public class RecoveredReplicationSourceShipper extends ReplicationSourceShipper
RecoveredReplicationSource
.ReplicationSourceShipper.WorkerState
Modifier and Type | Field and Description |
---|---|
protected RecoveredReplicationSource |
source |
conf, currentPath, entryReader, lastLoggedPosition, maxRetriesMultiplier, queue, sleepForRetries, walGroupId
Constructor and Description |
---|
RecoveredReplicationSourceShipper(Configuration conf,
java.lang.String walGroupId,
java.util.concurrent.PriorityBlockingQueue<Path> queue,
RecoveredReplicationSource source,
ReplicationQueues replicationQueues) |
Modifier and Type | Method and Description |
---|---|
long |
getStartPosition() |
void |
run() |
protected void |
updateLogPosition(long lastReadPosition) |
getCurrentPath, getCurrentPosition, getLogQueue, getWorkerState, isActive, isFinished, setWALReader, setWorkerState, shipEdits, sleepForRetries, startup, stopWorker
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
protected final RecoveredReplicationSource source
public RecoveredReplicationSourceShipper(Configuration conf, java.lang.String walGroupId, java.util.concurrent.PriorityBlockingQueue<Path> queue, RecoveredReplicationSource source, ReplicationQueues replicationQueues)
public void run()
run
in interface java.lang.Runnable
run
in class ReplicationSourceShipper
public long getStartPosition()
getStartPosition
in class ReplicationSourceShipper
protected void updateLogPosition(long lastReadPosition)
updateLogPosition
in class ReplicationSourceShipper