@InterfaceAudience.Public @InterfaceStability.Evolving public class TextSortReducer extends <any>
HFileOutputFormat
,
KeyValueSortReducer
,
PutSortReducer
Constructor and Description |
---|
TextSortReducer() |
Modifier and Type | Method and Description |
---|---|
protected void |
doSetup(Context context)
Handles common parameter initialization that a subclass might want to leverage.
|
Counter |
getBadLineCount() |
boolean |
getSkipBadLines() |
long |
getTs() |
void |
incrementBadLineCount(int count) |
protected void |
reduce(ImmutableBytesWritable rowKey,
java.lang.Iterable<Text> lines,
<any>.Context context) |
protected void |
setup(Context context)
Handles initializing this class with objects specific to it (i.e., the parser).
|
public long getTs()
public boolean getSkipBadLines()
public Counter getBadLineCount()
public void incrementBadLineCount(int count)
protected void setup(Context context)
doSetup
. Hence a subclass may choose to override this method
and call doSetup
as well before handling it's own custom params.context
- protected void doSetup(Context context)
context
- protected void reduce(ImmutableBytesWritable rowKey, java.lang.Iterable<Text> lines, <any>.Context context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException