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

Class HadoopLogProcessor

java.lang.Object

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

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

All Implemented Interfaces:

MapProcessor

public class HadoopLogProcessor
extends AbstractProcessor

Constructor Summary

Constructors

Constructor and Description
HadoopLogProcessor()

Method Summary

Modifier and Type	Method and Description
String	getDataType()
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

getCurrentPos, getStartOffset, process, setCurrentPos, setStartOffset

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopLogProcessor

public HadoopLogProcessor()

Method Detail

parse

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

Throws:

Throwable

getDataType

public String getDataType()