Package org.apache.storm.streams

# 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:
  - Serialized Form

- ## Method Summary

  Modifier and Type
  Method
  Description
  `PairStream<K,V>`
  `toPairStream()`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Method Details

  - ### toPairStream

    public PairStream<K,V> toPairStream()