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