public class ClientTraceProcessor extends AbstractProcessor
Modifier and Type | Class and Description |
---|---|
static class |
ClientTraceProcessor.Locality |
Constructor and Description |
---|
ClientTraceProcessor() |
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.