org.apache.hadoop.hbase.replication.regionserver

Class RecoveredReplicationSourceWALReader

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader

org.apache.hadoop.hbase.replication.regionserver.RecoveredReplicationSourceWALReader

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class RecoveredReplicationSourceWALReader
extends ReplicationSourceWALReader

Used by a RecoveredReplicationSourceShipper.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader

ReplicationSourceWALReader.WALEntryBatch

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader

entryBatchQueue, replicationBatchCountCapacity

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
RecoveredReplicationSourceWALReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, PriorityBlockingQueue<org.apache.hadoop.fs.Path> logQueue, long startPosition, WALEntryFilter filter, ReplicationSource source)

Method Summary

Modifier and Type	Method and Description
protected void	handleEmptyWALEntryBatch(ReplicationSourceWALReader.WALEntryBatch batch, org.apache.hadoop.fs.Path currentPath)

Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader

getCurrentPath, isReaderRunning, run, setReaderRunning, take

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

RecoveredReplicationSourceWALReader

public RecoveredReplicationSourceWALReader(org.apache.hadoop.fs.FileSystem fs,
                                           org.apache.hadoop.conf.Configuration conf,
                                           PriorityBlockingQueue<org.apache.hadoop.fs.Path> logQueue,
                                           long startPosition,
                                           WALEntryFilter filter,
                                           ReplicationSource source)

Method Detail

handleEmptyWALEntryBatch

protected void handleEmptyWALEntryBatch(ReplicationSourceWALReader.WALEntryBatch batch,
                                        org.apache.hadoop.fs.Path currentPath)
                                 throws InterruptedException

Overrides:

handleEmptyWALEntryBatch in class ReplicationSourceWALReader

Throws:

InterruptedException