Package org.apache.storm.trident.state
Interface StateUpdater<S extends State>
-
- All Superinterfaces:
Operation,Serializable
- All Known Implementing Classes:
AbstractRedisStateUpdater,BaseStateUpdater,CombinerAggStateUpdater,HdfsUpdater,HiveUpdater,JdbcUpdater,JmsUpdater,MapCombinerAggStateUpdater,MapReducerAggStateUpdater,RedisClusterStateUpdater,RedisStateUpdater,ReducerAggStateUpdater,TridentKafkaStateUpdater,WindowsStateUpdater
public interface StateUpdater<S extends State> extends Operation
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidupdateState(S state, List<TridentTuple> tuples, TridentCollector collector)
-
-
-
Method Detail
-
updateState
void updateState(S state, List<TridentTuple> tuples, TridentCollector collector)
-
-