Uses of Package
org.apache.storm.streams.operations
Packages that use org.apache.storm.streams.operations
Package
Description
-
Classes in org.apache.storm.streams.operations used by org.apache.storm.sql.runtime.streams.functionsClassDescriptionA function that accepts one argument and returns an
Iterable
of elements as its result.Represents a function that accepts one argument and produces a result.The parent interface for any kind of streaming operation.A function that accepts an argument and produces a key-value Pair.Represents a predicate (boolean-valued function) of a value. -
Classes in org.apache.storm.streams.operations used by org.apache.storm.streamsClassDescriptiona function that accepts two arguments and produces a result.Interface for aggregating values.Represents an operation that accepts a single input argument and returns no result.A function that accepts one argument and returns an
Iterable
of elements as its result.Represents a function that accepts one argument and produces a result.A function that accepts an argument and produces a key-value Pair.Represents a predicate (boolean-valued function) of a value.TheReducer
performs an operation on two values of the same type producing a result of the same type.Interface for updating state.An interface for joining two values to produce a result. -
Classes in org.apache.storm.streams.operations used by org.apache.storm.streams.operationsClassDescriptiona function that accepts two arguments and produces a result.Interface for aggregating values.Represents an operation that accepts a single input argument and returns no result.A function that accepts one argument and returns an
Iterable
of elements as its result.Represents a function that accepts one argument and produces a result.The parent interface for any kind of streaming operation.Interface for updating state.An interface for joining two values to produce a result. -
Classes in org.apache.storm.streams.operations used by org.apache.storm.streams.operations.aggregatorsClassDescriptionInterface for aggregating values.The parent interface for any kind of streaming operation.
-
Classes in org.apache.storm.streams.operations used by org.apache.storm.streams.operations.mappersClassDescriptionRepresents a function that accepts one argument and produces a result.The parent interface for any kind of streaming operation.A function that accepts an argument and produces a key-value Pair.
-
Classes in org.apache.storm.streams.operations used by org.apache.storm.streams.processorsClassDescriptionInterface for aggregating values.Represents an operation that accepts a single input argument and returns no result.A function that accepts one argument and returns an
Iterable
of elements as its result.Represents a function that accepts one argument and produces a result.Represents a predicate (boolean-valued function) of a value.TheReducer
performs an operation on two values of the same type producing a result of the same type.Interface for updating state.An interface for joining two values to produce a result.