HBASE-8988 Reuse the thread pool in the shell to not run out of threads
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1504637 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
521f17f275
commit
018b22366d
|
@ -25,6 +25,8 @@ module Hbase
|
|||
class Table
|
||||
include HBaseConstants
|
||||
|
||||
@@thread_pool = nil
|
||||
|
||||
# Add the command 'name' to table s.t. the shell command also called via 'name'
|
||||
# and has an internal method also called 'name'.
|
||||
#
|
||||
|
@ -110,7 +112,12 @@ EOF
|
|||
attr_reader :name
|
||||
|
||||
def initialize(configuration, table_name, shell)
|
||||
@table = org.apache.hadoop.hbase.client.HTable.new(configuration, table_name)
|
||||
if @@thread_pool then
|
||||
@table = org.apache.hadoop.hbase.client.HTable.new(configuration, table_name.to_java_bytes, @@thread_pool)
|
||||
else
|
||||
@table = org.apache.hadoop.hbase.client.HTable.new(configuration, table_name)
|
||||
@@thread_pool = @table.getPool()
|
||||
end
|
||||
@name = table_name
|
||||
@shell = shell
|
||||
@converters = Hash.new()
|
||||
|
|
Loading…
Reference in New Issue