Uses of Class
org.apache.storm.streams.StreamState
-
Uses of StreamState 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.<R> StreamState<K,
R> PairStream.updateStateByKey
(R initialValue, BiFunction<? super R, ? super V, ? extends R> stateUpdateFn) Update the state by applying the given state update function to the previous state of the key and the new value for the key.Modifier and TypeMethodDescription<V> PairStream<T,
V> Stream.stateQuery
(StreamState<T, V> streamState) Queries the given stream state with the values in this stream as the keys. -
Uses of StreamState in org.apache.storm.streams.processors