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

Class MRJobReduceProcessor

java.lang.Object

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

All Implemented Interfaces:

ReduceProcessor

public class MRJobReduceProcessor
extends Object
implements ReduceProcessor

Constructor Summary

Constructors

Constructor and Description
MRJobReduceProcessor()

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MRJobReduceProcessor

public MRJobReduceProcessor()

Method Detail

getDataType

public String getDataType()

Specified by:

getDataType in interface ReduceProcessor

process

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

Specified by:

process in interface ReduceProcessor