Uses of Interface
org.apache.storm.streams.operations.Function
-
-
Uses of Function in org.apache.storm.sql.runtime.streams.functions
Classes in org.apache.storm.sql.runtime.streams.functions that implement Function Modifier and Type Class Description class
EvaluationCalc
class
EvaluationFunction
class
StreamInsertMapToPairFunction
class
StreamsScanTupleValueMapper
-
Uses of Function in org.apache.storm.streams
Methods in org.apache.storm.streams with parameters of type Function Modifier and Type Method Description <R> Stream<R>
Stream. map(Function<? super T,? extends R> function)
Returns a stream consisting of the result of applying the given mapping function to the values of this stream.<R> PairStream<K,R>
PairStream. mapValues(Function<? super V,? extends R> function)
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
Subinterfaces of Function in org.apache.storm.streams.operations Modifier and Type Interface Description interface
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.Classes in org.apache.storm.streams.operations that implement Function Modifier and Type Class Description class
IdentityFunction<T>
AFunction
that returns the input argument itself as the result. -
Uses of Function in org.apache.storm.streams.operations.mappers
Subinterfaces of Function in org.apache.storm.streams.operations.mappers Modifier and Type Interface Description interface
TupleValueMapper<T>
A generic interface for mapping aTuple
to typed values.Classes in org.apache.storm.streams.operations.mappers that implement Function Modifier and Type Class Description class
PairValueMapper<K,V>
Extracts a typed key-value pair from a tuple.class
ValueMapper<T>
Extracts a single typed value from a tuple.class
ValuesMapper
-
Uses of Function in org.apache.storm.streams.processors
Constructors in org.apache.storm.streams.processors with parameters of type Function Constructor Description MapProcessor(Function<T,R> function)
MapValuesProcessor(Function<V,R> function)
-