Skip to content

PreprocessTableUpdate Logical Resolution Rule

PreprocessTableUpdate is a post-hoc logical resolution rule (Rule[LogicalPlan]) to resolve DeltaUpdateTable commands in a logical query plan into UpdateCommands.

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

Creating Instance

PreprocessTableUpdate takes the following to be created:

PreprocessTableUpdate is created when:

Executing Rule

apply(
  plan: LogicalPlan): LogicalPlan

apply is part of the Rule (Spark SQL) abstraction.

apply resolves (replaces) DeltaUpdateTable logical commands (in a logical query plan) into UpdateCommands.

toCommand

toCommand(
  update: DeltaUpdateTable): UpdateCommand

toCommand...FIXME


Last update: 2021-05-21
Back to top