DataflowGraph¶

Creating Instance¶

DataflowGraph takes the following to be created:

• Flows
• Tables
• Views

DataflowGraph is created when:

• DataflowGraph is requested to reanalyzeFlow
• GraphRegistrationContext is requested to toDataflowGraph

reanalyzeFlow¶

reanalyzeFlow(
  srcFlow: Flow): ResolvedFlow

reanalyzeFlow...FIXME

reanalyzeFlow is used when:

• BatchTableWrite is requested to executeInternal
• StreamingTableWrite is requested to startStream

Resolve¶

resolve(): DataflowGraph

resolve...FIXME

resolve is used when:

• DataflowGraph is requested to reanalyzeFlow
• PipelineExecution is requested to initializeGraph

Validate¶

validate(): DataflowGraph

validate...FIXME

validate is used when:

• PipelineExecution is requested to initialize the dataflow graph