Class SplitWALCallable
java.lang.Object
org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable
org.apache.hadoop.hbase.regionserver.SplitWALCallable
- All Implemented Interfaces:
Callable<Void>
,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
Modifier and TypeClassDescriptionstatic class
static class
static class
-
Field Summary
Fields inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable
rs
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
doCall()
Event type used to select thread pool.protected void
initParameter
(byte[] parameter) Methods inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable
call, init
-
Field Details
-
walPath
-
splitWALLocks
-
splitWALLock
-
-
Constructor Details
-
SplitWALCallable
public SplitWALCallable()
-
-
Method Details
-
initParameter
protected void initParameter(byte[] parameter) throws org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException - Specified by:
initParameter
in classBaseRSProcedureCallable
- Throws:
org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException
-
getEventType
Description copied from interface:RSProcedureCallable
Event type used to select thread pool. -
doCall
- Specified by:
doCall
in classBaseRSProcedureCallable
- Throws:
Exception
-
getWalPath
-