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

HBASE-12595 Use Connection.getTable() in table.rb (Solomon Duskis)

This commit is contained in:
stack 2014-11-29 12:52:44 -08:00
parent b94b0e9ca7
commit 5985b48594
1 changed files with 6 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
hbase-shell/src/main/ruby/hbase/table.rb
View File

@ -112,26 +112,14 @@ EOF
attr_reader :name
def initialize(configuration, table_name, shell)
# Commenting out the HTable.new() calls and uncommenting the @connection approach causes
# Zookeepr exceptions. Interestingly, there were changes in admin.rb to convert
# HBaseAdmin.new() calls to ConnectionFactory.createConnection().getAdmin(). Either change
# of ConnectionFactory.createConnection().getTable() or
# ConnectionFactory.createConnection().getAdmin() by itself doesn't cause the Zookeper
# exception. Somehow the combination of the two causes the issue.
# TODO: Uncomment the createConnection approach after the underlying problem is fixed.
if @@thread_pool then
@table = org.apache.hadoop.hbase.client.HTable.new(configuration, table_name.to_java_bytes,
@@thread_pool)
# @connection = org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(
# configuration, @@thread_pool)
# @table = @connection.getTable(table_name)
@connection = org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(
configuration, @@thread_pool)
@table = @connection.getTable(table_name)
else
# @connection = org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(
# configuration)
# @table = @connection.getTable(table_name)
@table = org.apache.hadoop.hbase.client.HTable.new(configuration, table_name)
@connection = org.apache.hadoop.hbase.client.ConnectionFactory.createConnection(
configuration)
@table = @connection.getTable(table_name)
@@thread_pool = @table.getPool()
end