Package | Description |
---|---|
org.apache.storm.hbase.bolt.mapper | |
org.apache.storm.hbase.common | |
org.apache.storm.hbase.trident.mapper |
Modifier and Type | Method and Description |
---|---|
ColumnList |
HBaseMapper.columns(Tuple tuple)
Given a tuple, return a list of HBase columns to insert.
|
ColumnList |
SimpleHBaseMapper.columns(Tuple tuple) |
Modifier and Type | Method and Description |
---|---|
ColumnList |
ColumnList.addColumn(byte[] family,
byte[] qualifier,
byte[] value)
Add a standard HBase column.
|
ColumnList |
ColumnList.addColumn(byte[] family,
byte[] qualifier,
long ts,
byte[] value)
Add a standard HBase column.
|
ColumnList |
ColumnList.addColumn(IColumn column)
Add a standard HBase column given an instance of a class that implements the
IColumn interface. |
ColumnList |
ColumnList.addCounter(byte[] family,
byte[] qualifier,
long incr)
Add an HBase counter column.
|
ColumnList |
ColumnList.addCounter(ICounter counter)
Add an HBase counter column given an instance of a class that implements the
ICounter interface. |
ColumnList |
ColumnList.deleteColumn(byte[] family,
byte[] qualifier)
Remove a standard HBase column.
|
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.hbase.client.Mutation> |
HBaseClient.constructMutationReq(byte[] rowKey,
ColumnList cols,
org.apache.hadoop.hbase.client.Durability durability) |
Modifier and Type | Method and Description |
---|---|
ColumnList |
SimpleTridentHBaseMapper.columns(TridentTuple tuple) |
ColumnList |
TridentHBaseMapper.columns(TridentTuple tuple)
Given a tuple, return a list of HBase columns to insert.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.