Uses of Package
org.apache.storm.streams.operations
Package
Description
-
ClassDescriptionA 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. -
ClassDescriptiona 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. -
ClassDescriptiona 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. -
ClassDescriptionInterface for aggregating values.The parent interface for any kind of streaming operation.
-
ClassDescriptionRepresents 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.
-
ClassDescriptionInterface 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.