CheckDeltaInvariant¶

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

Creating Instance¶

CheckDeltaInvariant takes the following to be created:

• Child Expression (Spark SQL)
• Column Extractors (Map[String, Expression])
• Constraint

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