@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,
AtomicInteger inProgressTasks,
SplitLogWorker.TaskExecutor splitTaskExecutor,
org.apache.hadoop.hbase.protobuf.generated.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, AtomicInteger inProgressTasks, SplitLogWorker.TaskExecutor splitTaskExecutor, org.apache.hadoop.hbase.protobuf.generated.ZooKeeperProtos.SplitLogTask.RecoveryMode mode)
public void process()
throws IOException
EventHandlerprocess in class EventHandlerIOExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.