Skip to content

AutoCdcMergeFlow

AutoCdcMergeFlow is a ResolvedFlow that applies a CDC event stream to a target table via MERGE.

AutoCdcMergeFlow represents an AutoCdcFlow at execution time (when FlowResolver is requested to resolve a flow).

AutoCdcMergeFlow can be one of the two SCD Types (based on ChangeArgs):

  • Type1
  • Type2

AutoCdcMergeFlow type 1 (with a Table output) is executed as a Scd1MergeStreamingWrite. All the other variants fail at execution either with an UnsupportedOperationException or an AnalysisException.

Creating Instance

AutoCdcMergeFlow takes the following to be created:

AutoCdcMergeFlow is created when: