Package org.apache.hadoop.hbase.replication.master

Class ReplicationPeerConfigUpgrader

java.lang.Object

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

@Private
@Unstable
public class ReplicationPeerConfigUpgrader
extends Object

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	Description
private final org.apache.hadoop.conf.Configuration	conf
private static final org.slf4j.Logger	LOG
private final ReplicationPeerStorage	peerStorage
private static final String	TABLE_CFS_ZNODE
private static final String	TABLE_CFS_ZNODE_DEFAULT
private final ZKWatcher	zookeeper

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

TABLE_CFS_ZNODE

private static final String TABLE_CFS_ZNODE

See Also:

• Constant Field Values

TABLE_CFS_ZNODE_DEFAULT

private static final String TABLE_CFS_ZNODE_DEFAULT

See Also:

• Constant Field Values

LOG

private static final org.slf4j.Logger LOG

conf

private final org.apache.hadoop.conf.Configuration conf

zookeeper

private final ZKWatcher zookeeper

peerStorage

private final ReplicationPeerStorage peerStorage

Constructor Details

ReplicationPeerConfigUpgrader

public ReplicationPeerConfigUpgrader(ZKWatcher zookeeper,
 org.apache.hadoop.conf.Configuration conf)
                              throws IOException

Throws:

IOException

Method Details

upgrade

public void upgrade()
             throws Exception

Throws:

Exception

copyTableCFs

public void copyTableCFs()
                  throws ReplicationException

Throws:

ReplicationException

getTableCFsNode

protected String getTableCFsNode(String peerId)

copyTableCFs

public boolean copyTableCFs(String peerId)
                     throws ReplicationException

Throws:

ReplicationException

printUsageAndExit

private static void printUsageAndExit()

main

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

Throws:

Exception