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)
TridentHBaseMapper
Given a tuple, return the HBase rowkey.
rowKey
in interface TridentHBaseMapper
public ColumnList columns(TridentTuple tuple)
TridentHBaseMapper
Given a tuple, return a list of HBase columns to insert.
columns
in interface TridentHBaseMapper
Copyright © 2022 The Apache Software Foundation. All rights reserved.