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

Packages that use StreamGraph

Package	Description
org.apache.flink.api.java
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.graph

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
protected JobExecutionResult	ScalaShellRemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph, List<URL> jarFiles) Executes the remote job.

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.

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

Modifier and Type	Method and Description
protected JobExecutionResult	RemoteStreamEnvironment.executeRemotely(StreamGraph streamGraph, List<URL> jarFiles) Deprecated.

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
static StreamGraph	StreamGraphGenerator.generate(StreamExecutionEnvironment env, List<StreamTransformation<?>> transformations) Generates a StreamGraph by traversing the graph of StreamTransformations starting from the given transformations.

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[]>	StreamGraphUserHashHasher.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph)
Map<Integer,byte[]>	StreamGraphHasher.traverseStreamGraphAndGenerateHashes(StreamGraph streamGraph) Returns a map with a hash for each StreamNode of the StreamGraph.

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

Constructor and Description
JSONGenerator(StreamGraph streamGraph)