public class TableHFileArchiveTracker
extends ZKListener
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 |
Modifier and Type | Method and Description |
---|---|
static TableHFileArchiveTracker |
create(Configuration conf)
Create an archive tracker for the passed in server
|
HFileArchiveTableMonitor |
getMonitor() |
ZKWatcher |
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) |
void |
nodeCreated(java.lang.String path) |
void |
nodeDeleted(java.lang.String path) |
void |
start()
Start monitoring for archive updates
|
void |
stop()
Stop this tracker and the passed zookeeper
|
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)
public void nodeChildrenChanged(java.lang.String path)
public void nodeDeleted(java.lang.String path)
public 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 ZKWatcher getZooKeeperWatcher()
public void stop()