Interface | Description |
---|---|
StreamExecutionEnvironmentFactory |
Factory class for stream execution environments.
|
Class | Description |
---|---|
CheckpointConfig |
Configuration that captures all checkpointing related settings.
|
ExecutionCheckpointingOptions |
Execution
ConfigOption for configuring checkpointing related parameters. |
LocalStreamEnvironment |
The LocalStreamEnvironment is a StreamExecutionEnvironment that runs the program locally,
multi-threaded, in the JVM where the environment is instantiated.
|
RemoteStreamEnvironment |
A
StreamExecutionEnvironment for executing on a cluster. |
StreamExecutionEnvironment |
The StreamExecutionEnvironment is the context in which a streaming program is executed.
|
StreamPipelineOptions |
The
configuration options for job execution. |
Enum | Description |
---|---|
CheckpointConfig.ExternalizedCheckpointCleanup |
Cleanup behaviour for externalized checkpoints when the job is cancelled.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.