@InterfaceAudience.Private public class WALSplitterHandler extends EventHandler
EventHandler.EventHandlerListenereventType, seqids, server, waitingTimeForEvents| Constructor and Description |
|---|
WALSplitterHandler(Server server,
SplitLogWorkerCoordination coordination,
SplitLogWorkerCoordination.SplitTaskDetails splitDetails,
CancelableProgressable reporter,
java.util.concurrent.atomic.AtomicInteger inProgressTasks,
SplitLogWorker.TaskExecutor splitTaskExecutor,
ZooKeeperProtos.SplitLogTask.RecoveryMode mode) |
| Modifier and Type | Method and Description |
|---|---|
void |
process()
This method is the main processing loop to be implemented by the various
subclasses.
|
compareTo, getEventType, getInformativeName, getListener, getPriority, getSeqid, handleException, prepare, run, setListener, toStringpublic WALSplitterHandler(Server server, SplitLogWorkerCoordination coordination, SplitLogWorkerCoordination.SplitTaskDetails splitDetails, CancelableProgressable reporter, java.util.concurrent.atomic.AtomicInteger inProgressTasks, SplitLogWorker.TaskExecutor splitTaskExecutor, ZooKeeperProtos.SplitLogTask.RecoveryMode mode)
public void process()
throws java.io.IOException
EventHandlerprocess in class EventHandlerjava.io.IOException