module RBHive

Constants

HIVE_THRIFT_MAPPING
VERSION

Public Class Methods

connect(server, port=10_000) { |connection| ... } click to toggle source
   # File lib/rbhive/connection.rb
10 def connect(server, port=10_000)
11   connection = RBHive::Connection.new(server, port)
12   ret = nil
13   begin
14     connection.open
15     ret = yield(connection)
16   ensure
17     connection.close
18     ret
19   end
20 end
tcli_connect(server, port = 10_000, options={}) { |connection| ... } click to toggle source
   # File lib/rbhive/t_c_l_i_connection.rb
50 def tcli_connect(server, port = 10_000, options={})
51   logger = options.key?(:logger) ? options.delete(:logger) : StdOutLogger.new
52   connection = RBHive::TCLIConnection.new(server, port, options, logger)
53   ret = nil
54   begin
55     connection.open
56     connection.open_session
57     ret = yield(connection)
58 
59   ensure
60     # Try to close the session and our connection if those are still open, ignore io errors
61     begin
62       connection.close_session if connection.session
63       connection.close
64     rescue IOError => e
65       # noop
66     end
67   end
68 
69   ret
70 end

Private Instance Methods

connect(server, port=10_000) { |connection| ... } click to toggle source
   # File lib/rbhive/connection.rb
10 def connect(server, port=10_000)
11   connection = RBHive::Connection.new(server, port)
12   ret = nil
13   begin
14     connection.open
15     ret = yield(connection)
16   ensure
17     connection.close
18     ret
19   end
20 end
tcli_connect(server, port = 10_000, options={}) { |connection| ... } click to toggle source
   # File lib/rbhive/t_c_l_i_connection.rb
50 def tcli_connect(server, port = 10_000, options={})
51   logger = options.key?(:logger) ? options.delete(:logger) : StdOutLogger.new
52   connection = RBHive::TCLIConnection.new(server, port, options, logger)
53   ret = nil
54   begin
55     connection.open
56     connection.open_session
57     ret = yield(connection)
58 
59   ensure
60     # Try to close the session and our connection if those are still open, ignore io errors
61     begin
62       connection.close_session if connection.session
63       connection.close
64     rescue IOError => e
65       # noop
66     end
67   end
68 
69   ret
70 end