public class ZKDataMigrator
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
ZKDataMigrator.ZKDataMigratorAbortable |
| Modifier and Type | Field and Description |
|---|---|
private static org.apache.commons.logging.Log |
LOG |
| Constructor and Description |
|---|
ZKDataMigrator() |
| Modifier and Type | Method and Description |
|---|---|
private void |
checkAndMigratePeerZnodesToPB(ZooKeeperWatcher zkw,
String znode,
List<String> peers) |
private void |
checkAndMigrateQueuesToPB(ZooKeeperWatcher zkw,
String znode,
String rs) |
private void |
checkAndMigrateReplicationNodesToPB(ZooKeeperWatcher zkw) |
private void |
checkAndMigrateTableStatesToPB(ZooKeeperWatcher zkw) |
static void |
main(String[] args) |
private void |
migrateClusterKeyToPB(ZooKeeperWatcher zkw,
String peerZnode,
byte[] data) |
private void |
migratePeerStateToPB(ZooKeeperWatcher zkw,
byte[] data,
String peerStatePath) |
int |
run(String[] as) |
public int run(String[] as) throws Exception
run in interface org.apache.hadoop.util.ToolExceptionprivate void checkAndMigrateTableStatesToPB(ZooKeeperWatcher zkw) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperExceptionInterruptedExceptionprivate void checkAndMigrateReplicationNodesToPB(ZooKeeperWatcher zkw) throws org.apache.zookeeper.KeeperException, InterruptedException
org.apache.zookeeper.KeeperExceptionInterruptedExceptionprivate void checkAndMigrateQueuesToPB(ZooKeeperWatcher zkw, String znode, String rs) throws org.apache.zookeeper.KeeperException, org.apache.zookeeper.KeeperException.NoNodeException, InterruptedException
org.apache.zookeeper.KeeperExceptionorg.apache.zookeeper.KeeperException.NoNodeExceptionInterruptedExceptionprivate void checkAndMigratePeerZnodesToPB(ZooKeeperWatcher zkw, String znode, List<String> peers) throws org.apache.zookeeper.KeeperException, org.apache.zookeeper.KeeperException.NoNodeException, InterruptedException
org.apache.zookeeper.KeeperExceptionorg.apache.zookeeper.KeeperException.NoNodeExceptionInterruptedExceptionprivate void migrateClusterKeyToPB(ZooKeeperWatcher zkw, String peerZnode, byte[] data) throws org.apache.zookeeper.KeeperException, org.apache.zookeeper.KeeperException.NoNodeException
org.apache.zookeeper.KeeperExceptionorg.apache.zookeeper.KeeperException.NoNodeExceptionprivate void migratePeerStateToPB(ZooKeeperWatcher zkw, byte[] data, String peerStatePath) throws org.apache.zookeeper.KeeperException, org.apache.zookeeper.KeeperException.NoNodeException
org.apache.zookeeper.KeeperExceptionorg.apache.zookeeper.KeeperException.NoNodeExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.