Fix numRecords compilation issue

This PR renames `numRecords` to `numLogicalRecords` inside of `WriteIntoDelta.scala` to fix a compilation issue. GitOrigin-RevId: ba64eb90ab211bc1a1c8b7f3f5bcb7e4abaaa469
delta-io · Aug 11, 2022 · ff83a37 · ff83a37
1 parent 39aff15
commit ff83a37
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/core/src/main/scala/org/apache/spark/sql/delta/commands/WriteIntoDelta.scala b/core/src/main/scala/org/apache/spark/sql/delta/commands/WriteIntoDelta.scala
@@ -139,10 +139,10 @@ case class WriteIntoDelta(
       case a: AddFile =>
         numFiles += 1
         numOutputBytes += a.size
-        if (a.numRecords.isEmpty) {
+        if (a.numLogicalRecords.isEmpty) {
           hasRowLevelMetrics = false
         } else {
-          numNewRows += a.numRecords.get
+          numNewRows += a.numLogicalRecords.get
         }
       case cdc: AddCDCFile =>
         numAddedChangedFiles += 1
@@ -153,10 +153,10 @@ case class WriteIntoDelta(
       case a: AddFile =>
         numFiles += 1
         numOutputBytes += a.size
-        if (a.numRecords.isEmpty) {
+        if (a.numLogicalRecords.isEmpty) {
           hasRowLevelMetrics = false
         } else {
-          numCopiedRows += a.numRecords.get
+          numCopiedRows += a.numLogicalRecords.get
         }
       case cdc: AddCDCFile =>
         numAddedChangedFiles += 1