[HUDI-1223] Remove unused UpdateHandler class in HoodieCopyOnWriteTable (#2032)
diff --git a/hudi-client/src/main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java b/hudi-client/src/main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java
index 21f8bef..6292e56 100644
--- a/hudi-client/src/main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java
+++ b/hudi-client/src/main/java/org/apache/hudi/table/HoodieCopyOnWriteTable.java
@@ -32,7 +32,6 @@
import org.apache.hudi.common.table.timeline.HoodieInstant;
import org.apache.hudi.common.table.timeline.HoodieTimeline;
import org.apache.hudi.common.util.Option;
-import org.apache.hudi.common.util.queue.BoundedInMemoryQueueConsumer;
import org.apache.hudi.config.HoodieWriteConfig;
import org.apache.hudi.exception.HoodieNotSupportedException;
import org.apache.hudi.exception.HoodieUpsertException;
@@ -54,7 +53,6 @@
import org.apache.hudi.table.action.rollback.CopyOnWriteRollbackActionExecutor;
import org.apache.hudi.table.action.savepoint.SavepointActionExecutor;
-import org.apache.avro.generic.GenericRecord;
import org.apache.hadoop.conf.Configuration;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
@@ -203,29 +201,4 @@
return new CopyOnWriteRestoreActionExecutor(jsc, config, this, restoreInstantTime, instantToRestore).execute();
}
- /**
- * Consumer that dequeues records from queue and sends to Merge Handle.
- */
- private static class UpdateHandler extends BoundedInMemoryQueueConsumer<GenericRecord, Void> {
-
- private final HoodieMergeHandle upsertHandle;
-
- private UpdateHandler(HoodieMergeHandle upsertHandle) {
- this.upsertHandle = upsertHandle;
- }
-
- @Override
- protected void consumeOneRecord(GenericRecord record) {
- upsertHandle.write(record);
- }
-
- @Override
- protected void finish() {}
-
- @Override
- protected Void getResult() {
- return null;
- }
- }
-
}
