Overview
Package
Class
Use
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
A
B
C
D
E
F
G
H
I
L
M
N
O
P
Q
R
S
T
U
V
W
A
AbstractHBaseBolt
- Class in
org.apache.storm.hbase.bolt
AbstractHBaseBolt(String, HBaseMapper)
- Constructor for class org.apache.storm.hbase.bolt.
AbstractHBaseBolt
addColumn(HBaseProjectionCriteria.ColumnMetaData)
- Method in class org.apache.storm.hbase.bolt.mapper.
HBaseProjectionCriteria
Only this column from the the columnFamily will be included as result of HBase lookup.
addColumn(byte[], byte[], long, byte[])
- Method in class org.apache.storm.hbase.common.
ColumnList
Add a standard HBase column.
addColumn(byte[], byte[], byte[])
- Method in class org.apache.storm.hbase.common.
ColumnList
Add a standard HBase column
addColumn(IColumn)
- Method in class org.apache.storm.hbase.common.
ColumnList
Add a standard HBase column given an instance of a class that implements the
IColumn
interface.
addColumnFamily(String)
- Method in class org.apache.storm.hbase.bolt.mapper.
HBaseProjectionCriteria
all columns from this family will be included as result of HBase lookup.
addCounter(byte[], byte[], long)
- Method in class org.apache.storm.hbase.common.
ColumnList
Add an HBase counter column.
addCounter(ICounter)
- Method in class org.apache.storm.hbase.common.
ColumnList
Add an HBase counter column given an instance of a class that implements the
ICounter
interface.
B
batchGet(List<Get>)
- Method in class org.apache.storm.hbase.common.
HBaseClient
batchMutate(List<Mutation>)
- Method in class org.apache.storm.hbase.common.
HBaseClient
batchRetrieve(HBaseState, List<TridentTuple>)
- Method in class org.apache.storm.hbase.trident.state.
HBaseQuery
batchRetrieve(List<TridentTuple>)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState
beginCommit(Long)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState
C
cacheSize
- Variable in class org.apache.storm.hbase.trident.state.
HBaseMapState.Options
collector
- Variable in class org.apache.storm.hbase.bolt.
AbstractHBaseBolt
columnFamily
- Variable in class org.apache.storm.hbase.trident.state.
HBaseMapState.Options
ColumnList
- Class in
org.apache.storm.hbase.common
Represents a list of HBase columns.
ColumnList()
- Constructor for class org.apache.storm.hbase.common.
ColumnList
ColumnList.AbstractColumn
- Class in
org.apache.storm.hbase.common
ColumnList.Column
- Class in
org.apache.storm.hbase.common
ColumnList.Counter
- Class in
org.apache.storm.hbase.common
columns(Tuple)
- Method in interface org.apache.storm.hbase.bolt.mapper.
HBaseMapper
Given a tuple, return a list of HBase columns to insert.
columns(Tuple)
- Method in class org.apache.storm.hbase.bolt.mapper.
SimpleHBaseMapper
columns(TridentTuple)
- Method in class org.apache.storm.hbase.trident.mapper.
SimpleTridentHBaseMapper
columns(TridentTuple)
- Method in interface org.apache.storm.hbase.trident.mapper.
TridentHBaseMapper
Given a tuple, return a list of HBase columns to insert.
commit(Long)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState
configKey
- Variable in class org.apache.storm.hbase.bolt.
AbstractHBaseBolt
configKey
- Variable in class org.apache.storm.hbase.trident.state.
HBaseMapState.Options
constructGetRequests(byte[], HBaseProjectionCriteria)
- Method in class org.apache.storm.hbase.common.
HBaseClient
constructMutationReq(byte[], ColumnList, Durability)
- Method in class org.apache.storm.hbase.common.
HBaseClient
D
declareOutputFields(OutputFieldsDeclarer)
- Method in class org.apache.storm.hbase.bolt.
HBaseBolt
declareOutputFields(OutputFieldsDeclarer)
- Method in class org.apache.storm.hbase.bolt.
HBaseLookupBolt
declareOutputFields(OutputFieldsDeclarer)
- Method in interface org.apache.storm.hbase.bolt.mapper.
HBaseValueMapper
declares the output fields for the lookup bolt.
E
execute(Tuple)
- Method in class org.apache.storm.hbase.bolt.
HBaseBolt
execute(Tuple)
- Method in class org.apache.storm.hbase.bolt.
HBaseLookupBolt
execute(TridentTuple, List<Values>, TridentCollector)
- Method in class org.apache.storm.hbase.trident.state.
HBaseQuery
F
family()
- Method in interface org.apache.storm.hbase.common.
IColumn
family()
- Method in interface org.apache.storm.hbase.common.
ICounter
G
getColumnFamilies()
- Method in class org.apache.storm.hbase.bolt.mapper.
HBaseProjectionCriteria
getColumnFamily()
- Method in class org.apache.storm.hbase.bolt.mapper.
HBaseProjectionCriteria.ColumnMetaData
getColumns()
- Method in class org.apache.storm.hbase.bolt.mapper.
HBaseProjectionCriteria
getColumns()
- Method in class org.apache.storm.hbase.common.
ColumnList
Get the list of column definitions.
getCounters()
- Method in class org.apache.storm.hbase.common.
ColumnList
Get the list of counter definitions.
getFamily()
- Method in class org.apache.storm.hbase.common.
ColumnList.AbstractColumn
getIncrement()
- Method in class org.apache.storm.hbase.common.
ColumnList.Counter
getQualifier()
- Method in class org.apache.storm.hbase.bolt.mapper.
HBaseProjectionCriteria.ColumnMetaData
getQualifier()
- Method in class org.apache.storm.hbase.common.
ColumnList.AbstractColumn
getTs()
- Method in class org.apache.storm.hbase.common.
ColumnList.Column
getValue()
- Method in class org.apache.storm.hbase.common.
ColumnList.Column
globalKey
- Variable in class org.apache.storm.hbase.trident.state.
HBaseMapState.Options
H
hasColumns()
- Method in class org.apache.storm.hbase.common.
ColumnList
Query to determine if we have column definitions.
hasCounters()
- Method in class org.apache.storm.hbase.common.
ColumnList
Query to determine if we have counter definitions.
HBaseBolt
- Class in
org.apache.storm.hbase.bolt
Basic bolt for writing to HBase.
HBaseBolt(String, HBaseMapper)
- Constructor for class org.apache.storm.hbase.bolt.
HBaseBolt
hBaseClient
- Variable in class org.apache.storm.hbase.bolt.
AbstractHBaseBolt
HBaseClient
- Class in
org.apache.storm.hbase.common
HBaseClient(Map<String, Object>, Configuration, String)
- Constructor for class org.apache.storm.hbase.common.
HBaseClient
HBaseLookupBolt
- Class in
org.apache.storm.hbase.bolt
Basic bolt for querying from HBase.
HBaseLookupBolt(String, HBaseMapper, HBaseValueMapper)
- Constructor for class org.apache.storm.hbase.bolt.
HBaseLookupBolt
HBaseMapper
- Interface in
org.apache.storm.hbase.bolt.mapper
Maps a
backtype.storm.tuple.Tuple
object to a row in an HBase table.
HBaseMapState
<
T
> - Class in
org.apache.storm.hbase.trident.state
HBaseMapState(HBaseMapState.Options<T>, Map, int)
- Constructor for class org.apache.storm.hbase.trident.state.
HBaseMapState
HBaseMapState.Factory
- Class in
org.apache.storm.hbase.trident.state
HBaseMapState.Factory(StateType, HBaseMapState.Options)
- Constructor for class org.apache.storm.hbase.trident.state.
HBaseMapState.Factory
HBaseMapState.Options
<
T
> - Class in
org.apache.storm.hbase.trident.state
HBaseMapState.Options()
- Constructor for class org.apache.storm.hbase.trident.state.
HBaseMapState.Options
HBaseProjectionCriteria
- Class in
org.apache.storm.hbase.bolt.mapper
Allows the user to specify the projection criteria.
HBaseProjectionCriteria()
- Constructor for class org.apache.storm.hbase.bolt.mapper.
HBaseProjectionCriteria
HBaseProjectionCriteria.ColumnMetaData
- Class in
org.apache.storm.hbase.bolt.mapper
HBaseProjectionCriteria.ColumnMetaData(String, String)
- Constructor for class org.apache.storm.hbase.bolt.mapper.
HBaseProjectionCriteria.ColumnMetaData
HBaseQuery
- Class in
org.apache.storm.hbase.trident.state
HBaseQuery()
- Constructor for class org.apache.storm.hbase.trident.state.
HBaseQuery
HBaseSecurityUtil
- Class in
org.apache.storm.hbase.security
This class provides util methods for storm-hbase connector communicating with secured HBase.
HBaseSecurityUtil()
- Constructor for class org.apache.storm.hbase.security.
HBaseSecurityUtil
HBaseState
- Class in
org.apache.storm.hbase.trident.state
HBaseState(Map, int, int, HBaseState.Options)
- Constructor for class org.apache.storm.hbase.trident.state.
HBaseState
HBaseState.Options
- Class in
org.apache.storm.hbase.trident.state
HBaseState.Options()
- Constructor for class org.apache.storm.hbase.trident.state.
HBaseState.Options
HBaseStateFactory
- Class in
org.apache.storm.hbase.trident.state
HBaseStateFactory(HBaseState.Options)
- Constructor for class org.apache.storm.hbase.trident.state.
HBaseStateFactory
HBaseUpdater
- Class in
org.apache.storm.hbase.trident.state
HBaseUpdater()
- Constructor for class org.apache.storm.hbase.trident.state.
HBaseUpdater
HBaseValueMapper
- Interface in
org.apache.storm.hbase.bolt.mapper
I
IColumn
- Interface in
org.apache.storm.hbase.common
Interface definition for classes that support being written to HBase as a regular column.
ICounter
- Interface in
org.apache.storm.hbase.common
Interface definition for classes that support being written to HBase as a counter column.
increment()
- Method in interface org.apache.storm.hbase.common.
ICounter
L
login(Map, Configuration)
- Static method in class org.apache.storm.hbase.security.
HBaseSecurityUtil
M
makeState(Map, IMetricsContext, int, int)
- Method in class org.apache.storm.hbase.trident.state.
HBaseMapState.Factory
makeState(Map, IMetricsContext, int, int)
- Method in class org.apache.storm.hbase.trident.state.
HBaseStateFactory
mapper
- Variable in class org.apache.storm.hbase.bolt.
AbstractHBaseBolt
multiGet(List<List<Object>>)
- Method in class org.apache.storm.hbase.trident.state.
HBaseMapState
multiPut(List<List<Object>>, List<T>)
- Method in class org.apache.storm.hbase.trident.state.
HBaseMapState
N
nonTransactional()
- Static method in class org.apache.storm.hbase.trident.state.
HBaseMapState
nonTransactional(HBaseMapState.Options<Object>)
- Static method in class org.apache.storm.hbase.trident.state.
HBaseMapState
O
opaque()
- Static method in class org.apache.storm.hbase.trident.state.
HBaseMapState
opaque(HBaseMapState.Options<OpaqueValue>)
- Static method in class org.apache.storm.hbase.trident.state.
HBaseMapState
org.apache.storm.hbase.bolt
- package org.apache.storm.hbase.bolt
org.apache.storm.hbase.bolt.mapper
- package org.apache.storm.hbase.bolt.mapper
org.apache.storm.hbase.common
- package org.apache.storm.hbase.common
org.apache.storm.hbase.security
- package org.apache.storm.hbase.security
org.apache.storm.hbase.trident.mapper
- package org.apache.storm.hbase.trident.mapper
org.apache.storm.hbase.trident.state
- package org.apache.storm.hbase.trident.state
P
prepare(Map, TopologyContext, OutputCollector)
- Method in class org.apache.storm.hbase.bolt.
AbstractHBaseBolt
prepare()
- Method in class org.apache.storm.hbase.trident.state.
HBaseState
Q
qualifier()
- Method in interface org.apache.storm.hbase.common.
IColumn
qualifier()
- Method in interface org.apache.storm.hbase.common.
ICounter
qualifier
- Variable in class org.apache.storm.hbase.trident.state.
HBaseMapState.Options
R
rowKey(Tuple)
- Method in interface org.apache.storm.hbase.bolt.mapper.
HBaseMapper
Given a tuple, return the HBase rowkey.
rowKey(Tuple)
- Method in class org.apache.storm.hbase.bolt.mapper.
SimpleHBaseMapper
rowKey(TridentTuple)
- Method in class org.apache.storm.hbase.trident.mapper.
SimpleTridentHBaseMapper
rowKey(TridentTuple)
- Method in interface org.apache.storm.hbase.trident.mapper.
TridentHBaseMapper
Given a tuple, return the HBase rowkey.
S
serializer
- Variable in class org.apache.storm.hbase.trident.state.
HBaseMapState.Options
SimpleHBaseMapper
- Class in
org.apache.storm.hbase.bolt.mapper
SimpleHBaseMapper()
- Constructor for class org.apache.storm.hbase.bolt.mapper.
SimpleHBaseMapper
SimpleTridentHBaseMapper
- Class in
org.apache.storm.hbase.trident.mapper
SimpleTridentHBaseMapper()
- Constructor for class org.apache.storm.hbase.trident.mapper.
SimpleTridentHBaseMapper
STORM_KEYTAB_FILE_KEY
- Static variable in class org.apache.storm.hbase.security.
HBaseSecurityUtil
STORM_USER_NAME_KEY
- Static variable in class org.apache.storm.hbase.security.
HBaseSecurityUtil
T
tableName
- Variable in class org.apache.storm.hbase.bolt.
AbstractHBaseBolt
tableName
- Variable in class org.apache.storm.hbase.trident.state.
HBaseMapState.Options
timestamp()
- Method in interface org.apache.storm.hbase.common.
IColumn
toBytes(Object)
- Static method in class org.apache.storm.hbase.common.
Utils
toLong(Object)
- Static method in class org.apache.storm.hbase.common.
Utils
toValues(ITuple, Result)
- Method in interface org.apache.storm.hbase.bolt.mapper.
HBaseValueMapper
transactional()
- Static method in class org.apache.storm.hbase.trident.state.
HBaseMapState
transactional(HBaseMapState.Options<TransactionalValue>)
- Static method in class org.apache.storm.hbase.trident.state.
HBaseMapState
TridentHBaseMapper
- Interface in
org.apache.storm.hbase.trident.mapper
Maps a
storm.trident.tuple.TridentTuple
object to a row in an HBase table.
U
updateState(List<TridentTuple>, TridentCollector)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState
updateState(HBaseState, List<TridentTuple>, TridentCollector)
- Method in class org.apache.storm.hbase.trident.state.
HBaseUpdater
Utils
- Class in
org.apache.storm.hbase.common
V
value()
- Method in interface org.apache.storm.hbase.common.
IColumn
W
withColumnFamily(String)
- Method in class org.apache.storm.hbase.bolt.mapper.
SimpleHBaseMapper
withColumnFamily(String)
- Method in class org.apache.storm.hbase.trident.mapper.
SimpleTridentHBaseMapper
withColumnFields(Fields)
- Method in class org.apache.storm.hbase.bolt.mapper.
SimpleHBaseMapper
withColumnFields(Fields)
- Method in class org.apache.storm.hbase.trident.mapper.
SimpleTridentHBaseMapper
withConfigKey(String)
- Method in class org.apache.storm.hbase.bolt.
HBaseBolt
withConfigKey(String)
- Method in class org.apache.storm.hbase.bolt.
HBaseLookupBolt
withConfigKey(String)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState.Options
withCounterFields(Fields)
- Method in class org.apache.storm.hbase.bolt.mapper.
SimpleHBaseMapper
withCounterFields(Fields)
- Method in class org.apache.storm.hbase.trident.mapper.
SimpleTridentHBaseMapper
withDurability(Durability)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState.Options
withMapper(TridentHBaseMapper)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState.Options
withProjectionCriteria(HBaseProjectionCriteria)
- Method in class org.apache.storm.hbase.bolt.
HBaseLookupBolt
withProjectionCriteria(HBaseProjectionCriteria)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState.Options
withRowKeyField(String)
- Method in class org.apache.storm.hbase.bolt.mapper.
SimpleHBaseMapper
withRowKeyField(String)
- Method in class org.apache.storm.hbase.trident.mapper.
SimpleTridentHBaseMapper
withRowToStormValueMapper(HBaseValueMapper)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState.Options
withTableName(String)
- Method in class org.apache.storm.hbase.trident.state.
HBaseState.Options
writeToWAL(boolean)
- Method in class org.apache.storm.hbase.bolt.
HBaseBolt
A
B
C
D
E
F
G
H
I
L
M
N
O
P
Q
R
S
T
U
V
W
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
Copyright © 2014
The Apache Software Foundation
. All Rights Reserved.