Package org.apache.storm.trident.state

Interface StateUpdater<S extends State>

All Superinterfaces:

Operation, Serializable

All Known Implementing Classes:

AbstractRedisStateUpdater, BaseStateUpdater, CombinerAggStateUpdater, EsUpdater, HdfsUpdater, HiveUpdater, JdbcUpdater, JmsUpdater, MapCombinerAggStateUpdater, MapReducerAggStateUpdater, RedisClusterStateUpdater, RedisStateUpdater, ReducerAggStateUpdater, TridentKafkaStateUpdater, WindowsStateUpdater

public interface StateUpdater<S extends State>
extends Operation

Method Summary

Modifier and Type	Method	Description
void	updateState(S state, List<TridentTuple> tuples, TridentCollector collector)

Methods inherited from interface org.apache.storm.trident.operation.Operation

cleanup, prepare

Method Details

updateState

void updateState(S state,
 List<TridentTuple> tuples,
 TridentCollector collector)