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 | Description |
---|---|
ClosureCleaner |
The closure cleaner is a utility that tries to truncate the closure (enclosing instance) of
non-static inner classes (created for inline transformation functions).
|
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 a
Plan . |
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 of
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.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.