Package org.apache.spark.sql.pipelines.graph

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.

Constructor Summary

Constructors

Constructor	Description
FlowPlanner(DataflowGraph graph, PipelineUpdateContext updateContext, scala.Function1<Flow,Trigger> triggerFor)

Method Summary

Modifier and Type	Method	Description
FlowExecution	plan(ResolvedFlow flow)	Turns a Flow into an executable FlowExecution.

Methods inherited from class java.lang.Object

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

Constructor Details

FlowPlanner

public FlowPlanner(DataflowGraph graph,
 PipelineUpdateContext updateContext,
 scala.Function1<Flow,Trigger> triggerFor)

Method Details

plan

public FlowExecution plan(ResolvedFlow flow)

Turns a Flow into an executable FlowExecution.

Parameters:

flow - (undocumented)

Returns:

(undocumented)