Uses of Interface
org.apache.storm.streams.operations.StateUpdater
Package
Description
-
Uses of StateUpdater in org.apache.storm.streams
Modifier and TypeMethodDescription<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
Modifier and TypeMethodDescriptionstatic <T,
S> StateUpdater<T, S> StateUpdater.of
(S initialValue, BiFunction<? super S, ? super T, ? extends S> stateUpdateFn) A static factory to create aStateUpdater
based on an initial value of the state and a state update function. -
Uses of StateUpdater in org.apache.storm.streams.processors