org.apache.hadoop.hbase.regionserver.handler

Class WALSplitterHandler

java.lang.Object

org.apache.hadoop.hbase.executor.EventHandler

org.apache.hadoop.hbase.regionserver.handler.WALSplitterHandler

All Implemented Interfaces:

Comparable<Runnable>, Runnable

@InterfaceAudience.Private
public class WALSplitterHandler
extends EventHandler

Handles log splitting a wal

Field Summary

Fields

Modifier and Type	Field and Description
private SplitLogWorkerCoordination	coordination
private AtomicInteger	inProgressTasks
private static org.slf4j.Logger	LOG
private CancelableProgressable	reporter
private ServerName	serverName
private SplitLogWorkerCoordination.SplitTaskDetails	splitTaskDetails
private SplitLogWorker.TaskExecutor	splitTaskExecutor

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

eventType, seqids, server, waitingTimeForEvents

Constructor Summary

Constructors

Constructor and Description
WALSplitterHandler(Server server, SplitLogWorkerCoordination coordination, SplitLogWorkerCoordination.SplitTaskDetails splitDetails, CancelableProgressable reporter, AtomicInteger inProgressTasks, SplitLogWorker.TaskExecutor splitTaskExecutor)

Method Summary

Modifier and Type	Method and Description
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, getPriority, getSeqid, handleException, prepare, run, toString

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

serverName

private final ServerName serverName

reporter

private final CancelableProgressable reporter

inProgressTasks

private final AtomicInteger inProgressTasks

splitTaskExecutor

private final SplitLogWorker.TaskExecutor splitTaskExecutor

splitTaskDetails

private final SplitLogWorkerCoordination.SplitTaskDetails splitTaskDetails

coordination

private final SplitLogWorkerCoordination coordination

Constructor Detail

WALSplitterHandler

public WALSplitterHandler(Server server,
                          SplitLogWorkerCoordination coordination,
                          SplitLogWorkerCoordination.SplitTaskDetails splitDetails,
                          CancelableProgressable reporter,
                          AtomicInteger inProgressTasks,
                          SplitLogWorker.TaskExecutor splitTaskExecutor)

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