Uses of Interface
org.apache.flink.api.common.functions.Function

Packages that use Function

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base
org.apache.flink.api.java.functions
org.apache.flink.api.java.typeutils

Uses of Function in org.apache.flink.api.common.functions

Subinterfaces of Function in org.apache.flink.api.common.functions

Modifier and Type	Interface	Description
interface	AggregateFunction<IN,ACC,OUT>	The AggregateFunction is a flexible aggregation function, characterized by the following features: The aggregates may use different types for input values, intermediate aggregates, and result type, to support a wide range of aggregation types.
interface	CoGroupFunction<IN1,IN2,O>	The interface for CoGroup functions.
interface	CombineFunction<IN,OUT>	Generic interface used for combine functions ("combiners").
interface	CrossFunction<IN1,IN2,OUT>	Interface for Cross functions.
interface	FilterFunction<T>	A filter function is a predicate applied individually to each record.
interface	FlatJoinFunction<IN1,IN2,OUT>	Interface for Join functions.
interface	FlatMapFunction<T,O>	Base interface for flatMap functions.
interface	GroupCombineFunction<IN,OUT>	Generic interface used for combine functions ("combiners").
interface	GroupReduceFunction<T,O>	The interface for group reduce functions.
interface	JoinFunction<IN1,IN2,OUT>	Interface for Join functions.
interface	MapFunction<T,O>	Base interface for Map functions.
interface	MapPartitionFunction<T,O>	Interface for "mapPartition" functions.
interface	Partitioner<K>	Function to implement a custom partition assignment for keys.
interface	ReduceFunction<T>	Base interface for Reduce functions.
interface	RichFunction	An base interface for all rich user-defined functions.

Classes in org.apache.flink.api.common.functions that implement Function

Modifier and Type	Class	Description
class	AbstractRichFunction	An abstract stub implementation for rich user-defined functions.
class	RichAggregateFunction<IN,ACC,OUT>	Rich variant of the AggregateFunction.
class	RichCoGroupFunction<IN1,IN2,OUT>	Rich variant of the CoGroupFunction.
class	RichCrossFunction<IN1,IN2,OUT>	Rich variant of the CrossFunction.
class	RichFilterFunction<T>	Rich variant of the FilterFunction.
class	RichFlatJoinFunction<IN1,IN2,OUT>	Rich variant of the FlatJoinFunction.
class	RichFlatMapFunction<IN,OUT>	Rich variant of the FlatMapFunction.
class	RichGroupCombineFunction<IN,OUT>	Rich variant of the GroupCombineFunction.
class	RichGroupReduceFunction<IN,OUT>	Rich variant of the GroupReduceFunction.
class	RichJoinFunction<IN1,IN2,OUT>	Rich variant of the JoinFunction.
class	RichMapFunction<IN,OUT>	Rich variant of the MapFunction.
class	RichMapPartitionFunction<I,O>	Rich variant of the MapPartitionFunction.
class	RichReduceFunction<T>	Rich variant of the ReduceFunction.

Uses of Function in org.apache.flink.api.common.functions.util

Classes in org.apache.flink.api.common.functions.util that implement Function

Modifier and Type	Class	Description
class	NoOpFunction	An AbstractRichFunction that does nothing.

Methods in org.apache.flink.api.common.functions.util with parameters of type Function

Modifier and Type	Method	Description
static void	FunctionUtils.closeFunction(Function function)
static RuntimeContext	FunctionUtils.getFunctionRuntimeContext(Function function, RuntimeContext defaultContext)
static void	FunctionUtils.openFunction(Function function, OpenContext openContext)
static void	FunctionUtils.setFunctionRuntimeContext(Function function, RuntimeContext context)

Uses of Function in org.apache.flink.api.common.operators

Classes in org.apache.flink.api.common.operators with type parameters of type Function

Modifier and Type	Class	Description
class	AbstractUdfOperator<OUT,FT extends Function>	Abstract superclass for all contracts that represent actual operators.
class	DualInputOperator<IN1,IN2,OUT,FT extends Function>	Abstract operator superclass for all operators that have two inputs, like "Join", "CoGroup", or "Cross".
class	SingleInputOperator<IN,OUT,FT extends Function>	Abstract superclass for all operators that have one input like "map" or "reduce".

Uses of Function in org.apache.flink.api.common.operators.base

Classes in org.apache.flink.api.common.operators.base that implement Function

Modifier and Type	Class	Description
static class	BulkIterationBase.TerminationCriterionMapper<X>	Special Mapper that is added before a termination criterion and is only a container for an special aggregator

Uses of Function in org.apache.flink.api.java.functions

Subinterfaces of Function in org.apache.flink.api.java.functions

Modifier and Type	Interface	Description
interface	KeySelector<IN,KEY>	The KeySelector allows to use deterministic objects for operations such as reduce, reduceGroup, join, coGroup, etc.

Classes in org.apache.flink.api.java.functions that implement Function

Modifier and Type	Class	Description
class	NullByteKeySelector<T>	Used as a dummy KeySelector to allow using keyed operators for non-keyed use cases.

Uses of Function in org.apache.flink.api.java.typeutils

Methods in org.apache.flink.api.java.typeutils with parameters of type Function

Modifier and Type	Method	Description
static TypeExtractionUtils.LambdaExecutable	TypeExtractionUtils.checkAndExtractLambda(Function function)	Checks if the given function has been implemented using a Java 8 lambda.
static <IN1,IN2,OUT> TypeInformation<OUT>	TypeExtractor.getBinaryOperatorReturnType(Function function, Class<?> baseClass, int input1TypeArgumentIndex, int input2TypeArgumentIndex, int outputTypeArgumentIndex, int[] lambdaOutputTypeArgumentIndices, TypeInformation<IN1> in1Type, TypeInformation<IN2> in2Type, String functionName, boolean allowMissing)	Returns the binary operator's return type.
static <IN,OUT> TypeInformation<OUT>	TypeExtractor.getUnaryOperatorReturnType(Function function, Class<?> baseClass, int inputTypeArgumentIndex, int outputTypeArgumentIndex, int[] lambdaOutputTypeArgumentIndices, TypeInformation<IN> inType, String functionName, boolean allowMissing)	Returns the unary operator's return type.