storm.trident.state

Interface StateUpdater<S extends State>

All Superinterfaces:

Operation, Serializable

All Known Implementing Classes:

BaseStateUpdater, CombinerAggStateUpdater, MapCombinerAggStateUpdater, MapReducerAggStateUpdater, ReducerAggStateUpdater

public interface StateUpdater<S extends State>
extends Operation

Method Summary

Methods

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

Methods inherited from interface storm.trident.operation.Operation

cleanup, prepare

Method Detail

updateState

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