PreprocessTableMerge Logical Resolution Rule

PreprocessTableMerge is a post-hoc logical resolution rule (Rule[LogicalPlan]) to resolve DeltaMergeInto logical commands in a query plan into MergeIntoCommands.

PreprocessTableMerge is installed (injected) into a SparkSession using DeltaSparkSessionExtension.

Creating Instance

PreprocessTableMerge takes a single SQLConf to be created.

PreprocessTableMerge is created when:

Executing Rule

apply(
  plan: LogicalPlan): LogicalPlan

apply resolves (replaces) DeltaMergeInto logical commands (in a logical query plan) into corresponding MergeIntoCommands.

apply is part of the Spark SQL’s Rule abstraction.