Package org.apache.flink.api.java.functions

Interface Summary

Interface	Description
KeySelector<IN,KEY>	The KeySelector allows to use deterministic objects for operations such as reduce, reduceGroup, join, coGoup, etc.

Class Summary

Class	Description
FirstReducer<T>	Reducer that only emits the first N elements in a group.
FlatMapIterator<IN,OUT>	A convenience variant of the RichFlatMapFunction that returns elements through an iterator, rather then through a collector.
FormattingMapper<T>	Mapper that converts values to strings using a TextOutputFormat.TextFormatter.
FunctionAnnotation	This class defines Java annotations for semantic assertions that can be added to Flink functions.
GroupReduceIterator<IN,OUT>	Base class that simplifies reducing all values provided as Iterable.
IdPartitioner	Partitioner that partitions by id.
NullByteKeySelector<T>	Used as a dummy KeySelector to allow using keyed operators for non-keyed use cases.
SampleInCoordinator<T>	SampleInCoordinator wraps the sample logic of the coordinator side (the second phase of distributed sample algorithm).
SampleInPartition<T>	SampleInPartition wraps the sample logic on the partition side (the first phase of distributed sample algorithm).
SampleWithFraction<T>	A map partition function wrapper for sampling algorithms with fraction, the sample algorithm takes the partition iterator as input.
SelectByMaxFunction<T extends Tuple>	Function that enables selection by maximal value of a field.
SelectByMinFunction<T extends Tuple>	Function that enables selection by minimal value of a field.
SemanticPropUtil	Utility class that contains helper methods to work with SemanticProperties.

Annotation Types Summary

Annotation Type	Description
FunctionAnnotation.ForwardedFields	The ForwardedFields annotation declares fields which are never modified by the annotated function and which are forwarded at the same position to the output or unchanged copied to another position in the output.
FunctionAnnotation.ForwardedFieldsFirst	The ForwardedFieldsFirst annotation declares fields of the first input of a function which are never modified by the annotated function and which are forwarded at the same position to the output or unchanged copied to another position in the output.
FunctionAnnotation.ForwardedFieldsSecond	The ForwardedFieldsSecond annotation declares fields of the second input of a function which are never modified by the annotated function and which are forwarded at the same position to the output or unchanged copied to another position in the output.
FunctionAnnotation.NonForwardedFields	The NonForwardedFields annotation declares ALL fields which not preserved on the same position in a functions output.
FunctionAnnotation.NonForwardedFieldsFirst	The NonForwardedFieldsFirst annotation declares for a function ALL fields of its first input which are not preserved on the same position in its output.
FunctionAnnotation.NonForwardedFieldsSecond	The NonForwardedFieldsSecond annotation declares for a function ALL fields of its second input which are not preserved on the same position in its output.
FunctionAnnotation.ReadFields	The ReadFields annotation declares for a function all fields which it accesses and evaluates, i.e., all fields that are used by the function to compute its result.
FunctionAnnotation.ReadFieldsFirst	The ReadFieldsFirst annotation declares for a function all fields of the first input which it accesses and evaluates, i.e., all fields of the first input that are used by the function to compute its result.
FunctionAnnotation.ReadFieldsSecond	The ReadFieldsSecond annotation declares for a function all fields of the second input which it accesses and evaluates, i.e., all fields of the second input that are used by the function to compute its result.
FunctionAnnotation.SkipCodeAnalysis	The SkipCodeAnalysis annotation declares that a function will not be analyzed by Flink's code analysis capabilities independent of the configured CodeAnalysisMode.