Field Detail

• 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

Constructor Detail

• TsvImporterTextMapper

  public TsvImporterTextMapper()

Method Detail

• 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.Mapper.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.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,ImmutableBytesWritable,org.apache.hadoop.io.Text>

  Parameters:

  context -

• doSetup

  protected void doSetup(org.apache.hadoop.mapreduce.Mapper.Context context)

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

  Parameters:

  context -

• map

  public void map(org.apache.hadoop.io.LongWritable offset,
         org.apache.hadoop.io.Text value,
         org.apache.hadoop.mapreduce.Mapper.Context context)
           throws IOException

  Convert a line of TSV text into an HBase table row.

  Overrides:

  map in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text,ImmutableBytesWritable,org.apache.hadoop.io.Text>

  Throws:

  IOException