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

[aokolnychyi]

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 <aokolnyc...@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());
   }
 }