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