org.apache.hadoop.chukwa.extraction.demux.processor.reducer

Interface ReduceProcessor

All Known Implementing Classes:

ClientTrace, IdentityReducer, JobLogHistoryReduceProcessor, MRJobReduceProcessor, SystemMetrics

public interface ReduceProcessor

Method Summary

Methods

Modifier and Type	Method and Description
String	getDataType()
void	process(ChukwaRecordKey key, Iterator<ChukwaRecord> values, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)

Method Detail

getDataType

String getDataType()

process

void process(ChukwaRecordKey key,
           Iterator<ChukwaRecord> values,
           org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
           org.apache.hadoop.mapred.Reporter reporter)