From 06652aa93515fa8178e7fea2279f40123a69978c Mon Sep 17 00:00:00 2001 From: Zhiyuan Zhao <49054376+zhaomin1423@users.noreply.github.com> Date: Sun, 22 Mar 2020 21:39:33 +0800 Subject: [PATCH] [MINOR] Add omissive param desc on method doc and cleanup redundant code (#1437) --- .../hudi/client/AbstractHoodieWriteClient.java | 13 ------------- .../hudi/utilities/deltastreamer/DeltaSync.java | 7 ++++--- 2 files changed, 4 insertions(+), 16 deletions(-) diff --git a/hudi-client/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java b/hudi-client/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java index ad56762ee..ae75bb80f 100644 --- a/hudi-client/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java +++ b/hudi-client/src/main/java/org/apache/hudi/client/AbstractHoodieWriteClient.java @@ -417,17 +417,4 @@ public abstract class AbstractHoodieWriteClient e } } - /** - * Refers to different operation types. - */ - enum OperationType { - INSERT, - INSERT_PREPPED, - UPSERT, - UPSERT_PREPPED, - DELETE, - BULK_INSERT, - BULK_INSERT_PREPPED, - BOOTSTRAP - } } diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java index 5a8510fbb..633f1def2 100644 --- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java +++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java @@ -342,9 +342,10 @@ public class DeltaSync implements Serializable { /** * Perform Hoodie Write. Run Cleaner, schedule compaction and syncs to hive if needed. * - * @param records Input Records - * @param checkpointStr Checkpoint String - * @param metrics Metrics + * @param records Input Records + * @param checkpointStr Checkpoint String + * @param metrics Metrics + * @param overallTimerContext Timer Context * @return Option Compaction instant if one is scheduled */ private Option writeToSink(JavaRDD records, String checkpointStr,