Skip to content

CheckDeltaInvariant

CheckDeltaInvariant is a UnaryExpression (Spark SQL) for DeltaInvariantCheckerExec physical operator.

Creating Instance

CheckDeltaInvariant takes the following to be created:

CheckDeltaInvariant is created using withBoundReferences and when:

  • DeltaInvariantCheckerExec physical operator is executed

Evaluating Expression

eval(
  input: InternalRow): Any

eval is part of the Expression (Spark SQL) abstraction.

eval asserts the constraint on the input InternalRow.

Asserts Constraint

assertRule(
  input: InternalRow): Unit

assertRule...FIXME

Creating CheckDeltaInvariant with BoundReferences

withBoundReferences(
  input: AttributeSeq): CheckDeltaInvariant

withBoundReferences...FIXME

withBoundReferences is used when:

  • DeltaInvariantCheckerExec physical operator is executed