@InterfaceAudience.Private public class ReplaySyncReplicationWALCallable extends BaseRSProcedureCallable
Modifier and Type | Field and Description |
---|---|
private long |
batchSize |
private static long |
DEFAULT_REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE |
private static org.slf4j.Logger |
LOG |
private String |
peerId |
private KeyLocker<String> |
peersLock |
private static String |
REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE |
private List<String> |
wals |
rs
Constructor and Description |
---|
ReplaySyncReplicationWALCallable() |
Modifier and Type | Method and Description |
---|---|
protected void |
doCall() |
private boolean |
filter(WAL.Entry entry) |
EventType |
getEventType()
Event type used to select thread pool.
|
private WALStreamReader |
getReader(String wal) |
protected void |
initParameter(byte[] parameter) |
private List<WAL.Entry> |
readWALEntries(WALStreamReader reader,
String wal) |
private void |
replayWAL(String wal) |
call, init
private static final org.slf4j.Logger LOG
private static final String REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE
private static final long DEFAULT_REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE
private long batchSize
public ReplaySyncReplicationWALCallable()
protected void doCall() throws Exception
doCall
in class BaseRSProcedureCallable
Exception
protected void initParameter(byte[] parameter) throws org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException
initParameter
in class BaseRSProcedureCallable
org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException
public EventType getEventType()
RSProcedureCallable
private void replayWAL(String wal) throws IOException
IOException
private WALStreamReader getReader(String wal) throws IOException
IOException
private List<WAL.Entry> readWALEntries(WALStreamReader reader, String wal) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.