HBase Cluster Replication

Deploy HBase replication to point slave cluster.

module.exports =  header: 'HBase Client Replication', handler: ({options}) ->

Wait

Wait for the Master to be started.

  @call 'ryba/hbase/master/wait', once: true, options.wait_hbase_master

Add Peer

Run the add_peer command to register each replicated cluster.

  for k, cluster of options.replicated_clusters
    peer_key = parseInt(k) + 1
    peer_value = "#{cluster.zookeeper_quorum}:#{cluster.zookeeper_port}:#{cluster.zookeeper_node}"
    if cluster.zookeeper_node != options.hbase_site['zookeeper.znode.parent']
      msg_err = "Slave Cluster must have same zookeeper hbase node: #{cluster.zookeeper_node} instead of #{options.hbase_site['zookeeper.znode.parent']}"
      throw new Error msg_err
    else
      @system.execute
        cmd: mkcmd.hbase @, """
        hbase shell -n 2>/dev/null <<-CMD
          add_peer '#{peer_key}', '#{peer_value}'
        CMD
        """
        unless_exec: mkcmd.hbase @, "hbase shell -n 2>/dev/null <<< \"list_peers\" | grep '#{peer_key} #{peer_value} ENABLED'"

Dependencies

mkcmd = require '../../lib/mkcmd'