Interface | Description |
---|---|
ExecutionEnvironmentFactory |
Factory class for execution environments.
|
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 |
Version of
ExecutionEnvironment that allows serial, local, collection-based executions of
Flink programs. |
DataSet<T> |
A DataSet represents a collection of elements of the same type.
|
ExecutionEnvironment |
The ExecutionEnvironment is the context in which a program is executed.
|
ExecutionPlanUtil |
A utility for extracting an execution plan (as JSON) from a
Plan . |
LocalEnvironment |
An
ExecutionEnvironment that runs the program locally, multi-threaded, in the JVM where
the environment is instantiated. |
RemoteEnvironment |
An
ExecutionEnvironment that sends programs to a cluster for execution. |
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–2022 The Apache Software Foundation. All rights reserved.