module RBHive

Constants

HIVE_THRIFT_MAPPING
VERSION

Public Class Methods

connect(server, port=10_000, logger=StdOutLogger.new) { |connection| ... } click to toggle source
# File lib/rbhive/connection.rb, line 10
def connect(server, port=10_000, logger=StdOutLogger.new)
  connection = RBHive::Connection.new(server, port, logger)
  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, logger=StdOutLogger.new) { |connection| ... } click to toggle source
# File lib/rbhive/connection.rb, line 10
def connect(server, port=10_000, logger=StdOutLogger.new)
  connection = RBHive::Connection.new(server, port, logger)
  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