public class SimpleTridentHBaseMapper extends Object implements TridentHBaseMapper
| Constructor and Description | 
|---|
SimpleTridentHBaseMapper()  | 
| Modifier and Type | Method and Description | 
|---|---|
ColumnList | 
columns(TridentTuple tuple)
Given a tuple, return a list of HBase columns to insert. 
 | 
byte[] | 
rowKey(TridentTuple tuple)
Given a tuple, return the HBase rowkey. 
 | 
SimpleTridentHBaseMapper | 
withColumnFamily(String columnFamily)  | 
SimpleTridentHBaseMapper | 
withColumnFields(Fields columnFields)  | 
SimpleTridentHBaseMapper | 
withCounterFields(Fields counterFields)  | 
SimpleTridentHBaseMapper | 
withRowKeyField(String rowKeyField)  | 
public SimpleTridentHBaseMapper withRowKeyField(String rowKeyField)
public SimpleTridentHBaseMapper withColumnFields(Fields columnFields)
public SimpleTridentHBaseMapper withCounterFields(Fields counterFields)
public SimpleTridentHBaseMapper withColumnFamily(String columnFamily)
public byte[] rowKey(TridentTuple tuple)
TridentHBaseMapperGiven a tuple, return the HBase rowkey.
rowKey in interface TridentHBaseMapperpublic ColumnList columns(TridentTuple tuple)
TridentHBaseMapperGiven a tuple, return a list of HBase columns to insert.
columns in interface TridentHBaseMapperCopyright © 2022 The Apache Software Foundation. All rights reserved.