From d909a38b69f27ed3597a46deff63aa7a2126bbde Mon Sep 17 00:00:00 2001 From: Amogh Jahagirdar Date: Mon, 25 Dec 2023 08:26:52 -0800 Subject: [PATCH] Core: Remove unused sourceTransform in private method (#9379) --- .../java/org/apache/iceberg/BaseUpdatePartitionSpec.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/core/src/main/java/org/apache/iceberg/BaseUpdatePartitionSpec.java b/core/src/main/java/org/apache/iceberg/BaseUpdatePartitionSpec.java index 02794da2e4de..b59292c397a1 100644 --- a/core/src/main/java/org/apache/iceberg/BaseUpdatePartitionSpec.java +++ b/core/src/main/java/org/apache/iceberg/BaseUpdatePartitionSpec.java @@ -156,8 +156,7 @@ public BaseUpdatePartitionSpec addField(Term term) { return addField(null, term); } - private BaseUpdatePartitionSpec rewriteDeleteAndAddField( - PartitionField existing, String name, Pair> sourceTransform) { + private BaseUpdatePartitionSpec rewriteDeleteAndAddField(PartitionField existing, String name) { deletes.remove(existing.fieldId()); if (name == null || existing.name().equals(name)) { return this; @@ -180,7 +179,7 @@ public BaseUpdatePartitionSpec addField(String name, Term term) { if (existing != null && deletes.contains(existing.fieldId()) && existing.transform().equals(sourceTransform.second())) { - return rewriteDeleteAndAddField(existing, name, sourceTransform); + return rewriteDeleteAndAddField(existing, name); } Preconditions.checkArgument(