public class MarkPartitionDoneEventAction extends Object implements PartitionMarkDoneAction
PartitionMarkDoneAction which add mark "PartitionEventType.LOAD_DONE".| 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, waitcreateActions, createPartitionHandler, generateCustomMarkDoneAction, openpublic MarkPartitionDoneEventAction(PartitionHandler partitionHandler)
public void markDone(String partition) throws Exception
markDone in interface PartitionMarkDoneActionExceptionpublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableIOExceptionCopyright © 2023–2025 The Apache Software Foundation. All rights reserved.