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()