Field Detail

• ts

  protected 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

  protected ImportTsv.TsvParser parser

• conf

  protected org.apache.hadoop.conf.Configuration conf

• cellVisibilityExpr

  protected String cellVisibilityExpr

• ttl

  protected long ttl

• kvCreator

  protected CellCreator kvCreator

• hfileOutPath

  private String hfileOutPath

Constructor Detail

• TsvImporterMapper

  public TsvImporterMapper()

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.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,Put>

  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,Put>

  Throws:

  IOException

• populatePut

  protected void populatePut(byte[] lineBytes,
                 ImportTsv.TsvParser.ParsedLine parsed,
                 Put put,
                 int i)
                      throws ImportTsv.TsvParser.BadTsvLineException,
                             IOException

  Throws:

  ImportTsv.TsvParser.BadTsvLineException

  IOException