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

Packages that use ChukwaRecord

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
org.apache.hadoop.chukwa.extraction.engine.datasource.record

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

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

Modifier and Type	Method and Description
protected void	FSMBuilder.FSMReducer.addStitchingFields_blockread(ChukwaRecord cr, ArrayList<String> fnl) Populates fields used by Pig script for stitching together causal flows
protected void	FSMBuilder.FSMReducer.addStitchingFields_blockwrite(ChukwaRecord cr, ArrayList<String> fnl)
protected void	FSMBuilder.FSMReducer.addStitchingFields_map(ChukwaRecord cr, ArrayList<String> fnl) Populates fields used by Pig script for stitching together causal flows
protected void	FSMBuilder.FSMReducer.addStitchingFields_redreducer(ChukwaRecord cr, ArrayList<String> fnl) Populates fields used by Pig script for stitching together causal flows
protected void	FSMBuilder.FSMReducer.addStitchingFields_redshufwait(ChukwaRecord cr, ArrayList<String> fnl) Populates fields used by Pig script for stitching together causal flows
protected void	FSMBuilder.FSMReducer.addStitchingFields_redsort(ChukwaRecord cr, ArrayList<String> fnl) Populates fields used by Pig script for stitching together causal flows
protected void	FSMBuilder.FSMReducer.addStitchingFields_shuffle(ChukwaRecord cr, ArrayList<String> fnl) Populates fields used by Pig script for stitching together causal flows
void	FSMBuilder.FSMReducer.addStitchingFields(ChukwaRecord cr)
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)
protected FSMIntermedEntry	JobHistoryTaskDataMapper.populateRecord_MapCounters(FSMIntermedEntry this_rec, ChukwaRecord val, ArrayList<String> fieldNamesList)
protected FSMIntermedEntry	JobHistoryTaskDataMapper.populateRecord_ReduceCounters(FSMIntermedEntry this_rec, ChukwaRecord val, ArrayList<String> fieldNamesList)

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

Modifier and Type	Method and Description
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 ChukwaRecord in org.apache.hadoop.chukwa.datacollection.writer.hbase

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

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

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

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

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)

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

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)
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 ChukwaRecord in org.apache.hadoop.chukwa.extraction.demux.processor

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

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 ChukwaRecord

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

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

Methods in org.apache.hadoop.chukwa.extraction.demux.processor.mapper that return ChukwaRecord

Modifier and Type	Method and Description
static ChukwaRecord	ChunkSaver.saveChunk(Chunk chunk, Throwable throwable, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)

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

Modifier and Type	Method and Description
protected void	JobSummary.buildGenericRecord(ChukwaRecord record, long timestamp, String dataSource)
protected void	AbstractProcessor.buildGenericRecord(ChukwaRecord record, String body, long timestamp, String dataSource)
protected void	HadoopMetricsProcessor.buildJVMRecord(ChukwaRecord record, long timestamp, String dataSource)
protected void	Log4jJobHistoryProcessor.extractCounters(ChukwaRecord record, String input)
protected void	JobLogHistoryProcessor.extractCounters(ChukwaRecord record, String input)
protected static void	PbsNodes.parsePbsRecord(String recordLine, ChukwaRecord record)
protected static void	PbsNodes.parseStatusField(String statusField, ChukwaRecord record)
void	Top.parseSummary(ChukwaRecord record, String header)

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

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)
void	ChunkProcessor.process(Chunk chunk, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.io.Text,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 ChukwaRecord in org.apache.hadoop.chukwa.extraction.demux.processor.reducer

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

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	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	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	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	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	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)
void	ClientTrace.process(ChukwaRecordKey key, Iterator<ChukwaRecord> values, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)

Uses of ChukwaRecord in org.apache.hadoop.chukwa.extraction.engine.datasource.record

Methods in org.apache.hadoop.chukwa.extraction.engine.datasource.record with parameters of type ChukwaRecord

Modifier and Type	Method and Description
protected static boolean	ChukwaSequenceFileParser.isValid(ChukwaRecord record, String filter)
protected boolean	ChukwaRecordDataSource.isValid(ChukwaRecord record, String filter)