Package | Description |
---|---|
org.apache.flink.api.java | |
org.apache.flink.streaming.api.environment | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.api.scala |
Modifier and Type | Method and Description |
---|---|
protected JobExecutionResult |
ScalaShellRemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph,
List<URL> jarFiles)
Executes the remote job.
|
Modifier and Type | Method and Description |
---|---|
StreamGraph |
StreamExecutionEnvironment.getStreamGraph()
Getter of the
StreamGraph of the streaming job. |
Modifier and Type | Method and Description |
---|---|
protected JobExecutionResult |
RemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph,
List<URL> jarFiles)
Executes the remote job.
|
Modifier and Type | Method and Description |
---|---|
static StreamGraph |
StreamGraphGenerator.generate(StreamExecutionEnvironment env,
List<StreamTransformation<?>> transformations)
Generates a
StreamGraph by traversing the graph of StreamTransformations
starting from the given transformations. |
Constructor and Description |
---|
JSONGenerator(StreamGraph streamGraph) |
StreamingJobGraphGenerator(StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
StreamGraph |
StreamExecutionEnvironment.getStreamGraph()
Getter of the
StreamGraph of the streaming job. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.