Interface | Description |
---|---|
StreamExecutionEnvironmentFactory |
Factory class for stream execution environments.
|
Class | Description |
---|---|
CheckpointConfig |
Configuration that captures all checkpointing related settings.
|
Flip6LocalStreamEnvironment |
The Flip6LocalStreamEnvironment is a StreamExecutionEnvironment that runs the program locally,
multi-threaded, in the JVM where the environment is instantiated.
|
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. |
StreamContextEnvironment |
Special
StreamExecutionEnvironment that will be used in cases where the CLI client or
testing utilities create a StreamExecutionEnvironment that should be used when
StreamExecutionEnvironment.getExecutionEnvironment() is called. |
StreamExecutionEnvironment |
The StreamExecutionEnvironment is the context in which a streaming program is executed.
|
StreamPlanEnvironment |
A special
StreamExecutionEnvironment that is used in the web frontend when generating
a user-inspectable graph of a streaming job. |
Enum | Description |
---|---|
CheckpointConfig.ExternalizedCheckpointCleanup |
Cleanup behaviour for externalized checkpoints when the job is cancelled.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.