@InterfaceAudience.Private public class WALSplitterHandler extends EventHandler
eventType, seqids, server, waitingTimeForEvents
Constructor and Description |
---|
WALSplitterHandler(Server server,
SplitLogWorkerCoordination coordination,
SplitLogWorkerCoordination.SplitTaskDetails splitDetails,
CancelableProgressable reporter,
AtomicInteger inProgressTasks,
SplitLogWorker.TaskExecutor splitTaskExecutor) |
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, getPriority, getSeqid, handleException, prepare, run, toString
public WALSplitterHandler(Server server, SplitLogWorkerCoordination coordination, SplitLogWorkerCoordination.SplitTaskDetails splitDetails, CancelableProgressable reporter, AtomicInteger inProgressTasks, SplitLogWorker.TaskExecutor splitTaskExecutor)
public void process() throws IOException
EventHandler
process
in class EventHandler
IOException
Copyright © 2007–2019 Cloudera. All rights reserved.