Uses of Interface
org.apache.storm.streams.operations.StateUpdater

Packages that use StateUpdater

Package	Description
org.apache.storm.streams
org.apache.storm.streams.operations
org.apache.storm.streams.processors

Uses of StateUpdater in org.apache.storm.streams

Methods in org.apache.storm.streams with parameters of type StateUpdater

Modifier and Type	Method and Description
<R> StreamState<K,R>	PairStream.updateStateByKey(StateUpdater<? super V,? extends R> stateUpdater) Update the state by applying the given state update function to the previous state of the key and the new value for the key.

Uses of StateUpdater in org.apache.storm.streams.operations

Methods in org.apache.storm.streams.operations that return StateUpdater

Modifier and Type	Method and Description
static <T,S> StateUpdater<T,S>	StateUpdater.of(S initialValue, BiFunction<? super S,? super T,? extends S> stateUpdateFn) A static factory to create a StateUpdater based on an initial value of the state and a state update function.

Uses of StateUpdater in org.apache.storm.streams.processors

Constructors in org.apache.storm.streams.processors with parameters of type StateUpdater

Constructor and Description
UpdateStateByKeyProcessor(StateUpdater<V,R> stateUpdater)