Uses of Package
org.apache.storm.streams.operations
-
Classes in org.apache.storm.streams.operations used by org.apache.storm.sql.runtime.streams.functions Class Description FlatMapFunction A function that accepts one argument and returns anIterable
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 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 anIterable
of elements as its result.Function Represents a function that accepts one argument and produces a result.PairFlatMapFunction PairFunction A function that accepts an argument and produces a key-value Pair.Predicate Represents a predicate (boolean-valued function) of a value.Reducer TheReducer
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 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 anIterable
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 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 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 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 anIterable
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 TheReducer
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.