PipelineUpdateContext¶
PipelineUpdateContext
is an abstraction of pipeline update contexts that can refreshTables (among other things).
Contract (Subset)¶
refreshTables¶
refreshTables: TableFilter
Used when:
DatasetManager
is requested to constructFullRefreshSetPipelineUpdateContext
is requested to refreshFlows
Unresolved Dataflow Graph¶
unresolvedGraph: DataflowGraph
The unresolved DataflowGraph of this pipeline update
Used when:
PipelineUpdateContext
is requested to initializeGraph
Implementations¶
PipelineExecution¶
pipelineExecution: PipelineExecution
PipelineUpdateContext
creates a PipelineExecution when created.
The PipelineExecution
is created for this PipelineUpdateContext
.
refreshFlows¶
refreshFlows: FlowFilter
Final Method
refreshFlows
is a Scala final method and may not be overridden in subclasses.
Learn more in the Scala Language Specification.
refreshFlows
...FIXME
refreshFlows
is used when:
TriggeredGraphExecution
is requested to start
Initialize Dataflow Graph¶
initializeGraph(): DataflowGraph
initializeGraph
...FIXME
initializeGraph
is used when:
PipelineExecution
is requested to start the pipeline