Class FlowPlanner

Object
org.apache.spark.sql.pipelines.graph.FlowPlanner

public class FlowPlanner extends Object
Plans execution of Flows in a DataflowGraph by converting Flows into 'FlowExecution's.

param: graph DataflowGraph to help plan based on relationship to other elements. param: updateContext PipelineUpdateContext for this pipeline update (shared across flows). param: triggerFor Function that returns the correct streaming Trigger for the specified Flow.