HBASE-19009 implement modifyTable and enable/disableTableReplication for AsyncAdmin (addendum)
This commit is contained in:
parent
e9612e6c89
commit
41fa71d9cd
|
@ -20,7 +20,7 @@
|
||||||
include Java
|
include Java
|
||||||
|
|
||||||
java_import org.apache.hadoop.hbase.client.replication.ReplicationAdmin
|
java_import org.apache.hadoop.hbase.client.replication.ReplicationAdmin
|
||||||
java_import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper
|
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
|
||||||
|
@ -144,7 +144,7 @@ module Hbase
|
||||||
# Show the current tableCFs config for the specified peer
|
# Show the current tableCFs config for the specified peer
|
||||||
def show_peer_tableCFs(id)
|
def show_peer_tableCFs(id)
|
||||||
rpc = @admin.getReplicationPeerConfig(id)
|
rpc = @admin.getReplicationPeerConfig(id)
|
||||||
ReplicationSerDeHelper.convertToString(rpc.getTableCFsMap)
|
ReplicationPeerConfigUtil.convertToString(rpc.getTableCFsMap)
|
||||||
end
|
end
|
||||||
|
|
||||||
#----------------------------------------------------------------------------------------------
|
#----------------------------------------------------------------------------------------------
|
||||||
|
|
Loading…
Reference in New Issue