Uses of Package
org.apache.storm.streams
Package
Description
-
-
ClassDescriptionRepresents a stream of values.A builder for constructing a
StormTopology
via storm streams api (DSL). -
-
ClassDescriptionA pair of values.Represents a stream of key-value pairs.Represents a stream of values.A builder for constructing a
StormTopology
via storm streams api (DSL).A wrapper for the stream state which can be used to query the state viaStream.stateQuery(StreamState)
. -
-
-
ClassDescriptionA pair of values.Node that wraps a processor in the stream.Provides reference counting of tuples.A wrapper for the stream state which can be used to query the state via
Stream.stateQuery(StreamState)
. -