Skip to content

DeltaInvariantCheckerStrategy Execution Planning Strategy

DeltaInvariantCheckerStrategy is a SparkStrategy (Spark SQL) to plan a DeltaInvariantChecker unary logical operator (with constraints attached) into a DeltaInvariantCheckerExec for execution.

Danger

DeltaInvariantCheckerStrategy does not seem to be used at all.

Creating Instance

DeltaInvariantCheckerStrategy is a Scala object and takes no input arguments to be created.

Executing Rule

apply(
  plan: LogicalPlan): Seq[SparkPlan]

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

For a given DeltaInvariantChecker unary logical operator with constraints attached, apply creates a DeltaInvariantCheckerExec unary physical operator. Otherwise, apply does nothing (noop).