@InterfaceAudience.Public @InterfaceStability.Stable public class TsvImporterMapper extends <any>
Modifier and Type | Field and Description |
---|---|
protected java.lang.String |
cellVisibilityExpr |
protected Configuration |
conf |
protected CellCreator |
kvCreator |
protected ImportTsv.TsvParser |
parser |
protected long |
ts
Timestamp for all inserted rows
|
protected long |
ttl |
Constructor and Description |
---|
TsvImporterMapper() |
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) |
void |
map(LongWritable offset,
Text value,
Context context)
Convert a line of TSV text into an HBase table row.
|
protected void |
populatePut(byte[] lineBytes,
org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine parsed,
Put put,
int i) |
protected void |
setup(Context context)
Handles initializing this class with objects specific to it (i.e., the parser).
|
protected long ts
protected ImportTsv.TsvParser parser
protected Configuration conf
protected java.lang.String cellVisibilityExpr
protected long ttl
protected CellCreator kvCreator
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
- public void map(LongWritable offset, Text value, Context context) throws java.io.IOException
java.io.IOException
protected void populatePut(byte[] lineBytes, org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine parsed, Put put, int i) throws ImportTsv.TsvParser.BadTsvLineException, java.io.IOException
ImportTsv.TsvParser.BadTsvLineException
java.io.IOException