Package 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	Description
static org.apache.flink.runtime.jobgraph.JobGraph	createJobGraph(ClassLoader userClassLoader, StreamGraph streamGraph, org.apache.flink.api.common.JobID jobID)
static org.apache.flink.runtime.jobgraph.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 org.apache.flink.runtime.jobgraph.JobGraph createJobGraph(StreamGraph streamGraph)

createJobGraph

public static org.apache.flink.runtime.jobgraph.JobGraph createJobGraph(ClassLoader userClassLoader,
                                                                        StreamGraph streamGraph,
                                                                        @Nullable
                                                                        org.apache.flink.api.common.JobID jobID)

isChainable

public static boolean isChainable(StreamEdge edge,
                                  StreamGraph streamGraph)