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

Class SerialReplicationSourceWALReader

java.lang.Object

java.lang.Thread

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

org.apache.hadoop.hbase.replication.regionserver.SerialReplicationSourceWALReader

All Implemented Interfaces:

Runnable

@Private
public class SerialReplicationSourceWALReader
extends ReplicationSourceWALReader

WAL reader for a serial replication peer.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final SerialReplicationChecker	checker
private Cell	firstCellInEntryBeforeFiltering
private static final org.slf4j.Logger	LOG

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

entryBatchQueue, waitingPeerEnabled

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
SerialReplicationSourceWALReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, ReplicationSourceLogQueue logQueue, long startPosition, WALEntryFilter filter, ReplicationSource source, String walGroupId)

Method Summary

Modifier and Type	Method	Description
protected void	readWALEntries(WALEntryStream entryStream, WALEntryBatch batch)
private void	removeEntryFromStream(WALEntryStream entryStream, WALEntryBatch batch)

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

addEntryToBatch, filterEntry, getCurrentPath, isReaderRunning, poll, run, setReaderRunning, sleep, switched, 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 Details

LOG

private static final org.slf4j.Logger LOG

firstCellInEntryBeforeFiltering

private Cell firstCellInEntryBeforeFiltering

checker

private final SerialReplicationChecker checker

Constructor Details

SerialReplicationSourceWALReader

public SerialReplicationSourceWALReader(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.conf.Configuration conf,
 ReplicationSourceLogQueue logQueue,
 long startPosition,
 WALEntryFilter filter,
 ReplicationSource source,
 String walGroupId)

Method Details

readWALEntries

protected void readWALEntries(WALEntryStream entryStream,
 WALEntryBatch batch)
                       throws InterruptedException

Overrides:

readWALEntries in class ReplicationSourceWALReader

Throws:

InterruptedException

removeEntryFromStream

private void removeEntryFromStream(WALEntryStream entryStream,
 WALEntryBatch batch)