Interface | Description |
---|---|
KeySelector<IN,KEY> |
The
KeySelector allows to use deterministic objects for operations such as reduce,
reduceGroup, join, coGroup, etc. |
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 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.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.