Contents

require "impaler/version"

require "impaler/manager"

module Impaler

  class ImpalerError < StandardError; end
  class ConnectionError < ImpalerError; end
  class QueryError < ImpalerError; end

  class ImpalerDefaultLogger < Logger
    def initialize
      super(STDOUT)
      self.level = Logger::WARN
    end
  end
  DEFAULT_LOGGER = ImpalerDefaultLogger.new()

  # Connect to the servers and optionally execute a block of code
  # with the servers.
  # @param [String] host:port for the impala server or an array of host:port to pick from many
  # @param [String] host:port for the hive thirft server (v1) or an array of host:port to pick from many
  # @yieldparam [Connection] conn the open connection. Will be closed once the block
  #    finishes
  # @return [Connection] the open connection, or, if a block is
  #    passed, the return value of the block
  def self.connect(impala_servers, hivethrift_servers, logger=Impaler::DEFAULT_LOGGER)
    manager = Manager.new(impala_servers, hivethrift_servers, logger=logger)

    if block_given?
      begin
        ret = yield manager
      ensure
        manager.close
      end
    else
      ret = manager
    end

    ret
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
impaler-0.0.1	lib/impaler.rb