Constructor Detail

• TextSortReducer

  public TextSortReducer()

Method Detail

• getTs

  public long getTs()

• getSkipBadLines

  public boolean getSkipBadLines()

• getBadLineCount

  public org.apache.hadoop.mapreduce.Counter getBadLineCount()

• incrementBadLineCount

  public void incrementBadLineCount(int count)

• setup

  protected void setup(org.apache.hadoop.mapreduce.Reducer.Context context)

  Handles initializing this class with objects specific to it (i.e., the parser). Common initialization that might be leveraged by a subsclass is done in doSetup. Hence a subclass may choose to override this method and call doSetup as well before handling it's own custom params.

  Overrides:

  setup in class org.apache.hadoop.mapreduce.Reducer<ImmutableBytesWritable,org.apache.hadoop.io.Text,ImmutableBytesWritable,KeyValue>

  Parameters:

  context -

• doSetup

  protected void doSetup(org.apache.hadoop.mapreduce.Reducer.Context context,
             org.apache.hadoop.conf.Configuration conf)

  Handles common parameter initialization that a subclass might want to leverage.

  Parameters:

  context -

  conf -

• reduce

  protected void reduce(ImmutableBytesWritable rowKey,
            Iterable<org.apache.hadoop.io.Text> lines,
            org.apache.hadoop.mapreduce.Reducer.Context context)
                 throws IOException,
                        InterruptedException

  Overrides:

  reduce in class org.apache.hadoop.mapreduce.Reducer<ImmutableBytesWritable,org.apache.hadoop.io.Text,ImmutableBytesWritable,KeyValue>

  Throws:

  IOException

  InterruptedException