Modifier and Type | Method and Description |
---|---|
protected boolean |
JobHistoryTaskDataMapper.expandReduceEnd(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
FSMIntermedEntry this_rec) |
protected boolean |
JobHistoryTaskDataMapper.expandReduceStart(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
FSMIntermedEntry this_rec) |
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) |
protected void |
TaskTrackerClientTraceMapper.parseClientTraceDetailed(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
ArrayList<String> fieldNamesList) |
protected void |
DataNodeClientTraceMapper.parseClientTraceDetailed(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
ArrayList<String> fieldNamesList) |
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 |
---|---|
protected boolean |
JobHistoryTaskDataMapper.expandReduceEnd(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
FSMIntermedEntry this_rec) |
protected boolean |
JobHistoryTaskDataMapper.expandReduceStart(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
FSMIntermedEntry this_rec) |
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) |
protected void |
TaskTrackerClientTraceMapper.parseClientTraceDetailed(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
ArrayList<String> fieldNamesList) |
protected void |
DataNodeClientTraceMapper.parseClientTraceDetailed(ChukwaRecordKey key,
ChukwaRecord val,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,FSMIntermedEntry> output,
org.apache.hadoop.mapred.Reporter reporter,
ArrayList<String> fieldNamesList) |
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 |
OutputCollector.collect(ChukwaRecordKey key,
ChukwaRecord value) |
Modifier and Type | Method and Description |
---|---|
protected String |
ChukwaRecordOutputFormat.generateFileNameForKeyValue(ChukwaRecordKey key,
ChukwaRecord record,
String name) |
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 | Field and Description |
---|---|
protected ChukwaRecordKey |
AbstractProcessor.key |
Modifier and Type | Method and Description |
---|---|
protected void |
ZookeeperProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
YWatch.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
TsProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
Torque.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
Top.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
SystemMetrics.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
SysLog.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
Sar.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
Ps.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
PbsNodes.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
NamenodeProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
Log4JMetricsContextProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
Log4jJobHistoryProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
JPluginMapper.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
JobTrackerProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
JobSummary.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
JobLogHistoryProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
JobLog.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
JobConfProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
Iostat.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
HBaseRegionServerProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
HBaseMasterProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
HadoopMetricsProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
HadoopLogProcessor.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
Df.parse(String recordEntry,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
protected void |
DefaultProcessor.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) |
protected void |
DatanodeProcessor.parse(String recordEntry,
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) |
protected abstract void |
AbstractProcessor.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) |
Copyright © 2014 Apache Software Foundation. All Rights Reserved.