Uses of Interface
org.apache.storm.streams.operations.Function

Packages that use Function

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

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 and 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 and 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 a Function 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 and Description
interface	FlatMapFunction<T,R> A function that accepts one argument and returns an Iterable of elements as its result.
interface	PairFlatMapFunction<T,K,V> A function that accepts one argument and returns an Iterable of Pair as its result.
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 and Description
class	IdentityFunction<T> A Function 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 and Description
interface	TupleValueMapper<T> A generic interface for mapping a Tuple to typed values.

Classes in org.apache.storm.streams.operations.mappers that implement Function

Modifier and Type	Class and 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 Constructs a Values from a Tuple based on indicies.

Uses of Function in org.apache.storm.streams.processors

Constructors in org.apache.storm.streams.processors with parameters of type Function

Constructor and Description
MapProcessor(Function<T,R> function)
MapValuesProcessor(Function<V,R> function)