org.apache.hadoop.hbase.replication.regionserver

Class RecoveredReplicationSource

java.lang.Object

java.lang.Thread

org.apache.hadoop.hbase.replication.regionserver.ReplicationSource

org.apache.hadoop.hbase.replication.regionserver.RecoveredReplicationSource

All Implemented Interfaces:

java.lang.Runnable, ReplicationSourceInterface

public class RecoveredReplicationSource
extends ReplicationSource

Class that handles the recovered source of a replication stream, which is transfered from another dead region server. This will be closed when all logs are pushed to peer cluster.

Nested Class Summary

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

ReplicationSource.LogsComparator

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

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

Field Summary

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

conf, DEFAULT_WAIT_ON_ENDPOINT_SECONDS, fs, manager, peerClusterZnode, queueSizePerGroup, replicationQueueInfo, replicationQueues, server, WAIT_ON_ENDPOINT_SECONDS, walEntryFilter, workerThreads

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
RecoveredReplicationSource()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getPeerId() Get the id that the source is replicating to.
ServerName	getServerWALsBelongTo() The queue of WALs only belong to one region server.
void	init(Configuration conf, FileSystem fs, ReplicationSourceManager manager, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, Server server, java.lang.String peerClusterZnode, java.util.UUID clusterId, ReplicationEndpoint replicationEndpoint, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics) Instantiation method used by region servers
void	locateRecoveredPaths(java.util.concurrent.PriorityBlockingQueue<Path> queue)
protected ReplicationSourceWALReader	startNewWALReader(java.lang.String threadName, java.lang.String walGroupId, java.util.concurrent.PriorityBlockingQueue<Path> queue, long startPosition)
void	tryFinish()
protected void	tryStartNewShipper(java.lang.String walGroupId, java.util.concurrent.PriorityBlockingQueue<Path> queue)

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

addHFileRefs, enqueueLog, getCurrentPath, getPeerClusterZnode, getReplicationEndpoint, getSourceManager, getSourceMetrics, getStats, getUncaughtExceptionHandler, getWALFileLengthProvider, isPeerEnabled, isSourceActive, postShipEdits, run, sleepForRetries, startup, terminate, terminate, terminate, tryThrottle

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, 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

RecoveredReplicationSource

public RecoveredReplicationSource()

Method Detail

init

public void init(Configuration conf,
                 FileSystem fs,
                 ReplicationSourceManager manager,
                 ReplicationQueues replicationQueues,
                 ReplicationPeers replicationPeers,
                 Server server,
                 java.lang.String peerClusterZnode,
                 java.util.UUID clusterId,
                 ReplicationEndpoint replicationEndpoint,
                 WALFileLengthProvider walFileLengthProvider,
                 MetricsSource metrics)
          throws java.io.IOException

Description copied from class: ReplicationSource

Instantiation method used by region servers

Specified by:

init in interface ReplicationSourceInterface

Overrides:

init in class ReplicationSource

Parameters:

conf - configuration to use

fs - file system to use

manager - replication manager to ping to

server - the server for this region server

peerClusterZnode - the name of our znode

clusterId - unique UUID for the cluster

replicationEndpoint - the replication endpoint implementation

metrics - metrics for replication source

Throws:

java.io.IOException

tryStartNewShipper

protected void tryStartNewShipper(java.lang.String walGroupId,
                                  java.util.concurrent.PriorityBlockingQueue<Path> queue)

Overrides:

tryStartNewShipper in class ReplicationSource

startNewWALReader

protected ReplicationSourceWALReader startNewWALReader(java.lang.String threadName,
                                                       java.lang.String walGroupId,
                                                       java.util.concurrent.PriorityBlockingQueue<Path> queue,
                                                       long startPosition)

Overrides:

startNewWALReader in class ReplicationSource

locateRecoveredPaths

public void locateRecoveredPaths(java.util.concurrent.PriorityBlockingQueue<Path> queue)
                          throws java.io.IOException

Throws:

java.io.IOException

tryFinish

public void tryFinish()

getPeerId

public java.lang.String getPeerId()

Description copied from interface: ReplicationSourceInterface

Get the id that the source is replicating to.

Specified by:

getPeerId in interface ReplicationSourceInterface

Overrides:

getPeerId in class ReplicationSource

Returns:

peer id

getServerWALsBelongTo

public ServerName getServerWALsBelongTo()

Description copied from interface: ReplicationSourceInterface

The queue of WALs only belong to one region server. This will return the server name which all WALs belong to.

Specified by:

getServerWALsBelongTo in interface ReplicationSourceInterface

Overrides:

getServerWALsBelongTo in class ReplicationSource

Returns:

the server name which all WALs belong to