storm.trident.state
Interface StateUpdater<S extends State>

All Superinterfaces:

Operation, java.io.Serializable

All Known Implementing Classes:

BaseStateUpdater, CombinerAggStateUpdater, MapCombinerAggStateUpdater, MapReducerAggStateUpdater, ReducerAggStateUpdater

public interface StateUpdater<S extends State>
extends Operation

Method Summary

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

Methods inherited from interface storm.trident.operation.Operation

cleanup, prepare

Method Detail

updateState

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