hudi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From le...@apache.org
Subject [incubator-hudi] branch master updated: [MINOR] Add omissive param desc on method doc and cleanup redundant code (#1437)
Date Sun, 22 Mar 2020 13:39:40 GMT
This is an automated email from the ASF dual-hosted git repository.

leesf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 06652aa  [MINOR] Add omissive param desc on method doc and cleanup redundant code
(#1437)
06652aa is described below

commit 06652aa93515fa8178e7fea2279f40123a69978c
Author: Zhiyuan Zhao <49054376+zhaomin1423@users.noreply.github.com>
AuthorDate: Sun Mar 22 21:39:33 2020 +0800

    [MINOR] Add omissive param desc on method doc and cleanup redundant code (#1437)
---
 .../org/apache/hudi/client/AbstractHoodieWriteClient.java   | 13 -------------
 .../org/apache/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 ad56762..ae75bb8 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<T extends HoodieRecordPayload>
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 5a8510f..633f1de 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<String> writeToSink(JavaRDD<HoodieRecord> records, String checkpointStr,


Mime
View raw message