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 |
---|---|
Map<Integer,byte[]> |
StreamGraphHasherV1.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph) |
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. |
Modifier and Type | Method and Description |
---|---|
static boolean |
StreamingJobGraphGenerator.isChainable(StreamEdge edge,
StreamGraph streamGraph) |
Map<Integer,byte[]> |
StreamGraphUserHashHasher.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph) |
Map<Integer,byte[]> |
StreamGraphHasherV2.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph)
Returns a map with a hash for each
StreamNode of the 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) |
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.