Uses of Interface
org.apache.storm.streams.operations.Function
Package
Description
-
Uses of Function in org.apache.storm.sql.runtime.streams.functions
Modifier and TypeClassDescriptionclass
class
class
class
-
Uses of Function in org.apache.storm.streams
Modifier and TypeMethodDescription<R> Stream<R>
Returns a stream consisting of the result of applying the given mapping function to the values of this stream.<R> PairStream<K,
R> Returns a new stream by applying aFunction
to the value of each key-value pairs in this stream. -
Uses of Function in org.apache.storm.streams.operations
Modifier and TypeInterfaceDescriptioninterface
FlatMapFunction<T,
R> A function that accepts one argument and returns anIterable
of elements as its result.interface
PairFlatMapFunction<T,
K, V> interface
PairFunction<T,
K, V> A function that accepts an argument and produces a key-value Pair.Modifier and TypeClassDescriptionclass
AFunction
that returns the input argument itself as the result. -
Uses of Function in org.apache.storm.streams.operations.mappers
Modifier and TypeInterfaceDescriptioninterface
A generic interface for mapping aTuple
to typed values.Modifier and TypeClassDescriptionclass
PairValueMapper<K,
V> Extracts a typed key-value pair from a tuple.class
ValueMapper<T>
Extracts a single typed value from a tuple.class
-
Uses of Function in org.apache.storm.streams.processors
ModifierConstructorDescriptionMapProcessor
(Function<T, R> function) MapValuesProcessor
(Function<V, R> function)