org.apache.flink.streaming.api.graph

Class StreamingJobGraphGenerator

java.lang.Object

org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator

@Internal
public class StreamingJobGraphGenerator
extends Object

The StreamingJobGraphGenerator converts a StreamGraph into a JobGraph.

Method Summary

Modifier and Type	Method and Description
static JobGraph	createJobGraph(ClassLoader userClassLoader, StreamGraph streamGraph, JobID jobID)
static JobGraph	createJobGraph(StreamGraph streamGraph)
static boolean	isChainable(StreamEdge edge, StreamGraph streamGraph)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createJobGraph

@VisibleForTesting
public static JobGraph createJobGraph(StreamGraph streamGraph)

createJobGraph

public static JobGraph createJobGraph(ClassLoader userClassLoader,
                                      StreamGraph streamGraph,
                                      @Nullable
                                      JobID jobID)

isChainable

public static boolean isChainable(StreamEdge edge,
                                  StreamGraph streamGraph)