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