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:

Runnable, ReplicationSourceInterface

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private String	actualPeerId
private static org.slf4j.Logger	LOG

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
String	getPeerId() Get the id that the source is replicating to.
private org.apache.hadoop.fs.Path	getReplSyncUpPath(org.apache.hadoop.fs.Path path)
ServerName	getServerWALsBelongTo() The queue of WALs only belong to one region server.
void	init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, ReplicationSourceManager manager, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, Server server, String peerClusterZnode, UUID clusterId, ReplicationEndpoint replicationEndpoint, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics) Instantiation method used by region servers
void	locateRecoveredPaths(PriorityBlockingQueue<org.apache.hadoop.fs.Path> queue)
protected ReplicationSourceWALReader	startNewWALReader(String threadName, String walGroupId, PriorityBlockingQueue<org.apache.hadoop.fs.Path> queue, long startPosition)
void	tryFinish()
protected void	tryStartNewShipper(String walGroupId, PriorityBlockingQueue<org.apache.hadoop.fs.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

Field Detail

LOG

private static final org.slf4j.Logger LOG

actualPeerId

private String actualPeerId

Constructor Detail

RecoveredReplicationSource

public RecoveredReplicationSource()

Method Detail

init

public void init(org.apache.hadoop.conf.Configuration conf,
                 org.apache.hadoop.fs.FileSystem fs,
                 ReplicationSourceManager manager,
                 ReplicationQueues replicationQueues,
                 ReplicationPeers replicationPeers,
                 Server server,
                 String peerClusterZnode,
                 UUID clusterId,
                 ReplicationEndpoint replicationEndpoint,
                 WALFileLengthProvider walFileLengthProvider,
                 MetricsSource metrics)
          throws 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:

IOException

tryStartNewShipper

protected void tryStartNewShipper(String walGroupId,
                                  PriorityBlockingQueue<org.apache.hadoop.fs.Path> queue)

Overrides:

tryStartNewShipper in class ReplicationSource

startNewWALReader

protected ReplicationSourceWALReader startNewWALReader(String threadName,
                                                       String walGroupId,
                                                       PriorityBlockingQueue<org.apache.hadoop.fs.Path> queue,
                                                       long startPosition)

Overrides:

startNewWALReader in class ReplicationSource

locateRecoveredPaths

public void locateRecoveredPaths(PriorityBlockingQueue<org.apache.hadoop.fs.Path> queue)
                          throws IOException

Throws:

IOException

getReplSyncUpPath

private org.apache.hadoop.fs.Path getReplSyncUpPath(org.apache.hadoop.fs.Path path)
                                             throws IOException

Throws:

IOException

tryFinish

public void tryFinish()

getPeerId

public 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