org.apache.hadoop.hbase.replication.regionserver

Class SerialReplicationSourceWALReader

java.lang.Object

java.lang.Thread

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

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
public class SerialReplicationSourceWALReader
extends Thread

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 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 boolean	addEntryToBatch(org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch batch, WAL.Entry entry)
protected org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch	createBatch(org.apache.hadoop.hbase.replication.regionserver.WALEntryStream entryStream)
protected WAL.Entry	filterEntry(WAL.Entry entry)
org.apache.hadoop.fs.Path	getCurrentPath()
static long	getEntrySizeExcludeBulkLoad(WAL.Entry entry)
boolean	isReaderRunning()
org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch	poll(long timeout)
protected org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch	readWALEntries(org.apache.hadoop.hbase.replication.regionserver.WALEntryStream entryStream)
void	run()
void	setReaderRunning(boolean readerRunning)
protected static boolean	switched(org.apache.hadoop.hbase.replication.regionserver.WALEntryStream entryStream, org.apache.hadoop.fs.Path path)
org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch	take() Retrieves the next batch of WAL entries from the queue, waiting up to the specified time for a batch to become available

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

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 org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch readWALEntries(org.apache.hadoop.hbase.replication.regionserver.WALEntryStream entryStream)
                                                                                 throws IOException,
                                                                                        InterruptedException

Throws:

IOException

InterruptedException

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

addEntryToBatch

protected final boolean addEntryToBatch(org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch batch,
                                        WAL.Entry entry)

switched

protected static final boolean switched(org.apache.hadoop.hbase.replication.regionserver.WALEntryStream entryStream,
                                        org.apache.hadoop.fs.Path path)

getCurrentPath

public org.apache.hadoop.fs.Path getCurrentPath()

createBatch

protected final org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch createBatch(org.apache.hadoop.hbase.replication.regionserver.WALEntryStream entryStream)

filterEntry

protected final WAL.Entry filterEntry(WAL.Entry entry)

take

public org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch take()
                                                                    throws InterruptedException

Retrieves the next batch of WAL entries from the queue, waiting up to the specified time for a batch to become available

Returns:

A batch of entries, along with the position in the log after reading the batch

Throws:

InterruptedException - if interrupted while waiting

poll

public org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch poll(long timeout)
                                                                    throws InterruptedException

Throws:

InterruptedException

getEntrySizeExcludeBulkLoad

public static long getEntrySizeExcludeBulkLoad(WAL.Entry entry)

isReaderRunning

public boolean isReaderRunning()

Returns:

whether the reader thread is running

setReaderRunning

public void setReaderRunning(boolean readerRunning)

Parameters:

readerRunning - the readerRunning to set