public class Log4jJobHistoryProcessor extends AbstractProcessor
archiveKey, chunk, key
Constructor and Description |
---|
Log4jJobHistoryProcessor() |
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) |
buildGenericRecord, hasNext, nextLine, process, reset, saveChunkInError
protected void parse(String recordEntry, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter) throws Throwable
parse
in class AbstractProcessor
Throwable
protected void extractCounters(ChukwaRecord record, String input)
public String getDataType()
Copyright © 2013 Apache Software Foundation. All Rights Reserved.