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 org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader

entryBatchQueue

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, ReplicationSourceLogQueue logQueue, long startPosition, WALEntryFilter filter, ReplicationSource source, String walGroupId)

Method Summary

Modifier and Type	Method and 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, 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,
                                        ReplicationSourceLogQueue logQueue,
                                        long startPosition,
                                        WALEntryFilter filter,
                                        ReplicationSource source,
                                        String walGroupId)

Method Detail

readWALEntries

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

Overrides:

readWALEntries in class ReplicationSourceWALReader

Throws:

IOException

InterruptedException

removeEntryFromStream

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

Throws:

IOException