public abstract class AbstractProcessor extends Object implements MapProcessor
Constructor and Description |
---|
AbstractProcessor() |
Modifier and Type | Method and Description |
---|---|
int |
getCurrentPos() |
int |
getStartOffset() |
void |
process(ChukwaArchiveKey archiveKey,
Chunk chunk,
org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output,
org.apache.hadoop.mapred.Reporter reporter) |
void |
setCurrentPos(int currentPos) |
void |
setStartOffset(int startOffset) |
public void process(ChukwaArchiveKey archiveKey, Chunk chunk, org.apache.hadoop.mapred.OutputCollector<ChukwaRecordKey,ChukwaRecord> output, org.apache.hadoop.mapred.Reporter reporter)
process
in interface MapProcessor
public int getCurrentPos()
public void setCurrentPos(int currentPos)
public int getStartOffset()
public void setStartOffset(int startOffset)
Copyright © 2016 Apache Software Foundation. All Rights Reserved.