Class JdbcQuery
java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.state.BaseQueryFunction<JdbcState,List<Values>>
 
org.apache.storm.jdbc.trident.state.JdbcQuery
- All Implemented Interfaces:
- Serializable,- EachOperation,- Operation,- QueryFunction<JdbcState,- List<Values>> 
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionbatchRetrieve(JdbcState jdbcState, List<TridentTuple> tridentTuples) voidexecute(TridentTuple tuples, List<Values> values, TridentCollector tridentCollector) Methods inherited from class org.apache.storm.trident.operation.BaseOperationcleanup, prepare
- 
Constructor Details- 
JdbcQuerypublic JdbcQuery()
 
- 
- 
Method Details- 
batchRetrieve
- 
execute
 
-