Package org.apache.storm.streams
-
Class Summary Class Description Pair<T1,T2> A pair of values.PairStream<K,V> Represents a stream of key-value pairs.ProcessorNode Node that wraps a processor in the stream.RefCountedTuple Provides reference counting of tuples.Stream<T> Represents a stream of values.StreamBuilder A builder for constructing aStormTopology
via storm streams api (DSL).StreamState<K,V> A wrapper for the stream state which can be used to query the state viaStream.stateQuery(StreamState)
.StreamUtil WindowNode Node that captures the windowing configurations.