Package org.apache.hadoop.hbase.replication.regionserver

Class ReplaySyncReplicationWALCallable

java.lang.Object

org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable

org.apache.hadoop.hbase.replication.regionserver.ReplaySyncReplicationWALCallable

All Implemented Interfaces:

Callable<Void>, RSProcedureCallable

@Private
public class ReplaySyncReplicationWALCallable
extends BaseRSProcedureCallable

This callable executed at RS side to replay sync replication wal.

Field Summary

Fields

Modifier and Type	Field	Description
private long	batchSize
private static final long	DEFAULT_REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE
private static final org.slf4j.Logger	LOG
private String	peerId
private final KeyLocker<String>	peersLock
private static final String	REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE
private List<String>	wals

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

rs

Constructor Summary

Constructors

Constructor	Description
ReplaySyncReplicationWALCallable()

Method Summary

Modifier and Type	Method	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)

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 Details

LOG

private static final org.slf4j.Logger LOG

REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE

private static final String REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE

See Also:

• Constant Field Values

DEFAULT_REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE

private static final long DEFAULT_REPLAY_SYNC_REPLICATION_WAL_BATCH_SIZE

See Also:

• Constant Field Values

peerId

private String peerId

wals

private List<String> wals

batchSize

private long batchSize

peersLock

private final KeyLocker<String> peersLock

Constructor Details

ReplaySyncReplicationWALCallable

public ReplaySyncReplicationWALCallable()

Method Details

doCall

protected void doCall()
               throws Exception

Specified by:

doCall in class BaseRSProcedureCallable

Throws:

Exception

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.

replayWAL

private void replayWAL(String wal)
                throws IOException

Throws:

IOException

getReader

private WALStreamReader getReader(String wal)
                           throws IOException

Throws:

IOException

filter

private boolean filter(WAL.Entry entry)

readWALEntries

private List<WAL.Entry> readWALEntries(WALStreamReader reader,
 String wal)
                                throws IOException

Throws:

IOException