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, line 10 def connect(server, port=10_000) connection = RBHive::Connection.new(server, port) ret = nil begin connection.open ret = yield(connection) ensure connection.close ret end end
tcli_connect(server, port = 10_000, options) { |connection| ... }
click to toggle source
# File lib/rbhive/t_c_l_i_connection.rb, line 50 def tcli_connect(server, port = 10_000, options) logger = options.key?(:logger) ? options.delete(:logger) : StdOutLogger.new connection = RBHive::TCLIConnection.new(server, port, options, logger) ret = nil begin connection.open connection.open_session ret = yield(connection) ensure # Try to close the session and our connection if those are still open, ignore io errors begin connection.close_session if connection.session connection.close rescue IOError => e # noop end end ret end
Private Instance Methods
connect(server, port=10_000) { |connection| ... }
click to toggle source
# File lib/rbhive/connection.rb, line 10 def connect(server, port=10_000) connection = RBHive::Connection.new(server, port) ret = nil begin connection.open ret = yield(connection) ensure connection.close ret end end
tcli_connect(server, port = 10_000, options) { |connection| ... }
click to toggle source
# File lib/rbhive/t_c_l_i_connection.rb, line 50 def tcli_connect(server, port = 10_000, options) logger = options.key?(:logger) ? options.delete(:logger) : StdOutLogger.new connection = RBHive::TCLIConnection.new(server, port, options, logger) ret = nil begin connection.open connection.open_session ret = yield(connection) ensure # Try to close the session and our connection if those are still open, ignore io errors begin connection.close_session if connection.session connection.close rescue IOError => e # noop end end ret end