Modifier and Type | Method and Description |
---|---|
int |
FSMIntermedEntryPartitioner.getPartition(ChukwaRecordKey key,
FSMIntermedEntry val,
int numPartitions) |
void |
TaskTrackerClientTraceMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
JobHistoryTaskDataMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
DataNodeClientTraceMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
FSMBuilder.FSMReducer.reduce(ChukwaRecordKey key,
Iterator<FSMIntermedEntry> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
TaskTrackerClientTraceMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
JobHistoryTaskDataMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
DataNodeClientTraceMapper.map(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
FSMBuilder.FSMReducer.reduce(ChukwaRecordKey key,
Iterator<FSMIntermedEntry> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
int |
ChukwaRecordPartitioner.getPartition(ChukwaRecordKey key,
ChukwaRecord record,
int numReduceTasks) |
void |
Demux.ReduceClass.reduce(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
Demux.MapClass.map(ChukwaArchiveKey key,
ChunkImpl chunk,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
Demux.ReduceClass.reduce(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
ChukwaOutputCollector.collect(ChukwaRecordKey key,
ChukwaRecord value) |
Constructor and Description |
---|
ChukwaOutputCollector(String groupName,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> outputCollector,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
HadoopLogProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
DebugOutputProcessor.parse(String line,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
ClientTraceProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
MapProcessor.process(ChukwaArchiveKey archiveKey,
Chunk chunk,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
AbstractProcessor.process(ChukwaArchiveKey archiveKey,
Chunk chunk,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
static ChukwaRecord |
ChunkSaver.saveChunk(Chunk chunk,
Throwable throwable,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
SystemMetrics.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
ReduceProcessor.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
MRJobReduceProcessor.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
JobLogHistoryReduceProcessor.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
IdentityReducer.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
ClientTrace.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
void |
SystemMetrics.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
ReduceProcessor.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
MRJobReduceProcessor.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
JobLogHistoryReduceProcessor.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
IdentityReducer.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
ClientTrace.process(ChukwaRecordKey key,
Iterator<ChukwaRecord> values,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
ChukwaRecordKey |
ChukwaDSInternalResult.getKey() |
Copyright © 2016 Apache Software Foundation. All Rights Reserved.