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