org.apache.hadoop.hbase.regionserver

Class SplitWALCallable

java.lang.Object

org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable

org.apache.hadoop.hbase.regionserver.SplitWALCallable

All Implemented Interfaces:

Callable<Void>, RSProcedureCallable

@InterfaceAudience.Private
public class SplitWALCallable
extends BaseRSProcedureCallable

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 Lock	splitWALLock
private KeyLocker<String>	splitWALLocks
private String	walPath

Fields inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable

rs

Constructor Summary

Constructors

Constructor and Description
SplitWALCallable()

Method Summary

Modifier and Type	Method and Description
protected void	doCall()
EventType	getEventType() Event type used to select thread pool.
String	getWalPath()
protected void	initParameter(byte[] parameter)

Methods inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable

call, init

Methods inherited from class java.lang.Object

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

Field Detail

walPath

private String walPath

splitWALLocks

private final KeyLocker<String> splitWALLocks

splitWALLock

private volatile Lock splitWALLock

Constructor Detail

SplitWALCallable

public SplitWALCallable()

Method Detail

initParameter

protected void initParameter(byte[] parameter)
                      throws org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException

Specified by:

initParameter in class BaseRSProcedureCallable

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException

getEventType

public EventType getEventType()

Description copied from interface: RSProcedureCallable

Event type used to select thread pool.

doCall

protected void doCall()
               throws Exception

Specified by:

doCall in class BaseRSProcedureCallable

Throws:

Exception

getWalPath

public String getWalPath()