Class ReplaySyncReplicationWALCallable
java.lang.Object
org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable
org.apache.hadoop.hbase.replication.regionserver.ReplaySyncReplicationWALCallable
- All Implemented Interfaces:
Callable<Void>
,RSProcedureCallable
This callable executed at RS side to replay sync replication wal.
-
Field Summary
Modifier and TypeFieldDescriptionprivate long
private static final long
private static final org.slf4j.Logger
private String
private static final String
Fields inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable
rs
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
doCall()
private boolean
Event type used to select thread pool.private WALStreamReader
protected void
initParameter
(byte[] parameter) readWALEntries
(WALStreamReader reader, String wal) private void
Methods inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable
call, init
-
Field Details
-
LOG
-
REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE
- See Also:
-
DEFAULT_REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE
- See Also:
-
peerId
-
wals
-
batchSize
-
peersLock
-
-
Constructor Details
-
ReplaySyncReplicationWALCallable
public ReplaySyncReplicationWALCallable()
-
-
Method Details
-
doCall
- Specified by:
doCall
in classBaseRSProcedureCallable
- Throws:
Exception
-
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. -
replayWAL
- Throws:
IOException
-
getReader
- Throws:
IOException
-
filter
-
readWALEntries
- Throws:
IOException
-