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

Class Log4jJobHistoryProcessor

java.lang.Object

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

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

All Implemented Interfaces:

MapProcessor

public class Log4jJobHistoryProcessor
extends AbstractProcessor

Field Summary

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

archiveKey, chunk, currentPos, key, startOffset

Constructor Summary

Constructors

Constructor and Description
Log4jJobHistoryProcessor()

Method Summary

Modifier and Type	Method and Description
protected void	extractCounters(ChukwaRecord record, String input)
String	getDataType()
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, getCurrentPos, getStartOffset, hasNext, nextLine, process, reset, saveChunkInError, setCurrentPos, setStartOffset

Methods inherited from class java.lang.Object

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

Constructor Detail

Log4jJobHistoryProcessor

public Log4jJobHistoryProcessor()

Method Detail

parse

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

Specified by:

parse in class AbstractProcessor

Throws:

Throwable

extractCounters

protected void extractCounters(ChukwaRecord record,
                               String input)

getDataType

public String getDataType()