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
Nested ClassesModifier and TypeClassDescriptionstatic classstatic classstatic class -
Field Summary
FieldsFields inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable
rs -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoCall()Event type used to select thread pool.protected voidinitParameter(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:
initParameterin classBaseRSProcedureCallable- Throws:
org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException
-
getEventType
Description copied from interface:RSProcedureCallableEvent type used to select thread pool. -
doCall
- Specified by:
doCallin classBaseRSProcedureCallable- Throws:
Exception
-
getWalPath
-