public class RecoveredReplicationSource extends ReplicationSource
ReplicationSource.LogsComparator
conf, DEFAULT_WAIT_ON_ENDPOINT_SECONDS, fs, manager, peerClusterZnode, queueSizePerGroup, replicationQueueInfo, replicationQueues, server, WAIT_ON_ENDPOINT_SECONDS, walEntryFilter, workerThreads
Constructor and Description |
---|
RecoveredReplicationSource() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getPeerId()
Get the id that the source is replicating to.
|
ServerName |
getServerWALsBelongTo()
The queue of WALs only belong to one region server.
|
void |
init(Configuration conf,
FileSystem fs,
ReplicationSourceManager manager,
ReplicationQueues replicationQueues,
ReplicationPeers replicationPeers,
Server server,
java.lang.String peerClusterZnode,
java.util.UUID clusterId,
ReplicationEndpoint replicationEndpoint,
WALFileLengthProvider walFileLengthProvider,
MetricsSource metrics)
Instantiation method used by region servers
|
void |
locateRecoveredPaths(java.util.concurrent.PriorityBlockingQueue<Path> queue) |
protected ReplicationSourceWALReader |
startNewWALReader(java.lang.String threadName,
java.lang.String walGroupId,
java.util.concurrent.PriorityBlockingQueue<Path> queue,
long startPosition) |
void |
tryFinish() |
protected void |
tryStartNewShipper(java.lang.String walGroupId,
java.util.concurrent.PriorityBlockingQueue<Path> queue) |
addHFileRefs, enqueueLog, getCurrentPath, getPeerClusterZnode, getReplicationEndpoint, getSourceManager, getSourceMetrics, getStats, getUncaughtExceptionHandler, getWALFileLengthProvider, isPeerEnabled, isSourceActive, postShipEdits, run, sleepForRetries, startup, terminate, terminate, terminate, tryThrottle
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public void init(Configuration conf, FileSystem fs, ReplicationSourceManager manager, ReplicationQueues replicationQueues, ReplicationPeers replicationPeers, Server server, java.lang.String peerClusterZnode, java.util.UUID clusterId, ReplicationEndpoint replicationEndpoint, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics) throws java.io.IOException
ReplicationSource
init
in interface ReplicationSourceInterface
init
in class ReplicationSource
conf
- configuration to usefs
- file system to usemanager
- replication manager to ping toserver
- the server for this region serverpeerClusterZnode
- the name of our znodeclusterId
- unique UUID for the clusterreplicationEndpoint
- the replication endpoint implementationmetrics
- metrics for replication sourcejava.io.IOException
protected void tryStartNewShipper(java.lang.String walGroupId, java.util.concurrent.PriorityBlockingQueue<Path> queue)
tryStartNewShipper
in class ReplicationSource
protected ReplicationSourceWALReader startNewWALReader(java.lang.String threadName, java.lang.String walGroupId, java.util.concurrent.PriorityBlockingQueue<Path> queue, long startPosition)
startNewWALReader
in class ReplicationSource
public void locateRecoveredPaths(java.util.concurrent.PriorityBlockingQueue<Path> queue) throws java.io.IOException
java.io.IOException
public void tryFinish()
public java.lang.String getPeerId()
ReplicationSourceInterface
getPeerId
in interface ReplicationSourceInterface
getPeerId
in class ReplicationSource
public ServerName getServerWALsBelongTo()
ReplicationSourceInterface
getServerWALsBelongTo
in interface ReplicationSourceInterface
getServerWALsBelongTo
in class ReplicationSource