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.

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 and Description
RecoveredReplicationSource()

Method Summary

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

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

addHFileRefs, enqueueLog, getCurrentPath, getPeer, getQueueId, getQueues, getReplicationEndpoint, getReplicationQueueStorage, getServer, getServerWALsBelongTo, getSourceManager, getSourceMetrics, getStats, getTotalReplicatedEdits, getWalEntryFilter, getWALFileLengthProvider, getWalGroupStatus, init, isSourceActive, isWorkerRunning, logPeerId, postShipEdits, removeWorker, sleepForRetries, 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 Detail

RecoveredReplicationSource

public RecoveredReplicationSource()

Method Detail

createNewShipper

protected RecoveredReplicationSourceShipper createNewShipper(String walGroupId,
                                                             ReplicationSourceWALReader walReader)

Overrides:

createNewShipper in class ReplicationSource