Package org.apache.hadoop.hbase.replication

Class ZKReplicationQueueStorageForMigration

java.lang.Object

org.apache.hadoop.hbase.replication.ZKReplicationStorageBase

org.apache.hadoop.hbase.replication.ZKReplicationQueueStorageForMigration

@Private
public class ZKReplicationQueueStorageForMigration
extends ZKReplicationStorageBase

Just retain a small set of the methods for the old zookeeper based replication queue storage, for migrating.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ZKReplicationQueueStorageForMigration.MigrationIterator<T>
static final class	ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId
static final class	ZKReplicationQueueStorageForMigration.ZkReplicationQueueData

Field Summary

Fields

Modifier and Type	Field	Description
private static final ZKReplicationQueueStorageForMigration.MigrationIterator	EMPTY_ITER
private final String	hfileRefsZNode	The name of the znode that contains queues of hfile references to be replicated
private final String	queuesZNode	The name of the znode that contains all replication queues
private final String	regionsZNode
static final String	ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT
static final String	ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY
static final String	ZOOKEEPER_ZNODE_REPLICATION_REGIONS_DEFAULT
static final String	ZOOKEEPER_ZNODE_REPLICATION_REGIONS_KEY

Fields inherited from class org.apache.hadoop.hbase.replication.ZKReplicationStorageBase

conf, REPLICATION_ZNODE, REPLICATION_ZNODE_DEFAULT, replicationZNode, zookeeper

Constructor Summary

Constructors

Constructor	Description
ZKReplicationQueueStorageForMigration(ZKWatcher zookeeper, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
void	deleteAllData()
private String	getFileNode(String queueNode, String fileName)
private String	getFileNode(ServerName serverName, String queueId, String fileName)
private String	getHFileRefsPeerNode(String peerId)
(package private) String	getHfileRefsZNode()
private String	getQueueNode(ServerName serverName, String queueId)
(package private) String	getQueuesZNode()
(package private) String	getRegionsZNode()
private String	getRsNode(ServerName serverName)
boolean	hasData()
ZKReplicationQueueStorageForMigration.MigrationIterator<Pair<String,List<String>>>	listAllHFileRefs()	Pair<PeerId, List<HFileRefs>>
ZKReplicationQueueStorageForMigration.MigrationIterator<List<ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId>>	listAllLastPushedSeqIds()
ZKReplicationQueueStorageForMigration.MigrationIterator<Pair<ServerName,List<ZKReplicationQueueStorageForMigration.ZkReplicationQueueData>>>	listAllQueues()

Methods inherited from class org.apache.hadoop.hbase.replication.ZKReplicationStorageBase

toByteArray

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

public static final String ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

See Also:

• Constant Field Values

ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT

public static final String ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT

See Also:

• Constant Field Values

ZOOKEEPER_ZNODE_REPLICATION_REGIONS_KEY

public static final String ZOOKEEPER_ZNODE_REPLICATION_REGIONS_KEY

See Also:

• Constant Field Values

ZOOKEEPER_ZNODE_REPLICATION_REGIONS_DEFAULT

public static final String ZOOKEEPER_ZNODE_REPLICATION_REGIONS_DEFAULT

See Also:

• Constant Field Values

queuesZNode

private final String queuesZNode

The name of the znode that contains all replication queues

hfileRefsZNode

private final String hfileRefsZNode

The name of the znode that contains queues of hfile references to be replicated

regionsZNode

private final String regionsZNode

EMPTY_ITER

private static final ZKReplicationQueueStorageForMigration.MigrationIterator EMPTY_ITER

Constructor Details

ZKReplicationQueueStorageForMigration

public ZKReplicationQueueStorageForMigration(ZKWatcher zookeeper,
 org.apache.hadoop.conf.Configuration conf)

Method Details

getRsNode

private String getRsNode(ServerName serverName)

getQueueNode

private String getQueueNode(ServerName serverName,
 String queueId)

getFileNode

private String getFileNode(String queueNode,
 String fileName)

getFileNode

private String getFileNode(ServerName serverName,
 String queueId,
 String fileName)

listAllQueues

public ZKReplicationQueueStorageForMigration.MigrationIterator<Pair<ServerName,List<ZKReplicationQueueStorageForMigration.ZkReplicationQueueData>>> listAllQueues()
                                                                                                                                                           throws org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.KeeperException

listAllLastPushedSeqIds

public ZKReplicationQueueStorageForMigration.MigrationIterator<List<ZKReplicationQueueStorageForMigration.ZkLastPushedSeqId>> listAllLastPushedSeqIds()
                                                                                                                                               throws org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.KeeperException

getHFileRefsPeerNode

private String getHFileRefsPeerNode(String peerId)

listAllHFileRefs

public ZKReplicationQueueStorageForMigration.MigrationIterator<Pair<String,List<String>>> listAllHFileRefs()
                                                                                                    throws org.apache.zookeeper.KeeperException

Pair<PeerId, List<HFileRefs>>

Throws:

org.apache.zookeeper.KeeperException

hasData

public boolean hasData()
                throws org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.KeeperException

deleteAllData

public void deleteAllData()
                   throws org.apache.zookeeper.KeeperException

Throws:

org.apache.zookeeper.KeeperException

getQueuesZNode

String getQueuesZNode()

getHfileRefsZNode

String getHfileRefsZNode()

getRegionsZNode

String getRegionsZNode()