Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-19591 Cleanup the usage of ReplicationAdmin from hbase-shell

This commit is contained in:
Guanghao Zhang 2017-12-22 14:14:10 +08:00
parent 001bce54e7
commit 7501e64426
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
hbase-shell/src/main/ruby/hbase/replication_admin.rb
View File

@ -19,21 +19,19 @@
include Java
java_import org.apache.hadoop.hbase.client.replication.ReplicationAdmin
java_import org.apache.hadoop.hbase.client.replication.ReplicationPeerConfigUtil
java_import org.apache.hadoop.hbase.replication.ReplicationPeerConfig
java_import org.apache.hadoop.hbase.util.Bytes
java_import org.apache.hadoop.hbase.zookeeper.ZKConfig
java_import org.apache.hadoop.hbase.TableName
# Wrapper for org.apache.hadoop.hbase.client.replication.ReplicationAdmin
# Used for replication administrative operations.
module Hbase
class RepAdmin
include HBaseConstants
def initialize(configuration)
@replication_admin = ReplicationAdmin.new(configuration)
@configuration = configuration
@admin = ConnectionFactory.createConnection(configuration).getAdmin
end
@ -272,10 +270,10 @@ module Hbase
end
def set_peer_replicate_all(id, replicate_all)
rpc = @replication_admin.getPeerConfig(id)
rpc = get_peer_config(id)
return if rpc.nil?
rpc.setReplicateAllUserTables(replicate_all)
@replication_admin.updatePeerConfig(id, rpc)
@admin.updateReplicationPeerConfig(id, rpc)
end
# Set exclude namespaces config for the specified peer