Package org.apache.flink.api.java
-
Interface Summary Interface Description ExecutionEnvironmentFactory Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.ExecutionPlanUtil.ExecutionPlanJSONGenerator Internal interface for the JSON plan generator that has to reside in the optimizer package. -
Class Summary Class Description CollectionEnvironment Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.DataSet<T> Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.ExecutionEnvironment Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.ExecutionPlanUtil A utility for extracting an execution plan (as JSON) from aPlan.LocalEnvironment Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.RemoteEnvironment Deprecated. All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version.RemoteEnvironmentConfigUtils A set of tools used by batch and streaming remote environments when preparing their configurations.Utils Utility class that contains helper methods to work with Java APIs.Utils.ChecksumHashCode Accumulator ofUtils.ChecksumHashCode.Utils.ChecksumHashCodeHelper<T> RichOutputFormatforUtils.ChecksumHashCode.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.