public static class ImportTsv.TsvParser
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
ImportTsv.TsvParser.BadTsvLineException |
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ATTRIBUTES_COLUMN_SPEC |
static java.lang.String |
CELL_TTL_COLUMN_SPEC |
static java.lang.String |
CELL_VISIBILITY_COLUMN_SPEC |
static int |
DEFAULT_ATTRIBUTES_COLUMN_INDEX |
static int |
DEFAULT_CELL_TTL_COLUMN_INDEX |
static int |
DEFAULT_CELL_VISIBILITY_COLUMN_INDEX |
static int |
DEFAULT_TIMESTAMP_COLUMN_INDEX |
static java.lang.String |
ROWKEY_COLUMN_SPEC |
static java.lang.String |
TIMESTAMPKEY_COLUMN_SPEC |
Constructor and Description |
---|
TsvParser(java.lang.String columnsSpecification,
java.lang.String separatorStr) |
Modifier and Type | Method and Description |
---|---|
int |
getAttributesKeyColumnIndex() |
int |
getCellTTLColumnIndex() |
int |
getCellVisibilityColumnIndex() |
byte[] |
getFamily(int idx) |
byte[] |
getQualifier(int idx) |
int |
getRowKeyColumnIndex() |
int |
getTimestampKeyColumnIndex() |
boolean |
hasAttributes() |
boolean |
hasCellTTL() |
boolean |
hasCellVisibility() |
boolean |
hasTimestamp() |
org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine |
parse(byte[] lineBytes,
int length) |
Pair<java.lang.Integer,java.lang.Integer> |
parseRowKey(byte[] lineBytes,
int length)
Return starting position and length of row key from the specified line bytes.
|
public static final int DEFAULT_TIMESTAMP_COLUMN_INDEX
public static final java.lang.String ROWKEY_COLUMN_SPEC
public static final java.lang.String TIMESTAMPKEY_COLUMN_SPEC
public static final java.lang.String ATTRIBUTES_COLUMN_SPEC
public static final java.lang.String CELL_VISIBILITY_COLUMN_SPEC
public static final java.lang.String CELL_TTL_COLUMN_SPEC
public static final int DEFAULT_ATTRIBUTES_COLUMN_INDEX
public static final int DEFAULT_CELL_VISIBILITY_COLUMN_INDEX
public static final int DEFAULT_CELL_TTL_COLUMN_INDEX
public TsvParser(java.lang.String columnsSpecification, java.lang.String separatorStr)
columnsSpecification
- the list of columns to parser out, comma separated.
The row key should be the special token TsvParser.ROWKEY_COLUMN_SPECseparatorStr
- public boolean hasTimestamp()
public int getTimestampKeyColumnIndex()
public boolean hasAttributes()
public boolean hasCellVisibility()
public boolean hasCellTTL()
public int getAttributesKeyColumnIndex()
public int getCellVisibilityColumnIndex()
public int getCellTTLColumnIndex()
public int getRowKeyColumnIndex()
public byte[] getFamily(int idx)
public byte[] getQualifier(int idx)
public org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine parse(byte[] lineBytes, int length) throws ImportTsv.TsvParser.BadTsvLineException
public Pair<java.lang.Integer,java.lang.Integer> parseRowKey(byte[] lineBytes, int length) throws ImportTsv.TsvParser.BadTsvLineException
lineBytes
- length
- ImportTsv.TsvParser.BadTsvLineException