Uses of Class
org.apache.storm.streams.StreamState

Packages that use StreamState

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

Uses of StreamState in org.apache.storm.streams

Methods in org.apache.storm.streams that return StreamState

Modifier and Type	Method and Description
<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.
<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.

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

Modifier and Type	Method and Description
<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

Methods in org.apache.storm.streams.processors that return StreamState

Modifier and Type	Method and Description
StreamState<K,V>	StateQueryProcessor.getStreamState()

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

Constructor and Description
StateQueryProcessor(StreamState<K,V> streamState)