Class StreamState<K,V>

java.lang.Object
org.apache.storm.streams.StreamState<K,V>
Type Parameters:
K - the key type
V - the value type
All Implemented Interfaces:
Serializable

public class StreamState<K,V> extends Object implements Serializable
A wrapper for the stream state which can be used to query the state via Stream.stateQuery(StreamState).
See Also:
  • Method Details