org.apache.hadoop.hbase.replication.regionserver

Class RecoveredReplicationSource

java.lang.Object

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

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

All Implemented Interfaces:

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

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, queueId, queueSizePerGroup, queueStorage, replicationPeer, replicationQueueInfo, server, WAIT_ON_ENDPOINT_SECONDS, walEntryFilter, workerThreads

Constructor Summary

Constructors

Constructor and Description
RecoveredReplicationSource()

Method Summary

Modifier and Type	Method and Description
protected RecoveredReplicationSourceShipper	createNewShipper(String walGroupId, PriorityBlockingQueue<org.apache.hadoop.fs.Path> queue)
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, ReplicationQueueStorage queueStorage, ReplicationPeer replicationPeer, Server server, String peerClusterZnode, UUID clusterId, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics) Instantiation method used by region servers
boolean	isRecovered()
void	locateRecoveredPaths(PriorityBlockingQueue<org.apache.hadoop.fs.Path> queue)
(package private) void	tryFinish()

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

addHFileRefs, enqueueLog, getCurrentPath, getQueueId, getQueueStorage, getReplicationEndpoint, getServer, getSourceManager, getSourceMetrics, getStats, getWALFileLengthProvider, getWalGroupStatus, isPeerEnabled, isSourceActive, postShipEdits, sleepForRetries, startup, terminate, terminate, terminate, terminate, tryThrottle, uncaughtException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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,
                 ReplicationQueueStorage queueStorage,
                 ReplicationPeer replicationPeer,
                 Server server,
                 String peerClusterZnode,
                 UUID clusterId,
                 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 id of our replication queue

clusterId - unique UUID for the cluster

metrics - metrics for replication source

Throws:

IOException

createNewShipper

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

Overrides:

createNewShipper 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

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

isRecovered

public boolean isRecovered()

Returns:

whether this is a replication source for recovery.