Module: Impala

Defined in:
lib/impala.rb,
lib/impala/cursor.rb,
lib/impala/version.rb,
lib/impala/protocol.rb,
lib/impala/connection.rb,
lib/impala/protocol/data_types.rb,
lib/impala/protocol/exprs_types.rb,
lib/impala/protocol/fb303_types.rb,
lib/impala/protocol/types_types.rb,
lib/impala/protocol/status_types.rb,
lib/impala/protocol/beeswax_types.rb,
lib/impala/protocol/opcodes_types.rb,
lib/impala/protocol/planner_types.rb,
lib/impala/protocol/data_constants.rb,
lib/impala/protocol/frontend_types.rb,
lib/impala/protocol/impala_service.rb,
lib/impala/protocol/beeswax_service.rb,
lib/impala/protocol/exprs_constants.rb,
lib/impala/protocol/fb303_constants.rb,
lib/impala/protocol/types_constants.rb,
lib/impala/protocol/data_sinks_types.rb,
lib/impala/protocol/facebook_service.rb,
lib/impala/protocol/partitions_types.rb,
lib/impala/protocol/plan_nodes_types.rb,
lib/impala/protocol/status_constants.rb,
lib/impala/protocol/beeswax_constants.rb,
lib/impala/protocol/descriptors_types.rb,
lib/impala/protocol/opcodes_constants.rb,
lib/impala/protocol/planner_constants.rb,
lib/impala/protocol/frontend_constants.rb,
lib/impala/protocol/impala_plan_service.rb,
lib/impala/protocol/state_store_service.rb,
lib/impala/protocol/data_sinks_constants.rb,
lib/impala/protocol/hive_metastore_types.rb,
lib/impala/protocol/impala_service_types.rb,
lib/impala/protocol/java_constants_types.rb,
lib/impala/protocol/partitions_constants.rb,
lib/impala/protocol/plan_nodes_constants.rb,
lib/impala/protocol/descriptors_constants.rb,
lib/impala/protocol/runtime_profile_types.rb,
lib/impala/protocol/thrift_hive_metastore.rb,
lib/impala/protocol/statestore_types_types.rb,
lib/impala/protocol/impala_internal_service.rb,
lib/impala/protocol/hive_metastore_constants.rb,
lib/impala/protocol/impala_service_constants.rb,
lib/impala/protocol/java_constants_constants.rb,
lib/impala/protocol/impala_plan_service_types.rb,
lib/impala/protocol/runtime_profile_constants.rb,
lib/impala/protocol/state_store_service_types.rb,
lib/impala/protocol/statestore_types_constants.rb,
lib/impala/protocol/impala_internal_service_types.rb,
lib/impala/protocol/impala_plan_service_constants.rb,
lib/impala/protocol/state_store_service_constants.rb,
lib/impala/protocol/state_store_subscriber_service.rb,
lib/impala/protocol/impala_internal_service_constants.rb,
lib/impala/protocol/state_store_subscriber_service_types.rb,
lib/impala/protocol/state_store_subscriber_service_constants.rb

Defined Under Namespace

Modules: Protocol Classes: Connection, ConnectionError, Cursor, CursorError, InvalidQueryError, ParsingError

Constant Summary collapse

KNOWN_COMMANDS = 
['select', 'show', 'describe', 'use']
DEFAULT_HOST = 
'localhost'
DEFAULT_PORT = 
21000
VERSION = 
"0.1.3"

Class Method Summary collapse

Class Method Details

.connect(host = DEFAULT_HOST, port = DEFAULT_PORT) {|conn| ... } ⇒ Connection

Connect to an Impala server. If a block is given, it will close the connection after calling the block with the collection.

Parameters:

  • host (String) (defaults to: DEFAULT_HOST) —

    the hostname or IP address of the Impala server

  • port (int) (defaults to: DEFAULT_PORT) —

    the port that the Impala server is listening on

Yield Parameters:

  • conn (Connection) —

    the open connection. Will be closed once the block finishes

Returns:

  • (Connection) —

    the open connection, or, if a block is passed, the return value of the block



32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/impala.rb', line 32

def self.connect(host=DEFAULT_HOST, port=DEFAULT_PORT)
  connection = Connection.new(host, port)

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

  ret
end