Package org.apache.storm.streams
package org.apache.storm.streams
-
ClassesClassDescriptionPair<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 aStormTopologyvia 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.