From ac45e23eb7c3fc2b672f8a3f90d781427c48d764 Mon Sep 17 00:00:00 2001 From: Andreas Chatzistergiou Date: Fri, 22 Mar 2024 14:29:09 +0100 Subject: [PATCH] nit --- .../spark/sql/delta/constraints/DeltaInvariantCheckerExec.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spark/src/main/scala/org/apache/spark/sql/delta/constraints/DeltaInvariantCheckerExec.scala b/spark/src/main/scala/org/apache/spark/sql/delta/constraints/DeltaInvariantCheckerExec.scala index 0a1e063effa..27ddbcc51db 100644 --- a/spark/src/main/scala/org/apache/spark/sql/delta/constraints/DeltaInvariantCheckerExec.scala +++ b/spark/src/main/scala/org/apache/spark/sql/delta/constraints/DeltaInvariantCheckerExec.scala @@ -21,6 +21,7 @@ import scala.collection.mutable import org.apache.spark.sql.delta.{DeltaErrors, DeltaIllegalStateException} import org.apache.spark.sql.delta.constraints.Constraints.{Check, NotNull} import org.apache.spark.sql.delta.schema.SchemaUtils +import org.apache.spark.sql.delta.util.AnalysisHelper import org.apache.spark.rdd.RDD import org.apache.spark.sql.SparkSession @@ -32,7 +33,6 @@ import org.apache.spark.sql.catalyst.optimizer.ReplaceExpressions import org.apache.spark.sql.catalyst.plans.logical.{LogicalPlan, UnaryNode} import org.apache.spark.sql.catalyst.plans.physical.Partitioning import org.apache.spark.sql.catalyst.rules.RuleExecutor -import org.apache.spark.sql.delta.util.AnalysisHelper import org.apache.spark.sql.execution.{SparkPlan, SparkStrategy, UnaryExecNode} import org.apache.spark.sql.types.StructType