org.apache.hadoop.hbase.regionserver

Class SplitWALCallable

java.lang.Object

org.apache.hadoop.hbase.regionserver.SplitWALCallable

All Implemented Interfaces:

Callable<Void>, RSProcedureCallable

@InterfaceAudience.Private
public class SplitWALCallable
extends Object
implements RSProcedureCallable

This callable is used to do the real split WAL task. It is called by SplitWALRemoteProcedure from master and executed by executor service which is in charge of executing the events of EventType.RS_LOG_REPLAY When execute this callable, it will call SplitLogWorker.splitLog() to split the WAL. If the return value is SplitLogWorker.TaskExecutor.Status.DONE, it means the task is successful and it will return null to end the call. Otherwise it will throw an exception and let SplitWALRemoteProcedure to handle this problem. This class is to replace the zk-based WAL splitting related code, SplitLogWorker, SplitLogWorkerCoordination and ZkSplitLogWorkerCoordination can be removed after we switch to procedure-based WAL splitting.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SplitWALCallable.ErrorWALSplitException
static class	SplitWALCallable.PreemptedWALSplitException
static class	SplitWALCallable.ResignedWALSplitException

Field Summary

Fields

Modifier and Type	Field and Description
private Exception	initError
private static org.slf4j.Logger	LOG
private HRegionServer	rs
private Lock	splitWALLock
private KeyLocker<String>	splitWALLocks
private String	walPath

Constructor Summary

Constructors

Constructor and Description
SplitWALCallable()

Method Summary

Modifier and Type	Method and Description
Void	call()
EventType	getEventType() Event type used to select thread pool.
String	getWalPath()
void	init(byte[] parameter, HRegionServer rs) Initialize the callable

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

walPath

private String walPath

initError

private Exception initError

rs

private HRegionServer rs

splitWALLocks

private final KeyLocker<String> splitWALLocks

splitWALLock

private volatile Lock splitWALLock

Constructor Detail

SplitWALCallable

public SplitWALCallable()

Method Detail

init

public void init(byte[] parameter,
                 HRegionServer rs)

Description copied from interface: RSProcedureCallable

Initialize the callable

Specified by:

init in interface RSProcedureCallable

Parameters:

parameter - the parameter passed from master.

rs - the regionserver instance

getEventType

public EventType getEventType()

Description copied from interface: RSProcedureCallable

Event type used to select thread pool.

Specified by:

getEventType in interface RSProcedureCallable

call

public Void call()
          throws Exception

Specified by:

call in interface Callable<Void>

Throws:

Exception

getWalPath

public String getWalPath()