@InterfaceAudience.Private public class RecoveredReplicationSource extends ReplicationSource
conf, DEFAULT_WAIT_ON_ENDPOINT_SECONDS, fs, logQueue, manager, queueId, queueSizePerGroup, queueStorage, replicationPeer, server, sourceRunning, startOffsets, WAIT_ON_ENDPOINT_SECONDS, walEntryFilter, workerThreads
Constructor and Description |
---|
RecoveredReplicationSource() |
Modifier and Type | Method and Description |
---|---|
protected RecoveredReplicationSourceShipper |
createNewShipper(String walGroupId,
ReplicationSourceWALReader walReader) |
protected void |
startShippers() |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getPeerId, isPeerEnabled, isRecovered, isSyncReplication, logPositionAndCleanOldLogs
public RecoveredReplicationSource()
protected void startShippers()
startShippers
in class ReplicationSource
protected RecoveredReplicationSourceShipper createNewShipper(String walGroupId, ReplicationSourceWALReader walReader)
createNewShipper
in class ReplicationSource
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.