Package org.apache.storm.jdbc.bolt
Class AbstractJdbcBolt
java.lang.Object
org.apache.storm.topology.base.BaseComponent
org.apache.storm.topology.base.BaseRichBolt
org.apache.storm.topology.base.BaseTickTupleAwareRichBolt
org.apache.storm.jdbc.bolt.AbstractJdbcBolt
- All Implemented Interfaces:
- Serializable,- IBolt,- IComponent,- IRichBolt
- Direct Known Subclasses:
- JdbcInsertBolt,- JdbcLookupBolt
- See Also:
- 
Field SummaryFieldsModifier and TypeFieldDescriptionprotected OutputCollectorprotected Stringprotected ConnectionProviderprotected JdbcClientprotected Integer
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidcleanup()Cleanup.voidprepare(Map<String, Object> map, TopologyContext topologyContext, OutputCollector outputCollector) Subclasses should call this to ensure output collector and connection provider are set up, and finally jdbcClient is initialized properly.Methods inherited from class org.apache.storm.topology.base.BaseTickTupleAwareRichBoltexecute, onTickTuple, processMethods inherited from class org.apache.storm.topology.base.BaseComponentgetComponentConfigurationMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.topology.IComponentdeclareOutputFields, getComponentConfiguration
- 
Field Details- 
collector
- 
jdbcClient
- 
configKey
- 
queryTimeoutSecs
- 
connectionProvider
 
- 
- 
Constructor Details- 
AbstractJdbcBoltConstructor.- Parameters:
- connectionProviderParam- database connection provider
 
 
- 
- 
Method Details- 
preparepublic void prepare(Map<String, Object> map, TopologyContext topologyContext, OutputCollector outputCollector) Subclasses should call this to ensure output collector and connection provider are set up, and finally jdbcClient is initialized properly. Called when a task for this component is initialized within a worker on the cluster. It provides the bolt with the environment in which the bolt executes.This includes the: - Parameters:
- map- The Storm configuration for this bolt. This is the configuration provided to the topology merged in with cluster configuration on this machine.
- topologyContext- This object can be used to get information about this task's place within the topology, including the task id and component id of this task, input and output information, etc.
- outputCollector- The collector is used to emit tuples from this bolt. Tuples can be emitted at any time, including the prepare and cleanup methods. The collector is thread-safe and should be saved as an instance variable of this bolt object.
 
- 
cleanuppublic void cleanup()Cleanup. Subclasses should call this to ensure connection provider can be also cleaned up.- Specified by:
- cleanupin interface- IBolt
- Overrides:
- cleanupin class- BaseRichBolt
 
 
-