public class HadoopLogProcessor extends AbstractProcessor
Constructor and Description |
---|
HadoopLogProcessor() |
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) |
getCurrentPos, getStartOffset, process, setCurrentPos, setStartOffset
public void parse(String recordEntry, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter) throws Throwable
Throwable
public String getDataType()
Copyright © 2016 Apache Software Foundation. All Rights Reserved.