Class FlowPlanner
Object
org.apache.spark.sql.pipelines.graph.FlowPlanner
Plans execution of
Flow
s in a DataflowGraph
by converting Flow
s 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
ConstructorsConstructorDescriptionFlowPlanner
(DataflowGraph graph, PipelineUpdateContext updateContext, scala.Function1<Flow, Trigger> triggerFor) -
Method Summary
Modifier and TypeMethodDescriptionplan
(ResolvedFlow flow) Turns aFlow
into an executableFlowExecution
.
-
Constructor Details
-
FlowPlanner
public FlowPlanner(DataflowGraph graph, PipelineUpdateContext updateContext, scala.Function1<Flow, Trigger> triggerFor)
-
-
Method Details
-
plan
Turns aFlow
into an executableFlowExecution
.- Parameters:
flow
- (undocumented)- Returns:
- (undocumented)
-