Class JdbcState
- java.lang.Object
-
- org.apache.storm.jdbc.trident.state.JdbcState
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classJdbcState.Options
-
Constructor Summary
Constructors Modifier Constructor Description protectedJdbcState(Map<String,Object> map, int partitionIndex, int numPartitions, JdbcState.Options options)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description List<List<Values>>batchRetrieve(List<TridentTuple> tridentTuples)voidbeginCommit(Long someLong)voidcommit(Long someLong)protected voidprepare()voidupdateState(List<TridentTuple> tuples, TridentCollector collector)
-
-
-
Constructor Detail
-
JdbcState
protected JdbcState(Map<String,Object> map, int partitionIndex, int numPartitions, JdbcState.Options options)
-
-
Method Detail
-
prepare
protected void prepare()
-
beginCommit
public void beginCommit(Long someLong)
- Specified by:
beginCommitin interfaceState
-
updateState
public void updateState(List<TridentTuple> tuples, TridentCollector collector)
-
batchRetrieve
public List<List<Values>> batchRetrieve(List<TridentTuple> tridentTuples)
-
-