Package org.apache.storm.streams
package org.apache.storm.streams
-
ClassDescriptionPair<T1,
T2> A pair of values.PairStream<K,V> Represents a stream of key-value pairs.Node that wraps a processor in the stream.Provides reference counting of tuples.Stream<T>Represents a stream of values.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)
.Node that captures the windowing configurations.