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

@InterfaceAudience.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 and Description
private SerialReplicationChecker	checker
private Cell	firstCellInEntryBeforeFiltering

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SerialReplicationSourceWALReader(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 WALEntryBatch	readWALEntries(WALEntryStream entryStream)
private void	removeEntryFromStream(WALEntryStream entryStream, WALEntryBatch batch)

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

addEntryToBatch, createBatch, filterEntry, getCurrentPath, getEntrySizeExcludeBulkLoad, isReaderRunning, poll, run, setReaderRunning, 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 Detail

firstCellInEntryBeforeFiltering

private Cell firstCellInEntryBeforeFiltering

checker

private final SerialReplicationChecker checker

Constructor Detail

SerialReplicationSourceWALReader

public SerialReplicationSourceWALReader(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

readWALEntries

protected WALEntryBatch readWALEntries(WALEntryStream entryStream)
                                throws IOException,
                                       InterruptedException

Overrides:

readWALEntries in class ReplicationSourceWALReader

Throws:

IOException

InterruptedException

removeEntryFromStream

private void removeEntryFromStream(WALEntryStream entryStream,
                                   WALEntryBatch batch)
                            throws IOException

Throws:

IOException