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