org.apache.hadoop.hbase.regionserver.handler

Class HLogSplitterHandler

java.lang.Object

org.apache.hadoop.hbase.executor.EventHandler

org.apache.hadoop.hbase.regionserver.handler.HLogSplitterHandler

All Implemented Interfaces:

Comparable<Runnable>, Runnable

@InterfaceAudience.Private
public class HLogSplitterHandler
extends EventHandler

Handles log splitting a wal

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.executor.EventHandler

EventHandler.EventHandlerListener

Field Summary

Fields inherited from class org.apache.hadoop.hbase.executor.EventHandler

eventType, seqids, server, waitingTimeForEvents

Constructor Summary

Constructors

Constructor and Description
HLogSplitterHandler(Server server, String curTask, org.apache.commons.lang.mutable.MutableInt curTaskZKVersion, CancelableProgressable reporter, AtomicInteger inProgressTasks, SplitLogWorker.TaskExecutor splitTaskExecutor, ZooKeeperProtos.SplitLogTask.RecoveryMode mode)

Method Summary

Methods

Modifier and Type	Method and Description
static void	endTask(ZooKeeperWatcher zkw, SplitLogTask slt, AtomicLong ctr, String task, int taskZKVersion) endTask() can fail and the only way to recover out of it is for the SplitLogManager to timeout the task node.
void	process() This method is the main processing loop to be implemented by the various subclasses.

Methods inherited from class org.apache.hadoop.hbase.executor.EventHandler

compareTo, getEventType, getInformativeName, getListener, getPriority, getSeqid, handleException, prepare, run, setListener, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

HLogSplitterHandler

public HLogSplitterHandler(Server server,
                   String curTask,
                   org.apache.commons.lang.mutable.MutableInt curTaskZKVersion,
                   CancelableProgressable reporter,
                   AtomicInteger inProgressTasks,
                   SplitLogWorker.TaskExecutor splitTaskExecutor,
                   ZooKeeperProtos.SplitLogTask.RecoveryMode mode)

Method Detail

process

public void process()
             throws IOException

Description copied from class: EventHandler

This method is the main processing loop to be implemented by the various subclasses.

Specified by:

process in class EventHandler

Throws:

IOException

endTask

public static void endTask(ZooKeeperWatcher zkw,
           SplitLogTask slt,
           AtomicLong ctr,
           String task,
           int taskZKVersion)

endTask() can fail and the only way to recover out of it is for the SplitLogManager to timeout the task node.

Parameters:

slt -

ctr -