@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) |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getPeerId, isPeerEnabled, isRecovered, isSyncReplication, logPositionAndCleanOldLogs
public RecoveredReplicationSource()
protected RecoveredReplicationSourceShipper createNewShipper(String walGroupId, ReplicationSourceWALReader walReader)
createNewShipper
in class ReplicationSource
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.