From 562e28f07918be76ab674d509a0e237d51533e02 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=91=A3=E5=8F=AF=E4=BC=A6?= Date: Fri, 27 Aug 2021 17:17:22 +0800 Subject: [PATCH] [HUDI-2365]Optimizing overwriteField method with Objects.equals (#3542) Optimizing overwriteField method with Objects.equals --- .../hudi/common/model/OverwriteWithLatestAvroPayload.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java b/hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java index 6e8351cc0..8c7820978 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java @@ -26,6 +26,7 @@ import org.apache.avro.generic.GenericRecord; import org.apache.avro.generic.IndexedRecord; import java.io.IOException; +import java.util.Objects; /** * Default payload used for delta streamer. @@ -98,6 +99,6 @@ public class OverwriteWithLatestAvroPayload extends BaseAvroPayload * Return true if value equals defaultValue otherwise false. */ public Boolean overwriteField(Object value, Object defaultValue) { - return defaultValue == null ? value == null : defaultValue.equals(value); + return Objects.equals(value, defaultValue); } }