Package org.apache.flink.api.common.functions

Interface Summary

Interface	Description
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.
BroadcastVariableInitializer<T,O>	A broadcast variable initializer can be used to transform a broadcast variable into another format during initialization.
CoGroupFunction<IN1,IN2,O>	The interface for CoGroup functions.
CombineFunction<IN,OUT>	Generic interface used for combine functions ("combiners").
CrossFunction<IN1,IN2,OUT>	Interface for Cross functions.
FilterFunction<T>	A filter function is a predicate applied individually to each record.
FlatJoinFunction<IN1,IN2,OUT>	Interface for Join functions.
FlatMapFunction<T,O>	Base interface for flatMap functions.
Function	The base interface for all user-defined functions.
GroupCombineFunction<IN,OUT>	Generic interface used for combine functions ("combiners").
GroupReduceFunction<T,O>	The interface for group reduce functions.
IterationRuntimeContext	A specialization of the RuntimeContext available in iterative computations of the DataSet API.
JoinFunction<IN1,IN2,OUT>	Interface for Join functions.
MapFunction<T,O>	Base interface for Map functions.
MapPartitionFunction<T,O>	Interface for "mapPartition" functions.
OpenContext	The OpenContext interface provides necessary information required by the RichFunction when it is opened.
Partitioner<K>	Function to implement a custom partition assignment for keys.
ReduceFunction<T>	Base interface for Reduce functions.
RichFunction	An base interface for all rich user-defined functions.
RuntimeContext	A RuntimeContext contains information about the context in which functions are executed.
SerializerFactory	A factory for TypeSerializer implementations.

Class Summary

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

Exception Summary

Exception	Description
InvalidTypesException	A special case of the InvalidProgramException, indicating that the types used in an operation are invalid or inconsistent.