org.apache.hadoop.hbase.replication.master

Class ReplicationPeerConfigUpgrader

java.lang.Object

org.apache.hadoop.hbase.replication.ReplicationStateZKBase

org.apache.hadoop.hbase.replication.master.ReplicationPeerConfigUpgrader

@InterfaceAudience.Private
 @InterfaceStability.Unstable
public class ReplicationPeerConfigUpgrader
extends ReplicationStateZKBase

This class is used to upgrade TableCFs from HBase 1.0, 1.1, 1.2, 1.3 to HBase 1.4 or 2.x. It will be removed in HBase 3.x. See HBASE-11393

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG

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

abortable, conf, DISABLED_ZNODE_BYTES, ENABLED_ZNODE_BYTES, hfileRefsZNode, ourClusterKey, peerStateNodeName, peersZNode, queuesZNode, replicationZNode, tableCFsNodeName, zookeeper, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_DEFAULT, ZOOKEEPER_ZNODE_REPLICATION_HFILE_REFS_KEY

Constructor Summary

Constructors

Constructor and Description
ReplicationPeerConfigUpgrader(ZKWatcher zookeeper, org.apache.hadoop.conf.Configuration conf, Abortable abortable)

Method Summary

Modifier and Type	Method and Description
void	copyTableCFs()
boolean	copyTableCFs(String peerId)
private ReplicationPeerConfig	getReplicationPeerConig(String peerNode)
static void	main(String[] args)
private static void	printUsageAndExit()
void	upgrade()

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

getListOfReplicatorsZK, getPeerNode, getPeerStateNode, getTableCFsNode, isPeerPath, peerExists, toByteArray

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

Constructor Detail

ReplicationPeerConfigUpgrader

public ReplicationPeerConfigUpgrader(ZKWatcher zookeeper,
                                     org.apache.hadoop.conf.Configuration conf,
                                     Abortable abortable)

Method Detail

upgrade

public void upgrade()
             throws Exception

Throws:

Exception

copyTableCFs

public void copyTableCFs()

copyTableCFs

public boolean copyTableCFs(String peerId)

getReplicationPeerConig

private ReplicationPeerConfig getReplicationPeerConig(String peerNode)
                                               throws org.apache.zookeeper.KeeperException,
                                                      InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

printUsageAndExit

private static void printUsageAndExit()

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception