Uses of Class
org.apache.flink.streaming.api.graph.StreamGraph

Packages that use StreamGraph

Package	Description
org.apache.flink.api.java
org.apache.flink.client.program
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.util
org.apache.flink.table.planner.utils
org.apache.flink.table.util

Uses of StreamGraph in org.apache.flink.api.java

Methods in org.apache.flink.api.java with parameters of type StreamGraph

Modifier and Type	Method and Description
JobClient	ScalaShellStreamEnvironment.executeAsync(StreamGraph streamGraph)

Uses of StreamGraph in org.apache.flink.client.program

Methods in org.apache.flink.client.program with parameters of type StreamGraph

Modifier and Type	Method and Description
JobExecutionResult	StreamContextEnvironment.execute(StreamGraph streamGraph)
JobClient	StreamContextEnvironment.executeAsync(StreamGraph streamGraph)
JobClient	StreamPlanEnvironment.executeAsync(StreamGraph streamGraph)

Uses of StreamGraph in org.apache.flink.streaming.api.environment

Methods in org.apache.flink.streaming.api.environment that return StreamGraph

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.

Methods in org.apache.flink.streaming.api.environment with parameters of type StreamGraph

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.

Uses of StreamGraph in org.apache.flink.streaming.api.graph

Methods in org.apache.flink.streaming.api.graph that return StreamGraph

Modifier and Type	Method and Description
StreamGraph	StreamGraphGenerator.generate()

Methods in org.apache.flink.streaming.api.graph with parameters of type StreamGraph

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)

Constructors in org.apache.flink.streaming.api.graph with parameters of type StreamGraph

Constructor and Description
JSONGenerator(StreamGraph streamGraph)

Uses of StreamGraph in org.apache.flink.streaming.util

Methods in org.apache.flink.streaming.util with parameters of type StreamGraph

Modifier and Type	Method and Description
JobExecutionResult	TestStreamEnvironment.execute(StreamGraph streamGraph)

Uses of StreamGraph in org.apache.flink.table.planner.utils

Methods in org.apache.flink.table.planner.utils that return StreamGraph

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)

Methods in org.apache.flink.table.planner.utils with parameters of type StreamGraph

Modifier and Type	Method and Description
JobExecutionResult	DummyStreamExecutionEnvironment.execute(StreamGraph streamGraph)
static void	ExecutorUtils.setBatchProperties(StreamGraph streamGraph, TableConfig tableConfig) Sets batch properties for StreamGraph.

Uses of StreamGraph in org.apache.flink.table.util

Methods in org.apache.flink.table.util that return StreamGraph

Modifier and Type	Method and Description
StreamGraph	DummyStreamExecutionEnvironment.getStreamGraph()
StreamGraph	DummyStreamExecutionEnvironment.getStreamGraph(String jobName)

Methods in org.apache.flink.table.util with parameters of type StreamGraph

Modifier and Type	Method and Description
JobExecutionResult	DummyStreamExecutionEnvironment.execute(StreamGraph streamGraph)