Package 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

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

Field Summary

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

conf, DEFAULT_WAIT_ON_ENDPOINT_SECONDS, fs, logQueue, manager, queueId, queueSizePerGroup, queueStorage, replicationPeer, server, sourceRunning, startOffsets, WAIT_ON_ENDPOINT_SECONDS, walEntryFilter, workerThreads

Constructor Summary

Constructors

Constructor	Description
RecoveredReplicationSource()

Method Summary

Modifier and Type	Method	Description
protected RecoveredReplicationSourceShipper	createNewShipper(String walGroupId, ReplicationSourceWALReader walReader)
protected void	startShippers()

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

addHFileRefs, createNewShipper, enqueueLog, getCurrentPath, getPeer, getQueueId, getQueues, getReplicationEndpoint, getReplicationQueueStorage, getServer, getServerWALsBelongTo, getSourceManager, getSourceMetrics, getStats, getTotalReplicatedEdits, getWalEntryFilter, getWALFileLengthProvider, getWalGroupStatus, init, isSourceActive, isWorkerRunning, logPeerId, postShipEdits, removeWorker, startShipper, startup, terminate, terminate, terminate, tryThrottle

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

getPeerId, isPeerEnabled, isRecovered, isSyncReplication, logPositionAndCleanOldLogs

Constructor Details

RecoveredReplicationSource

public RecoveredReplicationSource()

Method Details

startShippers

protected void startShippers()

Overrides:

startShippers in class ReplicationSource

createNewShipper

protected RecoveredReplicationSourceShipper createNewShipper(String walGroupId,
 ReplicationSourceWALReader walReader)

Overrides:

createNewShipper in class ReplicationSource