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

Copyright © 2014 The Apache Software Foundation. All Rights Reserved.