class Impala::Protocol::Beeswax::BeeswaxService::Client

Public Instance Methods

clean(log_context) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 191
def clean(log_context)
  send_clean(log_context)
  recv_clean()
end
close(handle) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 175
def close(handle)
  send_close(handle)
  recv_close()
end
dump_config() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 129
def dump_config()
  send_dump_config()
  return recv_dump_config()
end
echo(s) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 114
def echo(s)
  send_echo(s)
  return recv_echo()
end
executeAndWait(query, clientCtx) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 33
def executeAndWait(query, clientCtx)
  send_executeAndWait(query, clientCtx)
  return recv_executeAndWait()
end
explain(query) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 49
def explain(query)
  send_explain(query)
  return recv_explain()
end
fetch(query_id, start_over, fetch_size) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 65
def fetch(query_id, start_over, fetch_size)
  send_fetch(query_id, start_over, fetch_size)
  return recv_fetch()
end
get_default_configuration(include_hadoop) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 160
def get_default_configuration(include_hadoop)
  send_get_default_configuration(include_hadoop)
  return recv_get_default_configuration()
end
get_log(context) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 144
def get_log(context)
  send_get_log(context)
  return recv_get_log()
end
get_results_metadata(handle) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 98
def get_results_metadata(handle)
  send_get_results_metadata(handle)
  return recv_get_results_metadata()
end
get_state(handle) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 82
def get_state(handle)
  send_get_state(handle)
  return recv_get_state()
end
query(query) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 17
def query(query)
  send_query(query)
  return recv_query()
end
recv_clean() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 200
def recv_clean()
  result = receive_message(Clean_result)
  return
end
recv_close() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 184
def recv_close()
  result = receive_message(Close_result)
  raise result.error unless result.error.nil?
  raise result.error2 unless result.error2.nil?
  return
end
recv_dump_config() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 138
def recv_dump_config()
  result = receive_message(Dump_config_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'dump_config failed: unknown result')
end
recv_echo() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 123
def recv_echo()
  result = receive_message(Echo_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'echo failed: unknown result')
end
recv_executeAndWait() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 42
def recv_executeAndWait()
  result = receive_message(ExecuteAndWait_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'executeAndWait failed: unknown result')
end
recv_explain() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 58
def recv_explain()
  result = receive_message(Explain_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'explain failed: unknown result')
end
recv_fetch() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 74
def recv_fetch()
  result = receive_message(Fetch_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise result.error2 unless result.error2.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetch failed: unknown result')
end
recv_get_default_configuration() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 169
def recv_get_default_configuration()
  result = receive_message(Get_default_configuration_result)
  return result.success unless result.success.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_default_configuration failed: unknown result')
end
recv_get_log() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 153
def recv_get_log()
  result = receive_message(Get_log_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_log failed: unknown result')
end
recv_get_results_metadata() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 107
def recv_get_results_metadata()
  result = receive_message(Get_results_metadata_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_results_metadata failed: unknown result')
end
recv_get_state() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 91
def recv_get_state()
  result = receive_message(Get_state_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_state failed: unknown result')
end
recv_query() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 26
def recv_query()
  result = receive_message(Query_result)
  return result.success unless result.success.nil?
  raise result.error unless result.error.nil?
  raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'query failed: unknown result')
end
send_clean(log_context) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 196
def send_clean(log_context)
  send_message('clean', Clean_args, :log_context => log_context)
end
send_close(handle) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 180
def send_close(handle)
  send_message('close', Close_args, :handle => handle)
end
send_dump_config() click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 134
def send_dump_config()
  send_message('dump_config', Dump_config_args)
end
send_echo(s) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 119
def send_echo(s)
  send_message('echo', Echo_args, :s => s)
end
send_executeAndWait(query, clientCtx) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 38
def send_executeAndWait(query, clientCtx)
  send_message('executeAndWait', ExecuteAndWait_args, :query => query, :clientCtx => clientCtx)
end
send_explain(query) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 54
def send_explain(query)
  send_message('explain', Explain_args, :query => query)
end
send_fetch(query_id, start_over, fetch_size) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 70
def send_fetch(query_id, start_over, fetch_size)
  send_message('fetch', Fetch_args, :query_id => query_id, :start_over => start_over, :fetch_size => fetch_size)
end
send_get_default_configuration(include_hadoop) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 165
def send_get_default_configuration(include_hadoop)
  send_message('get_default_configuration', Get_default_configuration_args, :include_hadoop => include_hadoop)
end
send_get_log(context) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 149
def send_get_log(context)
  send_message('get_log', Get_log_args, :context => context)
end
send_get_results_metadata(handle) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 103
def send_get_results_metadata(handle)
  send_message('get_results_metadata', Get_results_metadata_args, :handle => handle)
end
send_get_state(handle) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 87
def send_get_state(handle)
  send_message('get_state', Get_state_args, :handle => handle)
end
send_query(query) click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 22
def send_query(query)
  send_message('query', Query_args, :query => query)
end