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 <[email protected]>
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,
