Modifier and Type | Method and Description |
---|---|
StreamExecutionEnvironment |
FlinkILoop.scalaSenv() |
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.createLocalEnvironmentWithWebUI(Configuration config)
Creates a
StreamExecutionEnvironment for local program execution that also starts the
web monitoring UI. |
StreamExecutionEnvironment |
StreamExecutionEnvironment$.createLocalEnvironmentWithWebUI(Configuration config)
Creates a
StreamExecutionEnvironment for local program execution that also starts the
web monitoring UI. |
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()
Deprecated.
. Since .
|
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)
Deprecated.
. Since .
|
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.
|
Modifier and Type | Method and Description |
---|---|
static DataStream<WindowJoin.Grade> |
WindowJoinSampleData.getGradeSource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, grade).
|
DataStream<WindowJoin.Grade> |
WindowJoinSampleData$.getGradeSource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, grade).
|
static DataStream<WindowJoin.Salary> |
WindowJoinSampleData.getSalarySource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, salary).
|
DataStream<WindowJoin.Salary> |
WindowJoinSampleData$.getSalarySource(StreamExecutionEnvironment env,
long rate)
Continuously generates (name, salary).
|
Modifier and Type | Method and Description |
---|---|
StreamTableEnvironment |
TableEnvironment$.getTableEnvironment(StreamExecutionEnvironment executionEnvironment)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
static StreamTableEnvironment |
TableEnvironment.getTableEnvironment(StreamExecutionEnvironment executionEnvironment)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
StreamTableEnvironment |
TableEnvironment$.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
static StreamTableEnvironment |
TableEnvironment.getTableEnvironment(StreamExecutionEnvironment executionEnvironment,
TableConfig tableConfig)
Returns a
ScalaStreamTableEnv for a Scala stream ScalaStreamExecEnv . |
Constructor and Description |
---|
StreamTableEnvironment(StreamExecutionEnvironment execEnv,
TableConfig config) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.