Package org.apache.hadoop.hbase.replication

Class CopyReplicationPeers

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.hbase.replication.CopyReplicationPeers

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

@LimitedPrivate("Tools")
public class CopyReplicationPeers
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

A tool for copying replication peer data across different replication peer storages.

Notice that we will not delete the replication peer data from the source storage, as this tool can also be used by online migration. See HBASE-27110 for the whole design.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
CopyReplicationPeers(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method	Description
private ReplicationPeerStorage	create(String type, org.apache.hadoop.fs.FileSystem fs, ZKWatcher zk)
private ZKWatcher	createZKWatcher()
static void	main(String[] args)
private void	migrate(ReplicationPeerStorage src, ReplicationPeerStorage dst)
int	run(String[] args)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Details

LOG

private static final org.slf4j.Logger LOG

NAME

public static final String NAME

See Also:

• Constant Field Values

Constructor Details

CopyReplicationPeers

public CopyReplicationPeers(org.apache.hadoop.conf.Configuration conf)

Method Details

create

private ReplicationPeerStorage create(String type,
 org.apache.hadoop.fs.FileSystem fs,
 ZKWatcher zk)

createZKWatcher

private ZKWatcher createZKWatcher()
                           throws IOException

Throws:

IOException

migrate

private void migrate(ReplicationPeerStorage src,
 ReplicationPeerStorage dst)
              throws ReplicationException

Throws:

ReplicationException

run

public int run(String[] args)
        throws Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

Exception

main

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

Throws:

Exception