@InterfaceAudience.Private public class ZKReplicationQueueStorageForMigration extends ZKReplicationStorageBase
Modifier and Type | Class and Description |
---|---|
static interface |
ZKReplicationQueueStorageForMigration.MigrationIterator<T> |
static class |
ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId |
static class |
ZKReplicationQueueStorageForMigration.ZkReplicationQueueData |
Modifier and Type | Field and Description |
---|---|
private static ZKReplicationQueueStorageForMigration.MigrationIterator |
EMPTY_ITER |
private String |
hfileRefsZNode
The name of the znode that contains queues of hfile references to be replicated
|
private String |
queuesZNode
The name of the znode that contains all replication queues
|
private String |
regionsZNode |
static String |
ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT |
static String |
ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY |
static String |
ZOOKEEPER_ZNODE_REPLICATION_REGIONS_DEFAULT |
static String |
ZOOKEEPER_ZNODE_REPLICATION_REGIONS_KEY |
conf, REPLICATION_ZNODE, REPLICATION_ZNODE_DEFAULT, replicationZNode, zookeeper
Constructor and Description |
---|
ZKReplicationQueueStorageForMigration(ZKWatcher zookeeper,
org.apache.hadoop.conf.Configuration conf) |
toByteArray
public static final String ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY
public static final String ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT
public static final String ZOOKEEPER_ZNODE_REPLICATION_REGIONS_KEY
public static final String ZOOKEEPER_ZNODE_REPLICATION_REGIONS_DEFAULT
private final String queuesZNode
private final String hfileRefsZNode
private final String regionsZNode
private static final ZKReplicationQueueStorageForMigration.MigrationIterator EMPTY_ITER
public ZKReplicationQueueStorageForMigration(ZKWatcher zookeeper, org.apache.hadoop.conf.Configuration conf)
private String getRsNode(ServerName serverName)
private String getQueueNode(ServerName serverName, String queueId)
private String getFileNode(String queueNode, String fileName)
private String getFileNode(ServerName serverName, String queueId, String fileName)
public ZKReplicationQueueStorageForMigration.MigrationIterator<Pair<ServerName,List<ZKReplicationQueueStorageForMigration.ZkReplicationQueueData>>> listAllQueues() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
public ZKReplicationQueueStorageForMigration.MigrationIterator<List<ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId>> listAllLastPushedSeqIds() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
private String getHFileRefsPeerNode(String peerId)
public ZKReplicationQueueStorageForMigration.MigrationIterator<Pair<String,List<String>>> listAllHFileRefs() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
public boolean hasData() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
public void deleteAllData() throws org.apache.zookeeper.KeeperException
org.apache.zookeeper.KeeperException
String getQueuesZNode()
String getHfileRefsZNode()
String getRegionsZNode()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.