Package 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:

Runnable

@Private
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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final Runnable	tryFinish

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

entryReader, walGroupId

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf, String walGroupId, RecoveredReplicationSource source, ReplicationSourceWALReader walReader, ReplicationQueueStorage queueStorage, Runnable tryFinish)

Method Summary

Modifier and Type	Method	Description
protected void	postFinish()

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

clearWALEntryBatch, getCurrentPath, getCurrentPosition, isActive, isFinished, run, setWorkerState, startup, stopWorker

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

tryFinish

private final Runnable tryFinish

Constructor Details

RecoveredReplicationSourceShipper

public RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf,
 String walGroupId,
 RecoveredReplicationSource source,
 ReplicationSourceWALReader walReader,
 ReplicationQueueStorage queueStorage,
 Runnable tryFinish)

Method Details

postFinish

protected void postFinish()

Overrides:

postFinish in class ReplicationSourceShipper