org.apache.flink.optimizer.plan

Class StreamingPlan

java.lang.Object

org.apache.flink.optimizer.plan.StreamingPlan

All Implemented Interfaces:

FlinkPlan

Direct Known Subclasses:

StreamGraph

public abstract class StreamingPlan
extends Object
implements FlinkPlan

Abstract class representing Flink Streaming plans

Constructor Summary

Constructors

Constructor and Description
StreamingPlan()

Method Summary

Modifier and Type	Method and Description
abstract void	dumpStreamingPlanAsJSON(File file)
JobGraph	getJobGraph() Gets the assembled JobGraph with a random JobID.
abstract JobGraph	getJobGraph(JobID jobID) Gets the assembled JobGraph with a specified JobID.
abstract String	getStreamingPlanAsJSON()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamingPlan

public StreamingPlan()

Method Detail

getJobGraph

public JobGraph getJobGraph()

Gets the assembled JobGraph with a random JobID.

getJobGraph

public abstract JobGraph getJobGraph(@Nullable
                                     JobID jobID)

Gets the assembled JobGraph with a specified JobID.

getStreamingPlanAsJSON

public abstract String getStreamingPlanAsJSON()

dumpStreamingPlanAsJSON

public abstract void dumpStreamingPlanAsJSON(File file)
                                      throws IOException

Throws:

IOException