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