class Impala::Protocol::Beeswax::BeeswaxService::Client
Public Instance Methods
clean(log_context)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 191 def clean(log_context) 192 send_clean(log_context) 193 recv_clean() 194 end
close(handle)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 175 def close(handle) 176 send_close(handle) 177 recv_close() 178 end
dump_config()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 129 def dump_config() 130 send_dump_config() 131 return recv_dump_config() 132 end
echo(s)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 114 def echo(s) 115 send_echo(s) 116 return recv_echo() 117 end
executeAndWait(query, clientCtx)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 33 def executeAndWait(query, clientCtx) 34 send_executeAndWait(query, clientCtx) 35 return recv_executeAndWait() 36 end
explain(query)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 49 def explain(query) 50 send_explain(query) 51 return recv_explain() 52 end
fetch(query_id, start_over, fetch_size)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 65 def fetch(query_id, start_over, fetch_size) 66 send_fetch(query_id, start_over, fetch_size) 67 return recv_fetch() 68 end
get_default_configuration(include_hadoop)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 160 def get_default_configuration(include_hadoop) 161 send_get_default_configuration(include_hadoop) 162 return recv_get_default_configuration() 163 end
get_log(context)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 144 def get_log(context) 145 send_get_log(context) 146 return recv_get_log() 147 end
get_results_metadata(handle)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 98 def get_results_metadata(handle) 99 send_get_results_metadata(handle) 100 return recv_get_results_metadata() 101 end
get_state(handle)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 82 def get_state(handle) 83 send_get_state(handle) 84 return recv_get_state() 85 end
query(query)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 17 def query(query) 18 send_query(query) 19 return recv_query() 20 end
recv_clean()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 200 def recv_clean() 201 result = receive_message(Clean_result) 202 return 203 end
recv_close()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 184 def recv_close() 185 result = receive_message(Close_result) 186 raise result.error unless result.error.nil? 187 raise result.error2 unless result.error2.nil? 188 return 189 end
recv_dump_config()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 138 def recv_dump_config() 139 result = receive_message(Dump_config_result) 140 return result.success unless result.success.nil? 141 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'dump_config failed: unknown result') 142 end
recv_echo()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 123 def recv_echo() 124 result = receive_message(Echo_result) 125 return result.success unless result.success.nil? 126 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'echo failed: unknown result') 127 end
recv_executeAndWait()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 42 def recv_executeAndWait() 43 result = receive_message(ExecuteAndWait_result) 44 return result.success unless result.success.nil? 45 raise result.error unless result.error.nil? 46 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'executeAndWait failed: unknown result') 47 end
recv_explain()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 58 def recv_explain() 59 result = receive_message(Explain_result) 60 return result.success unless result.success.nil? 61 raise result.error unless result.error.nil? 62 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'explain failed: unknown result') 63 end
recv_fetch()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 74 def recv_fetch() 75 result = receive_message(Fetch_result) 76 return result.success unless result.success.nil? 77 raise result.error unless result.error.nil? 78 raise result.error2 unless result.error2.nil? 79 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetch failed: unknown result') 80 end
recv_get_default_configuration()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 169 def recv_get_default_configuration() 170 result = receive_message(Get_default_configuration_result) 171 return result.success unless result.success.nil? 172 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_default_configuration failed: unknown result') 173 end
recv_get_log()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 153 def recv_get_log() 154 result = receive_message(Get_log_result) 155 return result.success unless result.success.nil? 156 raise result.error unless result.error.nil? 157 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_log failed: unknown result') 158 end
recv_get_results_metadata()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 107 def recv_get_results_metadata() 108 result = receive_message(Get_results_metadata_result) 109 return result.success unless result.success.nil? 110 raise result.error unless result.error.nil? 111 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_results_metadata failed: unknown result') 112 end
recv_get_state()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 91 def recv_get_state() 92 result = receive_message(Get_state_result) 93 return result.success unless result.success.nil? 94 raise result.error unless result.error.nil? 95 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_state failed: unknown result') 96 end
recv_query()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 26 def recv_query() 27 result = receive_message(Query_result) 28 return result.success unless result.success.nil? 29 raise result.error unless result.error.nil? 30 raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'query failed: unknown result') 31 end
send_clean(log_context)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 196 def send_clean(log_context) 197 send_message('clean', Clean_args, :log_context => log_context) 198 end
send_close(handle)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 180 def send_close(handle) 181 send_message('close', Close_args, :handle => handle) 182 end
send_dump_config()
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 134 def send_dump_config() 135 send_message('dump_config', Dump_config_args) 136 end
send_echo(s)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 119 def send_echo(s) 120 send_message('echo', Echo_args, :s => s) 121 end
send_executeAndWait(query, clientCtx)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 38 def send_executeAndWait(query, clientCtx) 39 send_message('executeAndWait', ExecuteAndWait_args, :query => query, :clientCtx => clientCtx) 40 end
send_explain(query)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 54 def send_explain(query) 55 send_message('explain', Explain_args, :query => query) 56 end
send_fetch(query_id, start_over, fetch_size)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 70 def send_fetch(query_id, start_over, fetch_size) 71 send_message('fetch', Fetch_args, :query_id => query_id, :start_over => start_over, :fetch_size => fetch_size) 72 end
send_get_default_configuration(include_hadoop)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 165 def send_get_default_configuration(include_hadoop) 166 send_message('get_default_configuration', Get_default_configuration_args, :include_hadoop => include_hadoop) 167 end
send_get_log(context)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 149 def send_get_log(context) 150 send_message('get_log', Get_log_args, :context => context) 151 end
send_get_results_metadata(handle)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 103 def send_get_results_metadata(handle) 104 send_message('get_results_metadata', Get_results_metadata_args, :handle => handle) 105 end
send_get_state(handle)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 87 def send_get_state(handle) 88 send_message('get_state', Get_state_args, :handle => handle) 89 end
send_query(query)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb 22 def send_query(query) 23 send_message('query', Query_args, :query => query) 24 end