Uses of Package
org.apache.storm.streams.operations

Packages that use org.apache.storm.streams.operations

Package	Description
org.apache.storm.sql.runtime.streams.functions
org.apache.storm.streams
org.apache.storm.streams.operations
org.apache.storm.streams.operations.aggregators
org.apache.storm.streams.operations.mappers
org.apache.storm.streams.processors

Classes in org.apache.storm.streams.operations used by org.apache.storm.sql.runtime.streams.functions

Class and Description
FlatMapFunction A function that accepts one argument and returns an Iterable of elements as its result.
Function Represents a function that accepts one argument and produces a result.
Operation The parent interface for any kind of streaming operation.
PairFunction A function that accepts an argument and produces a key-value Pair.
Predicate Represents a predicate (boolean-valued function) of a value.

Classes in org.apache.storm.streams.operations used by org.apache.storm.streams

Class and Description
BiFunction a function that accepts two arguments and produces a result.
CombinerAggregator Interface for aggregating values.
Consumer Represents an operation that accepts a single input argument and returns no result.
FlatMapFunction A function that accepts one argument and returns an Iterable of elements as its result.
Function Represents a function that accepts one argument and produces a result.
PairFlatMapFunction A function that accepts one argument and returns an Iterable of Pair as its result.
PairFunction A function that accepts an argument and produces a key-value Pair.
Predicate Represents a predicate (boolean-valued function) of a value.
Reducer The Reducer performs an operation on two values of the same type producing a result of the same type.
StateUpdater Interface for updating state.
ValueJoiner An interface for joining two values to produce a result.

Classes in org.apache.storm.streams.operations used by org.apache.storm.streams.operations

Class and Description
BiFunction a function that accepts two arguments and produces a result.
CombinerAggregator Interface for aggregating values.
Consumer Represents an operation that accepts a single input argument and returns no result.
FlatMapFunction A function that accepts one argument and returns an Iterable of elements as its result.
Function Represents a function that accepts one argument and produces a result.
Operation The parent interface for any kind of streaming operation.
StateUpdater Interface for updating state.
ValueJoiner An interface for joining two values to produce a result.

Classes in org.apache.storm.streams.operations used by org.apache.storm.streams.operations.aggregators

Class and Description
CombinerAggregator Interface for aggregating values.
Operation The parent interface for any kind of streaming operation.

Classes in org.apache.storm.streams.operations used by org.apache.storm.streams.operations.mappers

Class and Description
Function Represents a function that accepts one argument and produces a result.
Operation The parent interface for any kind of streaming operation.
PairFunction 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.processors

Class and Description
CombinerAggregator Interface for aggregating values.
Consumer Represents an operation that accepts a single input argument and returns no result.
FlatMapFunction A function that accepts one argument and returns an Iterable of elements as its result.
Function Represents a function that accepts one argument and produces a result.
Predicate Represents a predicate (boolean-valued function) of a value.
Reducer The Reducer performs an operation on two values of the same type producing a result of the same type.
StateUpdater Interface for updating state.
ValueJoiner An interface for joining two values to produce a result.