Minor refactoring to DataSkipping Reader

GitOrigin-RevId: 83e98666aa454cd72c850d96d436b40a3bcd05c6
the2nd07 · Apr 13, 2023 · 9e1439c · 9e1439c
1 parent c834cd0
commit 9e1439c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/sql/delta/stats/DataSkippingReader.scala b/core/src/main/scala/org/apache/spark/sql/delta/stats/DataSkippingReader.scala
@@ -720,7 +720,7 @@ trait DataSkippingReaderBase
     val bytesCompressed = col("size")
     val rows = getStatsColumnOrNullLiteral(NUM_RECORDS)
     val dvCardinality = coalesce(col("deletionVector.cardinality"), lit(0L))
-    val logicalRows = rows - dvCardinality as "logicalRows"
+    val logicalRows = (rows - dvCardinality).as("logicalRows")
 
     val accumulator = new ArrayAccumulator(4)
 
@@ -847,7 +847,6 @@ trait DataSkippingReaderBase
       val df = filteredFiles.withColumn("stats", statsColumn)
       convertDataFrameToAddFiles(df)
     }
-
     files.toSeq -> Seq(DataSize(totalSize), DataSize(partitionSize), DataSize(scanSize))
   }