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

Class DefaultProcessor

java.lang.Object

org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

org.apache.hadoop.chukwa.extraction.demux.processor.mapper.DefaultProcessor

All Implemented Interfaces:

MapProcessor

public class DefaultProcessor
extends AbstractProcessor

Field Summary

Fields inherited from class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

archiveKey, chunk, key

Constructor Summary

Constructors

Constructor and Description
DefaultProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	parse(String recordEntry, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)

Methods inherited from class org.apache.hadoop.chukwa.extraction.demux.processor.mapper.AbstractProcessor

buildGenericRecord, hasNext, nextLine, process, reset, saveChunkInError

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultProcessor

public DefaultProcessor()

Method Detail

parse

protected void parse(String recordEntry,
         org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
         org.apache.hadoop.mapred.Reporter reporter)

Specified by:

parse in class AbstractProcessor