@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, triggerNow
private 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
Exception
protected void chore()
ScheduledChore
chore
in class ScheduledChore
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.