Field Detail

• ts

  private long ts

  Timestamp for all inserted rows

• separator

  private String separator

  Column seperator

• skipBadLines

  private boolean skipBadLines

  Should skip bad lines

• badLineCount

  private org.apache.hadoop.mapreduce.Counter badLineCount

• parser

  private ImportTsv.TsvParser parser

• cellVisibilityExpr

  private String cellVisibilityExpr

  Cell visibility expr

• ttl

  private long ttl

  Cell TTL

• kvCreator

  private CellCreator kvCreator

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)

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

  Parameters:

  context -

• 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