@InterfaceAudience.Private public class ReplicationZKLockCleanerChore extends ScheduledChore
| Modifier and Type | Field and Description |
|---|---|
private static long |
DEFAULT_TTL |
private static org.apache.commons.logging.Log |
LOG |
private ReplicationQueuesZKImpl |
queues |
private ReplicationTracker |
tracker |
private long |
ttl |
static String |
TTL_CONFIG_KEY |
private ZooKeeperWatcher |
zk |
| Constructor and Description |
|---|
ReplicationZKLockCleanerChore(Stoppable stopper,
Abortable abortable,
int period,
ZooKeeperWatcher zk,
org.apache.hadoop.conf.Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
chore()
The task to execute on each scheduled execution of the Chore
|
cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, toString, triggerNowprivate static final org.apache.commons.logging.Log LOG
private ZooKeeperWatcher zk
private ReplicationTracker tracker
private long ttl
private ReplicationQueuesZKImpl queues
private static final long DEFAULT_TTL
public static final String TTL_CONFIG_KEY
public ReplicationZKLockCleanerChore(Stoppable stopper, Abortable abortable, int period, ZooKeeperWatcher zk, org.apache.hadoop.conf.Configuration conf) throws Exception
Exceptionprotected void chore()
ScheduledChorechore in class ScheduledChoreCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.