Package | Description |
---|---|
org.apache.flink.streaming.api.scala |
Modifier and Type | Method and Description |
---|---|
static StreamExecutionEnvironment |
StreamExecutionEnvironment.createLocalEnvironment(int parallelism)
Creates a local execution environment.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment$.createLocalEnvironment(int parallelism)
Creates a local execution environment.
|
static StreamExecutionEnvironment |
StreamExecutionEnvironment.createRemoteEnvironment(String host,
int port,
int parallelism,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment$.createRemoteEnvironment(String host,
int port,
int parallelism,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
static StreamExecutionEnvironment |
StreamExecutionEnvironment.createRemoteEnvironment(String host,
int port,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment$.createRemoteEnvironment(String host,
int port,
scala.collection.Seq<String> jarFiles)
Creates a remote execution environment.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.disableOperatorChaining()
Disables operator chaining for streaming operators.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing()
Method for enabling fault-tolerance.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing(long interval)
Enables checkpointing for the streaming job.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode)
Enables checkpointing for the streaming job.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.enableCheckpointing(long interval,
CheckpointingMode mode,
boolean force)
Enables checkpointing for the streaming job.
|
StreamExecutionEnvironment |
DataStream.executionEnvironment()
Returns the
StreamExecutionEnvironment associated with this data stream |
StreamExecutionEnvironment |
DataStream.getExecutionEnvironment()
Deprecated.
Use
executionEnvironment instead |
static StreamExecutionEnvironment |
StreamExecutionEnvironment.getExecutionEnvironment()
Creates an execution environment that represents the context in which the program is
currently executed.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment$.getExecutionEnvironment()
Creates an execution environment that represents the context in which the program is
currently executed.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setBufferTimeout(long timeoutMillis)
Sets the maximum time frequency (milliseconds) for the flushing of the
output buffers.
|
StreamExecutionEnvironment |
StreamExecutionEnvironment.setStateBackend(AbstractStateBackend backend)
Sets the state backend that describes how to store and checkpoint operator state.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.