DataflowGraph¶
Creating Instance¶
DataflowGraph
takes the following to be created:
DataflowGraph
is created when:
DataflowGraph
is requested to reanalyzeFlowGraphRegistrationContext
is requested to toDataflowGraph
reanalyzeFlow¶
reanalyzeFlow(
srcFlow: Flow): ResolvedFlow
reanalyzeFlow
...FIXME
reanalyzeFlow
is used when:
BatchTableWrite
is requested to executeInternalStreamingTableWrite
is requested to startStream
Resolve¶
resolve(): DataflowGraph
resolve
...FIXME
resolve
is used when:
DataflowGraph
is requested to reanalyzeFlowPipelineExecution
is requested to initializeGraph
Validate¶
validate(): DataflowGraph
validate
...FIXME
validate
is used when:
PipelineExecution
is requested to initialize the dataflow graph