Contents

require 'thread'

class HBase
module Admin
private
  def with_admin
    (@admin_mutex ||= Mutex.new).synchronize do
      begin
        admin = HBaseAdmin.new(@config)
        yield admin
      ensure
        admin.close if admin
      end
    end
  end

  def wait_async_admin admin
    while true
      pair  = admin.getAlterStatus(@name.to_java_bytes)
      yet   = pair.getFirst
      total = pair.getSecond

      break if yet == 0
      sleep 1
    end
  end
end#Admin
end#HBase

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
hbase-jruby-0.1.1-java	lib/hbase-jruby/admin.rb