JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
A
B
C
D
E
G
H
I
J
M
O
P
Q
S
T
U
W
A
AbstractJdbcBolt
- Class in
org.apache.storm.jdbc.bolt
AbstractJdbcBolt(ConnectionProvider)
- Constructor for class org.apache.storm.jdbc.bolt.
AbstractJdbcBolt
B
batchRetrieve(JdbcState, List<TridentTuple>)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcQuery
batchRetrieve(List<TridentTuple>)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState
beginCommit(Long)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState
C
cleanup()
- Method in class org.apache.storm.jdbc.bolt.
AbstractJdbcBolt
cleanup()
- Method in interface org.apache.storm.jdbc.common.
ConnectionProvider
called once when the system is shutting down, should be idempotent.
cleanup()
- Method in class org.apache.storm.jdbc.common.
HikariCPConnectionProvider
collector
- Variable in class org.apache.storm.jdbc.bolt.
AbstractJdbcBolt
Column
<
T
> - Class in
org.apache.storm.jdbc.common
A database table can be defined as a list of rows and each row can be defined as a list of columns where each column instance has a name, a value and a type.
Column(String, T, int)
- Constructor for class org.apache.storm.jdbc.common.
Column
Column(String, int)
- Constructor for class org.apache.storm.jdbc.common.
Column
commit(Long)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState
configKey
- Variable in class org.apache.storm.jdbc.bolt.
AbstractJdbcBolt
connectionProvider
- Variable in class org.apache.storm.jdbc.bolt.
AbstractJdbcBolt
ConnectionProvider
- Interface in
org.apache.storm.jdbc.common
Provides a database connection.
D
declareOutputFields(OutputFieldsDeclarer)
- Method in class org.apache.storm.jdbc.bolt.
JdbcInsertBolt
declareOutputFields(OutputFieldsDeclarer)
- Method in class org.apache.storm.jdbc.bolt.
JdbcLookupBolt
declareOutputFields(OutputFieldsDeclarer)
- Method in interface org.apache.storm.jdbc.mapper.
JdbcLookupMapper
declare what are the fields that this code will output.
declareOutputFields(OutputFieldsDeclarer)
- Method in class org.apache.storm.jdbc.mapper.
SimpleJdbcLookupMapper
E
equals(Object)
- Method in class org.apache.storm.jdbc.common.
Column
execute(Tuple)
- Method in class org.apache.storm.jdbc.bolt.
JdbcInsertBolt
execute(Tuple)
- Method in class org.apache.storm.jdbc.bolt.
JdbcLookupBolt
execute(TridentTuple, List<Values>, TridentCollector)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcQuery
executeInsertQuery(String, List<List<Column>>)
- Method in class org.apache.storm.jdbc.common.
JdbcClient
executeSql(String)
- Method in class org.apache.storm.jdbc.common.
JdbcClient
G
getColumnName()
- Method in class org.apache.storm.jdbc.common.
Column
getColumns(ITuple)
- Method in interface org.apache.storm.jdbc.mapper.
JdbcMapper
getColumns(ITuple)
- Method in class org.apache.storm.jdbc.mapper.
SimpleJdbcMapper
getColumnSchema(String)
- Method in class org.apache.storm.jdbc.common.
JdbcClient
getConnection()
- Method in interface org.apache.storm.jdbc.common.
ConnectionProvider
getConnection()
- Method in class org.apache.storm.jdbc.common.
HikariCPConnectionProvider
getJavaType(int)
- Static method in class org.apache.storm.jdbc.common.
Util
getSqlType()
- Method in class org.apache.storm.jdbc.common.
Column
getVal()
- Method in class org.apache.storm.jdbc.common.
Column
H
hashCode()
- Method in class org.apache.storm.jdbc.common.
Column
HikariCPConnectionProvider
- Class in
org.apache.storm.jdbc.common
HikariCPConnectionProvider(Map<String, Object>)
- Constructor for class org.apache.storm.jdbc.common.
HikariCPConnectionProvider
I
insert(String, List<List<Column>>)
- Method in class org.apache.storm.jdbc.common.
JdbcClient
J
jdbcClient
- Variable in class org.apache.storm.jdbc.bolt.
AbstractJdbcBolt
JdbcClient
- Class in
org.apache.storm.jdbc.common
JdbcClient(ConnectionProvider, int)
- Constructor for class org.apache.storm.jdbc.common.
JdbcClient
JdbcInsertBolt
- Class in
org.apache.storm.jdbc.bolt
Basic bolt for writing to any Database table.
JdbcInsertBolt(ConnectionProvider, JdbcMapper)
- Constructor for class org.apache.storm.jdbc.bolt.
JdbcInsertBolt
JdbcLookupBolt
- Class in
org.apache.storm.jdbc.bolt
Basic bolt for querying from any database.
JdbcLookupBolt(ConnectionProvider, String, JdbcLookupMapper)
- Constructor for class org.apache.storm.jdbc.bolt.
JdbcLookupBolt
JdbcLookupMapper
- Interface in
org.apache.storm.jdbc.mapper
JdbcMapper
- Interface in
org.apache.storm.jdbc.mapper
JdbcQuery
- Class in
org.apache.storm.jdbc.trident.state
JdbcQuery()
- Constructor for class org.apache.storm.jdbc.trident.state.
JdbcQuery
JdbcState
- Class in
org.apache.storm.jdbc.trident.state
JdbcState(Map, int, int, JdbcState.Options)
- Constructor for class org.apache.storm.jdbc.trident.state.
JdbcState
JdbcState.Options
- Class in
org.apache.storm.jdbc.trident.state
JdbcStateFactory
- Class in
org.apache.storm.jdbc.trident.state
JdbcStateFactory(JdbcState.Options)
- Constructor for class org.apache.storm.jdbc.trident.state.
JdbcStateFactory
JdbcUpdater
- Class in
org.apache.storm.jdbc.trident.state
JdbcUpdater()
- Constructor for class org.apache.storm.jdbc.trident.state.
JdbcUpdater
M
makeState(Map, IMetricsContext, int, int)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcStateFactory
O
Options()
- Constructor for class org.apache.storm.jdbc.trident.state.
JdbcState.Options
org.apache.storm.jdbc.bolt
- package org.apache.storm.jdbc.bolt
org.apache.storm.jdbc.common
- package org.apache.storm.jdbc.common
org.apache.storm.jdbc.mapper
- package org.apache.storm.jdbc.mapper
org.apache.storm.jdbc.trident.state
- package org.apache.storm.jdbc.trident.state
P
prepare(Map, TopologyContext, OutputCollector)
- Method in class org.apache.storm.jdbc.bolt.
AbstractJdbcBolt
prepare(Map, TopologyContext, OutputCollector)
- Method in class org.apache.storm.jdbc.bolt.
JdbcInsertBolt
prepare()
- Method in interface org.apache.storm.jdbc.common.
ConnectionProvider
method must be idempotent.
prepare()
- Method in class org.apache.storm.jdbc.common.
HikariCPConnectionProvider
prepare()
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState
Q
queryTimeoutSecs
- Variable in class org.apache.storm.jdbc.bolt.
AbstractJdbcBolt
S
select(String, List<Column>)
- Method in class org.apache.storm.jdbc.common.
JdbcClient
SimpleJdbcLookupMapper
- Class in
org.apache.storm.jdbc.mapper
SimpleJdbcLookupMapper(Fields, List<Column>)
- Constructor for class org.apache.storm.jdbc.mapper.
SimpleJdbcLookupMapper
SimpleJdbcMapper
- Class in
org.apache.storm.jdbc.mapper
SimpleJdbcMapper(String, ConnectionProvider)
- Constructor for class org.apache.storm.jdbc.mapper.
SimpleJdbcMapper
SimpleJdbcMapper(List<Column>)
- Constructor for class org.apache.storm.jdbc.mapper.
SimpleJdbcMapper
T
toString()
- Method in class org.apache.storm.jdbc.common.
Column
toTuple(ITuple, List<Column>)
- Method in interface org.apache.storm.jdbc.mapper.
JdbcLookupMapper
Converts a DB row to a list of storm values that can be emitted.
toTuple(ITuple, List<Column>)
- Method in class org.apache.storm.jdbc.mapper.
SimpleJdbcLookupMapper
U
updateState(List<TridentTuple>, TridentCollector)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState
updateState(JdbcState, List<TridentTuple>, TridentCollector)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcUpdater
Util
- Class in
org.apache.storm.jdbc.common
Util()
- Constructor for class org.apache.storm.jdbc.common.
Util
W
withConnectionProvider(ConnectionProvider)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState.Options
withInsertQuery(String)
- Method in class org.apache.storm.jdbc.bolt.
JdbcInsertBolt
withInsertQuery(String)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState.Options
withJdbcLookupMapper(JdbcLookupMapper)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState.Options
withMapper(JdbcMapper)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState.Options
withQueryTimeoutSecs(int)
- Method in class org.apache.storm.jdbc.bolt.
JdbcInsertBolt
withQueryTimeoutSecs(int)
- Method in class org.apache.storm.jdbc.bolt.
JdbcLookupBolt
withQueryTimeoutSecs(int)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState.Options
withSelectQuery(String)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState.Options
withTableName(String)
- Method in class org.apache.storm.jdbc.bolt.
JdbcInsertBolt
withTableName(String)
- Method in class org.apache.storm.jdbc.trident.state.
JdbcState.Options
A
B
C
D
E
G
H
I
J
M
O
P
Q
S
T
U
W
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2016
The Apache Software Foundation
. All Rights Reserved.