@InterfaceAudience.Private public class RecoveredReplicationSourceShipper extends ReplicationSourceShipper
RecoveredReplicationSource
.ReplicationSourceShipper.WorkerState
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private Runnable |
tryFinish |
entryReader, walGroupId
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf,
String walGroupId,
RecoveredReplicationSource source,
ReplicationSourceWALReader walReader,
ReplicationQueueStorage queueStorage,
Runnable tryFinish) |
Modifier and Type | Method and Description |
---|---|
protected void |
postFinish() |
clearWALEntryBatch, getCurrentPath, getCurrentPosition, isActive, isFinished, run, setWorkerState, 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
public RecoveredReplicationSourceShipper(org.apache.hadoop.conf.Configuration conf, String walGroupId, RecoveredReplicationSource source, ReplicationSourceWALReader walReader, ReplicationQueueStorage queueStorage, Runnable tryFinish)
protected void postFinish()
postFinish
in class ReplicationSourceShipper
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.