@InterfaceAudience.Private public class RecoveredReplicationSourceShipper extends ReplicationSourceShipper
RecoveredReplicationSource
.ReplicationSourceShipper.WorkerState
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private static org.slf4j.Logger |
LOG |
private ReplicationQueueStorage |
replicationQueues |
protected RecoveredReplicationSource |
source |
entryReader, logQueue, maxRetriesMultiplier, sleepForRetries, walGroupId
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf,
String walGroupId,
ReplicationSourceLogQueue logQueue,
RecoveredReplicationSource source,
ReplicationQueueStorage queueStorage) |
Modifier and Type | Method and Description |
---|---|
private long |
getRecoveredQueueStartPos() |
long |
getStartPosition() |
protected void |
noMoreData() |
protected void |
postFinish() |
private void |
terminate(String reason,
Exception cause) |
clearWALEntryBatch, getCurrentPath, getCurrentPosition, isActive, isFinished, run, setWALReader, setWorkerState, 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
private static final org.slf4j.Logger LOG
protected final RecoveredReplicationSource source
private final ReplicationQueueStorage replicationQueues
public RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf, String walGroupId, ReplicationSourceLogQueue logQueue, RecoveredReplicationSource source, ReplicationQueueStorage queueStorage)
protected void noMoreData()
noMoreData
in class ReplicationSourceShipper
protected void postFinish()
postFinish
in class ReplicationSourceShipper
public long getStartPosition()
getStartPosition
in class ReplicationSourceShipper
private long getRecoveredQueueStartPos()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.