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,