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 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 Description static <T,S>
StateUpdater<T,S>StateUpdater. of(S initialValue, BiFunction<? super S,? super T,? extends S> stateUpdateFn)A static factory to create aStateUpdaterbased 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 Description UpdateStateByKeyProcessor(StateUpdater<V,R> stateUpdater)
-