[iceberg] branch master updated: Spark 3.3: Remove redundant vars in ChangelogRowReader (#6792)

[ao...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

aokolnychyi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new 824c6d8ad3 Spark 3.3: Remove redundant vars in ChangelogRowReader (#6792)
824c6d8ad3 is described below

commit 824c6d8ad389bd9659a43cff81d2eaea3875fc95
Author: Anton Okolnychyi <ao...@apple.com>
AuthorDate: Fri Feb 10 13:47:51 2023 -0800

    Spark 3.3: Remove redundant vars in ChangelogRowReader (#6792)
---
 .../org/apache/iceberg/spark/source/ChangelogRowReader.java    | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/ChangelogRowReader.java b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/ChangelogRowReader.java
index 41d8f62c57..ecda3ca37c 100644
--- a/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/ChangelogRowReader.java
+++ b/spark/v3.3/spark/src/main/java/org/apache/iceberg/spark/source/ChangelogRowReader.java
@@ -151,16 +151,14 @@ class ChangelogRowReader extends BaseRowReader<ChangelogScanTask>
   }
 
   private static Stream<ContentFile<?>> deletedDataFileScanTaskFiles(DeletedDataFileScanTask task) {
-    DeletedDataFileScanTask deletedDataFileScanTask = task;
-    DataFile file = deletedDataFileScanTask.file();
-    List<DeleteFile> existingDeletes = deletedDataFileScanTask.existingDeletes();
+    DataFile file = task.file();
+    List<DeleteFile> existingDeletes = task.existingDeletes();
     return Stream.concat(Stream.of(file), existingDeletes.stream());
   }
 
   private static Stream<ContentFile<?>> addedRowsScanTaskFiles(AddedRowsScanTask task) {
-    AddedRowsScanTask addedRowsScanTask = task;
-    DataFile file = addedRowsScanTask.file();
-    List<DeleteFile> deletes = addedRowsScanTask.deletes();
+    DataFile file = task.file();
+    List<DeleteFile> deletes = task.deletes();
     return Stream.concat(Stream.of(file), deletes.stream());
   }
 }