@InterfaceAudience.Private class CatalogReplicationSource extends ReplicationSource
ReplicationSourceFactory
.conf, DEFAULT_WAIT_ON_ENDPOINT_SECONDS, fs, logQueue, manager, queueId, queueSizePerGroup, queueStorage, replicationPeer, replicationQueueInfo, server, sourceRunning, WAIT_ON_ENDPOINT_SECONDS, walEntryFilter, workerThreads
Constructor and Description |
---|
CatalogReplicationSource() |
Modifier and Type | Method and Description |
---|---|
void |
logPositionAndCleanOldLogs(WALEntryBatch entryBatch)
Log the current position to storage.
|
addHFileRefs, createNewShipper, enqueueLog, getCurrentPath, getPeerId, getQueueId, getQueues, getReplicationEndpoint, getReplicationQueueInfo, getReplicationQueueStorage, getServer, getServerWALsBelongTo, getSourceManager, getSourceMetrics, getStats, getWalEntryFilter, getWALFileLengthProvider, getWalGroupStatus, init, isPeerEnabled, isSourceActive, isWorkerRunning, logPeerId, postShipEdits, sleepForRetries, startup, terminate, terminate, terminate, terminate, tryThrottle, uncaughtException
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isRecovered
CatalogReplicationSource()
public void logPositionAndCleanOldLogs(WALEntryBatch entryBatch)
ReplicationSourceInterface
ReplicationSourceManager.logPositionAndCleanOldLogs(ReplicationSourceInterface, WALEntryBatch)
whem implementation does not need to persist state to backing storage.entryBatch
- the wal entry batch we just shippedCopyright © 2007–2020 The Apache Software Foundation. All rights reserved.