class Impala::Protocol::Beeswax::BeeswaxService::Processor

Public Instance Methods

process_clean(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
323 def process_clean(seqid, iprot, oprot)
324   args = read_args(iprot, Clean_args)
325   result = Clean_result.new()
326   @handler.clean(args.log_context)
327   write_result(result, oprot, 'clean', seqid)
328 end
process_close(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
310 def process_close(seqid, iprot, oprot)
311   args = read_args(iprot, Close_args)
312   result = Close_result.new()
313   begin
314     @handler.close(args.handle)
315   rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error
316     result.error = error
317   rescue ::Impala::Protocol::Beeswax::BeeswaxException => error2
318     result.error2 = error2
319   end
320   write_result(result, oprot, 'close', seqid)
321 end
process_dump_config(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
285 def process_dump_config(seqid, iprot, oprot)
286   args = read_args(iprot, Dump_config_args)
287   result = Dump_config_result.new()
288   result.success = @handler.dump_config()
289   write_result(result, oprot, 'dump_config', seqid)
290 end
process_echo(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
278 def process_echo(seqid, iprot, oprot)
279   args = read_args(iprot, Echo_args)
280   result = Echo_result.new()
281   result.success = @handler.echo(args.s)
282   write_result(result, oprot, 'echo', seqid)
283 end
process_executeAndWait(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
221 def process_executeAndWait(seqid, iprot, oprot)
222   args = read_args(iprot, ExecuteAndWait_args)
223   result = ExecuteAndWait_result.new()
224   begin
225     result.success = @handler.executeAndWait(args.query, args.clientCtx)
226   rescue ::Impala::Protocol::Beeswax::BeeswaxException => error
227     result.error = error
228   end
229   write_result(result, oprot, 'executeAndWait', seqid)
230 end
process_explain(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
232 def process_explain(seqid, iprot, oprot)
233   args = read_args(iprot, Explain_args)
234   result = Explain_result.new()
235   begin
236     result.success = @handler.explain(args.query)
237   rescue ::Impala::Protocol::Beeswax::BeeswaxException => error
238     result.error = error
239   end
240   write_result(result, oprot, 'explain', seqid)
241 end
process_fetch(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
243 def process_fetch(seqid, iprot, oprot)
244   args = read_args(iprot, Fetch_args)
245   result = Fetch_result.new()
246   begin
247     result.success = @handler.fetch(args.query_id, args.start_over, args.fetch_size)
248   rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error
249     result.error = error
250   rescue ::Impala::Protocol::Beeswax::BeeswaxException => error2
251     result.error2 = error2
252   end
253   write_result(result, oprot, 'fetch', seqid)
254 end
process_get_default_configuration(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
303 def process_get_default_configuration(seqid, iprot, oprot)
304   args = read_args(iprot, Get_default_configuration_args)
305   result = Get_default_configuration_result.new()
306   result.success = @handler.get_default_configuration(args.include_hadoop)
307   write_result(result, oprot, 'get_default_configuration', seqid)
308 end
process_get_log(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
292 def process_get_log(seqid, iprot, oprot)
293   args = read_args(iprot, Get_log_args)
294   result = Get_log_result.new()
295   begin
296     result.success = @handler.get_log(args.context)
297   rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error
298     result.error = error
299   end
300   write_result(result, oprot, 'get_log', seqid)
301 end
process_get_results_metadata(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
267 def process_get_results_metadata(seqid, iprot, oprot)
268   args = read_args(iprot, Get_results_metadata_args)
269   result = Get_results_metadata_result.new()
270   begin
271     result.success = @handler.get_results_metadata(args.handle)
272   rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error
273     result.error = error
274   end
275   write_result(result, oprot, 'get_results_metadata', seqid)
276 end
process_get_state(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
256 def process_get_state(seqid, iprot, oprot)
257   args = read_args(iprot, Get_state_args)
258   result = Get_state_result.new()
259   begin
260     result.success = @handler.get_state(args.handle)
261   rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error
262     result.error = error
263   end
264   write_result(result, oprot, 'get_state', seqid)
265 end
process_query(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/beeswax_service.rb
210 def process_query(seqid, iprot, oprot)
211   args = read_args(iprot, Query_args)
212   result = Query_result.new()
213   begin
214     result.success = @handler.query(args.query)
215   rescue ::Impala::Protocol::Beeswax::BeeswaxException => error
216     result.error = error
217   end
218   write_result(result, oprot, 'query', seqid)
219 end