public class MarkPartitionDoneEventAction extends Object implements PartitionMarkDoneAction
PartitionMarkDoneAction
which add mark "PartitionEventType.LOAD_DONE".CUSTOM, DONE_PARTITION, MARK_EVENT, SUCCESS_FILE
Constructor and Description |
---|
MarkPartitionDoneEventAction(PartitionHandler partitionHandler) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
markDone(String partition) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createActions, createPartitionHandler, generateCustomMarkDoneAction
public MarkPartitionDoneEventAction(PartitionHandler partitionHandler)
public void markDone(String partition) throws Exception
markDone
in interface PartitionMarkDoneAction
Exception
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.