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

Class ReduceProcessorFactory

java.lang.Object

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

public class ReduceProcessorFactory
extends Object

Method Summary

Modifier and Type	Method and Description
static ReduceProcessor	getProcessor(String processorClass)
static void	register(String reduceType, ReduceProcessor processor) Register a specific parser for a ReduceProcessor implementation.

Methods inherited from class java.lang.Object

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

Method Detail

register

public static void register(String reduceType,
                            ReduceProcessor processor)

Register a specific parser for a ReduceProcessor implementation.

Parameters:

reduceType - is data type assigned by mapper

processor - is parser class for reducer

getProcessor

public static ReduceProcessor getProcessor(String processorClass)
                                    throws UnknownReduceTypeException

Throws:

UnknownReduceTypeException