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. |
StreamGraph |
StreamExecutionEnvironment.getStreamGraph(String jobName)
Getter of the
StreamGraph of the streaming job. |
Modifier and Type | Method and Description |
---|---|
abstract JobExecutionResult |
StreamExecutionEnvironment.execute(StreamGraph streamGraph)
Triggers the program execution.
|
JobExecutionResult |
LocalStreamEnvironment.execute(StreamGraph streamGraph)
Executes the JobGraph of the on a mini cluster of ClusterUtil with a user
specified name.
|
JobExecutionResult |
StreamPlanEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
StreamContextEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
RemoteStreamEnvironment.execute(StreamGraph streamGraph) |
protected JobExecutionResult |
RemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph,
List<URL> jarFiles)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
StreamGraph |
StreamGraphGenerator.generate() |
Modifier and Type | Method and Description |
---|---|
static JobGraph |
StreamingJobGraphGenerator.createJobGraph(StreamGraph streamGraph) |
static JobGraph |
StreamingJobGraphGenerator.createJobGraph(StreamGraph streamGraph,
JobID jobID) |
static boolean |
StreamingJobGraphGenerator.isChainable(StreamEdge edge,
StreamGraph streamGraph) |
Map<Integer,byte[]> |
StreamGraphHasherV2.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph)
Returns a map with a hash for each
StreamNode of the StreamGraph . |
Map<Integer,byte[]> |
StreamGraphUserHashHasher.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph) |
Map<Integer,byte[]> |
StreamGraphHasher.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph)
Returns a map with a hash for each
StreamNode of the StreamGraph . |
Constructor and Description |
---|
JSONGenerator(StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
TestStreamEnvironment.execute(StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
StreamGraph |
StreamExecutor.getStreamGraph(String jobName) |
StreamGraph |
BatchExecutor.getStreamGraph(String jobName) |
abstract StreamGraph |
ExecutorBase.getStreamGraph(String jobName)
Translates the transformations applied into this executor to a stream graph.
|
Modifier and Type | Method and Description |
---|---|
static StreamGraph |
ExecutorUtils.generateStreamGraph(StreamExecutionEnvironment execEnv,
List<Transformation<?>> transformations)
Generate
StreamGraph by StreamGraphGenerator . |
StreamGraph |
DummyStreamExecutionEnvironment.getStreamGraph() |
StreamGraph |
DummyStreamExecutionEnvironment.getStreamGraph(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
DummyStreamExecutionEnvironment.execute(StreamGraph streamGraph) |
static void |
ExecutorUtils.setBatchProperties(StreamGraph streamGraph,
TableConfig tableConfig)
Sets batch properties for
StreamGraph . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.