@InterfaceAudience.Private public class ZKTableArchiveClient extends Configured
Constructor and Description |
---|
ZKTableArchiveClient(Configuration conf,
ClusterConnection connection) |
Modifier and Type | Method and Description |
---|---|
void |
disableHFileBackup()
Disable hfile backups for all tables.
|
void |
disableHFileBackup(byte[] table)
Disable hfile backups for the given table.
|
void |
disableHFileBackup(java.lang.String table)
Disable hfile backups for the given table.
|
void |
enableHFileBackupAsync(byte[] table)
Turn on backups for all HFiles for the given table.
|
static java.lang.String |
getArchiveZNode(Configuration conf,
ZooKeeperWatcher zooKeeper) |
boolean |
getArchivingEnabled(byte[] table)
Determine if archiving is enabled (but not necessarily fully propagated) for a table
|
boolean |
getArchivingEnabled(java.lang.String table)
Determine if archiving is enabled (but not necessarily fully propagated) for a table
|
public ZKTableArchiveClient(Configuration conf, ClusterConnection connection)
public void enableHFileBackupAsync(byte[] table) throws java.io.IOException, KeeperException
All deleted hfiles are moved to the archive directory under the table directory, rather than being deleted.
If backups are already enabled for this table, does nothing.
If the table does not exist, the archiving the table's hfiles is still enabled as a future table with that name may be created shortly.
table
- name of the table to start backing upjava.io.IOException
- if an unexpected exception occursKeeperException
- if zookeeper can't be reachedpublic void disableHFileBackup(java.lang.String table) throws java.io.IOException, KeeperException
Previously backed up files are still retained (if present).
Asynchronous operation - some extra HFiles may be retained, in the archive directory after disable is called, dependent on the latency in zookeeper to the servers.
table
- name of the table stop backing upjava.io.IOException
- if an unexpected exception occursKeeperException
- if zookeeper can't be reachedpublic void disableHFileBackup(byte[] table) throws java.io.IOException, KeeperException
Previously backed up files are still retained (if present).
Asynchronous operation - some extra HFiles may be retained, in the archive directory after disable is called, dependent on the latency in zookeeper to the servers.
table
- name of the table stop backing upjava.io.IOException
- if an unexpected exception occursKeeperException
- if zookeeper can't be reachedpublic void disableHFileBackup() throws java.io.IOException, KeeperException
Previously backed up files are still retained (if present).
Asynchronous operation - some extra HFiles may be retained, in the archive directory after disable is called, dependent on the latency in zookeeper to the servers.
java.io.IOException
- if an unexpected exception occursKeeperException
- if zookeeper can't be reachedpublic boolean getArchivingEnabled(byte[] table) throws java.io.IOException, KeeperException
table
- name of the table to checkjava.io.IOException
- if a connection to ZooKeeper cannot be establishedKeeperException
public boolean getArchivingEnabled(java.lang.String table) throws java.io.IOException, KeeperException
table
- name of the table to checkjava.io.IOException
- if an unexpected network issue occursKeeperException
- if zookeeper can't be reachedpublic static java.lang.String getArchiveZNode(Configuration conf, ZooKeeperWatcher zooKeeper)
conf
- conf to read for the base archive nodezooKeeper
- zookeeper to used for building the full path