Uses of Package
org.apache.storm.streams
-
Classes in org.apache.storm.streams used by org.apache.storm.sql Class Description Stream Represents a stream of values. -
Classes in org.apache.storm.streams used by org.apache.storm.sql.planner.streams Class Description Stream Represents a stream of values.StreamBuilder A builder for constructing aStormTopology
via storm streams api (DSL). -
Classes in org.apache.storm.streams used by org.apache.storm.sql.runtime.streams.functions Class Description Pair A pair of values. -
Classes in org.apache.storm.streams used by org.apache.storm.streams Class Description Pair A pair of values.PairStream Represents a stream of key-value pairs.Stream Represents a stream of values.StreamBuilder A builder for constructing aStormTopology
via storm streams api (DSL).StreamState A wrapper for the stream state which can be used to query the state viaStream.stateQuery(StreamState)
. -
Classes in org.apache.storm.streams used by org.apache.storm.streams.operations Class Description Pair A pair of values. -
Classes in org.apache.storm.streams used by org.apache.storm.streams.operations.mappers Class Description Pair A pair of values. -
Classes in org.apache.storm.streams used by org.apache.storm.streams.processors Class Description Pair A pair of values.ProcessorNode Node that wraps a processor in the stream.RefCountedTuple Provides reference counting of tuples.StreamState A wrapper for the stream state which can be used to query the state viaStream.stateQuery(StreamState)
. -
Classes in org.apache.storm.streams used by org.apache.storm.windowing Class Description Pair A pair of values.