All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary
| Class |
Description |
| AbstractParameterTool |
|
| AggregateOperator<IN> |
Deprecated.
|
| AggregationFunction<T> |
|
| AggregationFunctionFactory |
|
| Aggregations |
Deprecated.
|
| Aggregator<T,R> |
Generic interface for aggregation.
|
| BernoulliSampler<T> |
A sampler implementation built upon a Bernoulli trail.
|
| BlockingShuffleOutputFormat<T> |
This is the inner OutputFormat used for specify the BLOCKING_PERSISTENT result partition type of
coming edge.
|
| BooleanColumnSummary |
Deprecated.
|
| BooleanSummaryAggregator |
|
| BulkIterationResultSet<T> |
Resulting DataSet of bulk iterations. |
| CoGroupOperator<I1,I2,OUT> |
Deprecated.
|
| CoGroupOperator.CoGroupOperatorSets<I1,I2> |
Intermediate step of a CoGroup transformation.
|
| CoGroupRawOperator<I1,I2,OUT> |
A DataSet that is the result of a CoGroup transformation. |
| CollectionEnvironment |
Deprecated.
|
| CollectionInputFormat<T> |
Deprecated.
|
| ColumnSummary |
Deprecated.
|
| CombineToGroupCombineWrapper<IN,OUT,F extends org.apache.flink.api.common.functions.CombineFunction<IN,IN> & org.apache.flink.api.common.functions.GroupReduceFunction<IN,OUT>> |
A wrapper the wraps a function that implements both CombineFunction and GroupReduceFunction interfaces and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime.
|
| CompensatedSum |
Used to calculate sums using the Kahan summation algorithm.
|
| CrossOperator<I1,I2,OUT> |
Deprecated.
|
| CrossOperator.CrossProjection<I1,I2> |
|
| CrossOperator.DefaultCross<I1,I2> |
A Cross transformation that wraps pairs of crossed elements into Tuple2.
|
| CrossOperator.ProjectCross<I1,I2,OUT extends org.apache.flink.api.java.tuple.Tuple> |
A Cross transformation that projects crossing elements or fields of crossing Tuples into result Tuples.
|
| CrossOperator.ProjectCrossFunction<T1,T2,R extends org.apache.flink.api.java.tuple.Tuple> |
|
| CsvInputFormat<OUT> |
InputFormat that reads csv files.
|
| CsvOutputFormat<T extends org.apache.flink.api.java.tuple.Tuple> |
Deprecated.
|
| CsvReader |
Deprecated.
|
| CustomUnaryOperation<IN,OUT> |
Deprecated.
|
| DataSet<T> |
Deprecated.
|
| DataSetUtils |
Deprecated.
|
| DataSink<T> |
Deprecated.
|
| DataSource<OUT> |
Deprecated.
|
| DeltaIteration<ST,WT> |
Deprecated.
|
| DeltaIteration.SolutionSetPlaceHolder<ST> |
A DataSet that acts as a placeholder for the solution set during the iteration. |
| DeltaIteration.WorksetPlaceHolder<WT> |
A DataSet that acts as a placeholder for the workset during the iteration. |
| DeltaIterationResultSet<ST,WT> |
Deprecated.
|
| DiscardingOutputFormat<T> |
Deprecated.
|
| DistinctOperator<T> |
Deprecated.
|
| DistributedRandomSampler<T> |
For sampling with fraction, the sample algorithms are natively distributed, while it's not true
for fixed size sample algorithms.
|
| DoubleSummaryAggregator |
Aggregator that can handle Double types.
|
| DoubleSummaryAggregator.MaxDoubleAggregator |
Aggregator for max operation.
|
| DoubleSummaryAggregator.MinDoubleAggregator |
Aggregator for min operation.
|
| DoubleSummaryAggregator.SumDoubleAggregator |
Aggregator for sum operation.
|
| ExecutionEnvironment |
Deprecated.
|
| ExecutionEnvironmentFactory |
Deprecated.
|
| ExecutionPlanUtil |
A utility for extracting an execution plan (as JSON) from a Plan.
|
| ExecutionPlanUtil.ExecutionPlanJSONGenerator |
Internal interface for the JSON plan generator that has to reside in the optimizer package.
|
| FilterOperator<T> |
Deprecated.
|
| FirstReducer<T> |
Reducer that only emits the first N elements in a group.
|
| FlatMapIterator<IN,OUT> |
Deprecated.
|
| FlatMapOperator<IN,OUT> |
Deprecated.
|
| FlinkChillPackageRegistrar |
Registers all chill serializers used for Java types.
|
| FloatSummaryAggregator |
Aggregator that can handle Float types.
|
| FloatSummaryAggregator.MaxFloatAggregator |
Aggregator for max operation.
|
| FloatSummaryAggregator.MinFloatAggregator |
Aggregator for min operation.
|
| FloatSummaryAggregator.SumFloatAggregator |
Aggregator for sum operation.
|
| FormattingMapper<T> |
|
| FunctionAnnotation |
Deprecated.
|
| 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.
|
| GroupCombineOperator<IN,OUT> |
Deprecated.
|
| Grouping<T> |
Deprecated.
|
| GroupReduceIterator<IN,OUT> |
Deprecated.
|
| GroupReduceOperator<IN,OUT> |
Deprecated.
|
| IdPartitioner |
Partitioner that partitions by id.
|
| IntegerSummaryAggregator |
Aggregator that can handle Integer types.
|
| IntegerSummaryAggregator.MaxIntegerAggregator |
Aggregator for max operation.
|
| IntegerSummaryAggregator.MinIntegerAggregator |
Aggregator for min operation.
|
| IntegerSummaryAggregator.SumIntegerAggregator |
Aggregator for sum operation.
|
| IntermediateSampleData<T> |
The data structure which is transferred between partitions and the coordinator for distributed
random sampling.
|
| IterativeDataSet<T> |
Deprecated.
|
| IteratorInputFormat<T> |
Deprecated.
|
| JoinFunctionAssigner<I1,I2> |
Deprecated.
|
| JoinOperator<I1,I2,OUT> |
Deprecated.
|
| JoinOperator.DefaultJoin<I1,I2> |
A Join transformation that wraps pairs of joining elements into Tuple2.
|
| JoinOperator.DefaultJoin.WrappingFlatJoinFunction<IN1,IN2,OUT> |
Wrapper around JoinFunction.
|
| JoinOperator.EquiJoin<I1,I2,OUT> |
A Join transformation that applies a JoinFunction on each pair of joining elements.
|
| JoinOperator.JoinOperatorSets<I1,I2> |
Intermediate step of a Join transformation.
|
| JoinOperator.ProjectJoin<I1,I2,OUT extends org.apache.flink.api.java.tuple.Tuple> |
A Join transformation that projects joining elements or fields of joining Tuples into result Tuples.
|
| JoinOperatorSetsBase<I1,I2> |
Deprecated.
|
| JoinType |
Deprecated.
|
| KeyExtractingMapper<T,K> |
Mapper that extracts keys.
|
| KeyFunctions |
This class holds static utilities to append functions that extract and prune keys.
|
| KeyRemovingMapper<T,K> |
Mapper that removes keys.
|
| LocalCollectionOutputFormat<T> |
Deprecated.
|
| LocalEnvironment |
Deprecated.
|
| LongSummaryAggregator |
Aggregator that can handle Long types.
|
| LongSummaryAggregator.MaxLongAggregator |
Aggregator for max operation.
|
| LongSummaryAggregator.MinLongAggregator |
Aggregator for min operation.
|
| MapOperator<IN,OUT> |
Deprecated.
|
| MapPartitionOperator<IN,OUT> |
Deprecated.
|
| MaxAggregationFunction<T extends Comparable<T>> |
|
| MaxAggregationFunction.MaxAggregationFunctionFactory |
|
| MinAggregationFunction<T extends Comparable<T>> |
|
| MinAggregationFunction.MinAggregationFunctionFactory |
|
| MultipleParameterTool |
This class provides simple utility methods for reading and parsing program arguments from
different sources.
|
| NoOpOperator<IN> |
This operator will be ignored during translation.
|
| NumericColumnSummary<T> |
Deprecated.
|
| NumericSummaryAggregator<T extends Number> |
Generic aggregator for all numeric types creates a summary of a column of numbers.
|
| ObjectColumnSummary |
Deprecated.
|
| ObjectSummaryAggregator |
|
| Operator<OUT,O extends Operator<OUT,O>> |
Deprecated.
|
| OperatorTranslation |
Used for translating data sets into corresponding operators.
|
| ParallelIteratorInputFormat<T> |
Deprecated.
|
| ParameterTool |
This class provides simple utility methods for reading and parsing program arguments from
different sources.
|
| PartitionOperator<T> |
Deprecated.
|
| PlanBothUnwrappingCoGroupOperator<I1,I2,OUT,K> |
A co group operator that applies the operation only on the unwrapped values.
|
| PlanFilterOperator<T> |
|
| PlanFilterOperator.FlatMapFilter<T> |
|
| PlanGenerator |
A generator that generates a Plan from a graph of Operators.
|
| PlanLeftUnwrappingCoGroupOperator<I1,I2,OUT,K> |
A co group operator that applies the operation only on the unwrapped values on the left.
|
| PlanProjectOperator<T,R extends org.apache.flink.api.java.tuple.Tuple> |
A map operator that retains a subset of fields from incoming tuples.
|
| PlanRightUnwrappingCoGroupOperator<I1,I2,OUT,K> |
A co group operator that applies the operation only on the unwrapped values on the right.
|
| PlanUnwrappingGroupCombineOperator<IN,OUT,K> |
A group combine operator that takes 2-tuples (key-value pairs), and applies the group combine
operation only on the unwrapped values.
|
| PlanUnwrappingReduceGroupOperator<IN,OUT,K> |
A reduce operator that takes 2-tuples (key-value pairs), and applies the group reduce operation
only on the unwrapped values.
|
| PlanUnwrappingReduceOperator<T,K> |
A reduce operator that takes 2-tuples (key-value pairs), and applies the reduce operation only on
the unwrapped values.
|
| PlanUnwrappingSortedGroupCombineOperator<IN,OUT,K1,K2> |
A reduce operator that takes 3-tuples (groupKey, sortKey, value), and applies the sorted partial
group reduce operation only on the unwrapped values.
|
| PlanUnwrappingSortedReduceGroupOperator<IN,OUT,K1,K2> |
A reduce operator that takes 3-tuples (groupKey, sortKey, value), and applies the sorted group
reduce operation only on the unwrapped values.
|
| PoissonSampler<T> |
A sampler implementation based on the Poisson Distribution.
|
| PojoCsvInputFormat<OUT> |
Input format that reads csv into POJOs.
|
| PrimitiveInputFormat<OT> |
Deprecated.
|
| PrintingOutputFormat<T> |
Deprecated.
|
| ProjectOperator<IN,OUT extends org.apache.flink.api.java.tuple.Tuple> |
Deprecated.
|
| ProjectOperator.Projection<T> |
|
| RandomSampler<T> |
A data sample is a set of data selected from a statistical population by a defined procedure.
|
| ReduceOperator<IN> |
Deprecated.
|
| RemoteEnvironment |
Deprecated.
|
| RemoteEnvironmentConfigUtils |
A set of tools used by batch and streaming remote environments when preparing their
configurations.
|
| ReservoirSamplerWithoutReplacement<T> |
A simple in memory implementation of Reservoir Sampling without replacement, and with only one
pass through the input iteration whose size is unpredictable.
|
| ReservoirSamplerWithReplacement<T> |
A simple in memory implementation of Reservoir Sampling with replacement and with only one pass
through the input iteration whose size is unpredictable.
|
| RichCombineToGroupCombineWrapper<IN,OUT,F extends org.apache.flink.api.common.functions.RichGroupReduceFunction<IN,OUT> & org.apache.flink.api.common.functions.CombineFunction<IN,IN>> |
A wrapper the wraps a function that implements both CombineFunction and GroupReduceFunction interfaces and makes it look like a function that implements GroupCombineFunction and GroupReduceFunction to the runtime.
|
| RowCsvInputFormat |
Deprecated.
|
| 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 org.apache.flink.api.java.tuple.Tuple> |
Function that enables selection by maximal value of a field.
|
| SelectByMinFunction<T extends org.apache.flink.api.java.tuple.Tuple> |
Function that enables selection by minimal value of a field.
|
| SemanticPropUtil |
Utility class that contains helper methods to work with SemanticProperties.
|
| ShortSummaryAggregator |
Aggregator that can handle Short types.
|
| ShortSummaryAggregator.MaxShortAggregator |
Aggregator for max operation.
|
| ShortSummaryAggregator.MinShortAggregator |
Aggregator for min operation.
|
| ShortSummaryAggregator.SumShortAggregator |
Aggregator for sum operation.
|
| SingleInputOperator<IN,OUT,O extends SingleInputOperator<IN,OUT,O>> |
Deprecated.
|
| SingleInputUdfOperator<IN,OUT,O extends SingleInputUdfOperator<IN,OUT,O>> |
Deprecated.
|
| SortedGrouping<T> |
Deprecated.
|
| SortPartitionOperator<T> |
Deprecated.
|
| SplitDataProperties<T> |
Deprecated.
|
| SplitDataProperties.SourcePartitionerMarker<T> |
A custom partitioner to mark compatible split partitionings.
|
| StringColumnSummary |
Deprecated.
|
| StringSummaryAggregator |
|
| SumAggregationFunction<T> |
Definitions of sum functions for different numerical types.
|
| SumAggregationFunction.SumAggregationFunctionFactory |
|
| SummaryAggregatorFactory |
Factory for creating Summary Aggregators.
|
| TextInputFormat |
Deprecated.
|
| TextOutputFormat<T> |
Deprecated.
|
| TextOutputFormat.TextFormatter<IN> |
Formatter that transforms values into their String representations. |
| TextValueInputFormat |
Deprecated.
|
| Tuple3UnwrappingIterator<T,K1,K2> |
An iterator that reads 3-tuples (groupKey, sortKey, value) and returns only the values (third
field).
|
| Tuple3WrappingCollector<IN,K1,K2> |
Needed to wrap tuples to Tuple3<groupKey, sortKey, value> for combine method of group
reduce with key selector sorting.
|
| TupleCsvInputFormat<OUT> |
Input format that reads csv into tuples.
|
| TupleLeftUnwrappingJoiner<I1,I2,OUT,K> |
Joiner that unwraps values from the left set before applying the join operation.
|
| TupleRightUnwrappingJoiner<I1,I2,OUT,K> |
Joiner that unwraps values from the right set before applying the join operation.
|
| TupleSummaryAggregator<R extends org.apache.flink.api.java.tuple.Tuple> |
Aggregate tuples using an array of aggregators, one for each "column" or position within the
Tuple.
|
| TupleUnwrappingIterator<T,K> |
An iterator that reads 2-tuples (key value pairs) and returns only the values (second field).
|
| TupleUnwrappingJoiner<I1,I2,OUT,K> |
Joiner that unwraps both values before applying the join operation.
|
| TupleWrappingCollector<IN,K> |
Needed to wrap tuples to Tuple2<key, value> pairs for combine method of group reduce with
key selector function.
|
| TwoInputOperator<IN1,IN2,OUT,O extends TwoInputOperator<IN1,IN2,OUT,O>> |
Deprecated.
|
| TwoInputUdfOperator<IN1,IN2,OUT,O extends TwoInputUdfOperator<IN1,IN2,OUT,O>> |
Deprecated.
|
| TwoKeyExtractingMapper<T,K1,K2> |
Mapper that extracts two keys of a value.
|
| TypeSerializerInputFormat<T> |
Deprecated.
|
| TypeSerializerOutputFormat<T> |
Deprecated.
|
| UdfOperator<O extends UdfOperator<O>> |
Deprecated.
|
| UnionOperator<T> |
Deprecated.
|
| UnsortedGrouping<T> |
Deprecated.
|
| UnsupportedAggregationTypeException |
Deprecated.
|
| Utils |
Utility class that contains helper methods to work with Java APIs.
|
| Utils.ChecksumHashCode |
|
| Utils.ChecksumHashCodeHelper<T> |
|
| Utils.CollectHelper<T> |
Utility sink function that collects elements into an accumulator, from which it they can be
retrieved by the client.
|
| Utils.CountHelper<T> |
Utility sink function that counts elements and writes the count into an accumulator, from
which it can be retrieved by the client.
|
| ValueSummaryAggregator<VT extends org.apache.flink.types.Value,PT,R,A extends Aggregator<PT,R>> |
This is a generic Aggregator for Value types like StringValue, DoubleValue, etc.
|
| ValueSummaryAggregator.BooleanValueSummaryAggregator |
|
| ValueSummaryAggregator.DoubleValueSummaryAggregator |
|
| ValueSummaryAggregator.FloatValueSummaryAggregator |
|
| ValueSummaryAggregator.IntegerValueSummaryAggregator |
|
| ValueSummaryAggregator.LongValueSummaryAggregator |
|
| ValueSummaryAggregator.ShortValueSummaryAggregator |
|
| ValueSummaryAggregator.StringValueSummaryAggregator |
|
| WrappingFunction<T extends org.apache.flink.api.common.functions.Function> |
Wrapper around Function.
|