org.apache.hadoop.hbase.replication.regionserver

Class RecoveredReplicationSourceShipper

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper

org.apache.hadoop.hbase.replication.regionserver.RecoveredReplicationSourceShipper

All Implemented Interfaces:

java.lang.Runnable

public class RecoveredReplicationSourceShipper
extends ReplicationSourceShipper

Used by a RecoveredReplicationSource.

Nested Class Summary

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

ReplicationSourceShipper.WorkerState

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected RecoveredReplicationSource	source

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

conf, currentPath, entryReader, lastLoggedPosition, maxRetriesMultiplier, queue, sleepForRetries, walGroupId

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
RecoveredReplicationSourceShipper(Configuration conf, java.lang.String walGroupId, java.util.concurrent.PriorityBlockingQueue<Path> queue, RecoveredReplicationSource source, ReplicationQueues replicationQueues)

Method Summary

Modifier and Type	Method and Description
long	getStartPosition()
void	run()
protected void	updateLogPosition(long lastReadPosition)

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

getCurrentPath, getCurrentPosition, getLogQueue, getWorkerState, isActive, isFinished, setWALReader, setWorkerState, shipEdits, sleepForRetries, startup, stopWorker

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

source

protected final RecoveredReplicationSource source

Constructor Detail

RecoveredReplicationSourceShipper

public RecoveredReplicationSourceShipper(Configuration conf,
                                         java.lang.String walGroupId,
                                         java.util.concurrent.PriorityBlockingQueue<Path> queue,
                                         RecoveredReplicationSource source,
                                         ReplicationQueues replicationQueues)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class ReplicationSourceShipper

getStartPosition

public long getStartPosition()

Overrides:

getStartPosition in class ReplicationSourceShipper

updateLogPosition

protected void updateLogPosition(long lastReadPosition)

Overrides:

updateLogPosition in class ReplicationSourceShipper