@InterfaceAudience.Private public class TableHFileArchiveTracker extends ZooKeeperListener
start()
needs to be called to start monitoring for tables to
archive.
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
HFILE_ARCHIVE_ZNODE_PARENT |
watcher
Modifier and Type | Method and Description |
---|---|
static TableHFileArchiveTracker |
create(Configuration conf)
Create an archive tracker for the passed in server
|
HFileArchiveTableMonitor |
getMonitor() |
ZooKeeperWatcher |
getZooKeeperWatcher() |
boolean |
keepHFiles(java.lang.String tableName)
Determine if the given table should or should not allow its hfiles to be deleted
|
void |
nodeChildrenChanged(java.lang.String path)
Called when an existing node has a child node added or removed.
|
void |
nodeCreated(java.lang.String path)
Called when a new node has been created.
|
void |
nodeDeleted(java.lang.String path)
Called when a node has been deleted
|
void |
start()
Start monitoring for archive updates
|
void |
stop()
Stop this tracker and the passed zookeeper
|
getWatcher, nodeDataChanged
public static final java.lang.String HFILE_ARCHIVE_ZNODE_PARENT
public void start() throws KeeperException
KeeperException
- on failure to find/create nodespublic void nodeCreated(java.lang.String path)
ZooKeeperListener
nodeCreated
in class ZooKeeperListener
path
- full path of the new nodepublic void nodeChildrenChanged(java.lang.String path)
ZooKeeperListener
nodeChildrenChanged
in class ZooKeeperListener
path
- full path of the node whose children have changedpublic void nodeDeleted(java.lang.String path)
ZooKeeperListener
nodeDeleted
in class ZooKeeperListener
path
- full path of the deleted nodepublic boolean keepHFiles(java.lang.String tableName)
tableName
- name of the table to checkpublic final HFileArchiveTableMonitor getMonitor()
public static TableHFileArchiveTracker create(Configuration conf) throws ZooKeeperConnectionException, java.io.IOException
conf
- to read for zookeeper connection informationjava.io.IOException
- If a unexpected exception occursZooKeeperConnectionException
- if we can't reach zookeeperpublic ZooKeeperWatcher getZooKeeperWatcher()
public void stop()