Modifier and Type | Method and Description |
---|---|
JobClient |
ScalaShellStreamEnvironment.executeAsync(StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamContextEnvironment.execute(StreamGraph streamGraph) |
JobClient |
StreamContextEnvironment.executeAsync(StreamGraph streamGraph) |
JobClient |
StreamPlanEnvironment.executeAsync(StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
static StreamGraph |
PythonConfigUtil.generateStreamGraphWithDependencies(StreamExecutionEnvironment env,
boolean clearTransformations)
Generate a
StreamGraph for transformations maintained by current StreamExecutionEnvironment , and reset the merged env configurations with dependencies to
every OneInputPythonFunctionOperator . |
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. |
StreamGraph |
StreamExecutionEnvironment.getStreamGraph(String jobName,
boolean clearTransformations)
Getter of the
StreamGraph of the
streaming job with the option to clear previously registered transformations . |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
StreamExecutionEnvironment.execute(StreamGraph streamGraph)
Triggers the program execution.
|
JobExecutionResult |
LocalStreamEnvironment.execute(StreamGraph streamGraph) |
JobExecutionResult |
RemoteStreamEnvironment.execute(StreamGraph streamGraph) |
JobClient |
StreamExecutionEnvironment.executeAsync(StreamGraph streamGraph)
Triggers the program execution asynchronously.
|
Modifier and Type | Method and Description |
---|---|
StreamGraph |
StreamGraphGenerator.generate() |
StreamGraph |
TransformationTranslator.Context.getStreamGraph()
Returns the
StreamGraph being created as the transformations of a pipeline are
translated to their runtime implementations. |
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[]> |
StreamGraphHasher.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph)
Returns a map with a hash for each
StreamNode of the StreamGraph . |
Map<Integer,byte[]> |
StreamGraphUserHashHasher.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph) |
Constructor and Description |
---|
JSONGenerator(StreamGraph streamGraph) |
Modifier and Type | Method and Description |
---|---|
static <T> void |
StreamGraphUtils.configureBufferTimeout(StreamGraph streamGraph,
int nodeId,
Transformation<T> transformation,
long defaultBufferTimeout)
Configure a stream node's buffer timeout according to the given transformation.
|
static void |
StreamGraphUtils.validateTransformationUid(StreamGraph streamGraph,
Transformation<?> transformation)
Throw
IllegalStateException if the PhysicalTransformation 's uid or hash is
not set when auto generate uid is disabled. |
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 . |
Modifier and Type | Method and Description |
---|---|
StreamGraph |
DummyStreamExecutionEnvironment.getStreamGraph() |
StreamGraph |
DummyStreamExecutionEnvironment.getStreamGraph(String jobName) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
DummyStreamExecutionEnvironment.execute(StreamGraph streamGraph) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.