public class RecoveredReplicationSourceWALReader extends ReplicationSourceWALReader
RecoveredReplicationSourceShipper
.entryBatchQueue, replicationBatchCountCapacity
Constructor and Description |
---|
RecoveredReplicationSourceWALReader(FileSystem fs,
Configuration conf,
java.util.concurrent.PriorityBlockingQueue<Path> logQueue,
long startPosition,
WALEntryFilter filter,
ReplicationSource source) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleEmptyWALEntryBatch(org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch batch,
Path currentPath) |
getCurrentPath, isReaderRunning, run, setReaderRunning, take
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public RecoveredReplicationSourceWALReader(FileSystem fs, Configuration conf, java.util.concurrent.PriorityBlockingQueue<Path> logQueue, long startPosition, WALEntryFilter filter, ReplicationSource source)
protected void handleEmptyWALEntryBatch(org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader.WALEntryBatch batch, Path currentPath) throws java.lang.InterruptedException
handleEmptyWALEntryBatch
in class ReplicationSourceWALReader
java.lang.InterruptedException