public class DebugOutputProcessor extends AbstractProcessor
Modifier and Type | Field and Description |
---|---|
static String |
recordType |
archiveKey, chunk, key
Constructor and Description |
---|
DebugOutputProcessor() |
Modifier and Type | Method and Description |
---|---|
String |
getDataType() |
void |
parse(String line,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
buildGenericRecord, hasNext, nextLine, process, reset, saveChunkInError
public static final String recordType
public void parse(String line, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)
parse
in class AbstractProcessor
public String getDataType()
Copyright © ${year} The Apache Software Foundation