Uses of Class
org.apache.hadoop.chukwa.extraction.engine.ChukwaRecordKey

Packages that use ChukwaRecordKey

Package	Description
org.apache.hadoop.chukwa.analysis.salsa.fsm
org.apache.hadoop.chukwa.datacollection.writer.hbase
org.apache.hadoop.chukwa.extraction.demux
org.apache.hadoop.chukwa.extraction.demux.processor
org.apache.hadoop.chukwa.extraction.demux.processor.mapper
org.apache.hadoop.chukwa.extraction.demux.processor.reducer

Uses of ChukwaRecordKey in org.apache.hadoop.chukwa.analysis.salsa.fsm

Methods in org.apache.hadoop.chukwa.analysis.salsa.fsm with parameters of type ChukwaRecordKey

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)

Method parameters in org.apache.hadoop.chukwa.analysis.salsa.fsm with type arguments of type ChukwaRecordKey

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)

Uses of ChukwaRecordKey in org.apache.hadoop.chukwa.datacollection.writer.hbase

Methods in org.apache.hadoop.chukwa.datacollection.writer.hbase with parameters of type ChukwaRecordKey

Modifier and Type	Method and Description
void	OutputCollector.collect(ChukwaRecordKey key, ChukwaRecord value)

Uses of ChukwaRecordKey in org.apache.hadoop.chukwa.extraction.demux

Methods in org.apache.hadoop.chukwa.extraction.demux with parameters of type ChukwaRecordKey

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)

Method parameters in org.apache.hadoop.chukwa.extraction.demux with type arguments of type ChukwaRecordKey

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)

Uses of ChukwaRecordKey in org.apache.hadoop.chukwa.extraction.demux.processor

Methods in org.apache.hadoop.chukwa.extraction.demux.processor with parameters of type ChukwaRecordKey

Modifier and Type	Method and Description
void	ChukwaOutputCollector.collect(ChukwaRecordKey key, ChukwaRecord value)

Constructor parameters in org.apache.hadoop.chukwa.extraction.demux.processor with type arguments of type ChukwaRecordKey

Constructor and Description
ChukwaOutputCollector(String groupName, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> outputCollector, org.apache.hadoop.mapred.Reporter reporter)

Uses of ChukwaRecordKey in org.apache.hadoop.chukwa.extraction.demux.processor.mapper

Fields in org.apache.hadoop.chukwa.extraction.demux.processor.mapper declared as ChukwaRecordKey

Modifier and Type	Field and Description
protected ChukwaRecordKey	AbstractProcessor.key

Method parameters in org.apache.hadoop.chukwa.extraction.demux.processor.mapper with type arguments of type ChukwaRecordKey

Modifier and Type	Method and Description
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	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	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	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)
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)

Uses of ChukwaRecordKey in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

Methods in org.apache.hadoop.chukwa.extraction.demux.processor.reducer with parameters of type ChukwaRecordKey

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)

Method parameters in org.apache.hadoop.chukwa.extraction.demux.processor.reducer with type arguments of type ChukwaRecordKey

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)