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, line 323 def process_clean(seqid, iprot, oprot) args = read_args(iprot, Clean_args) result = Clean_result.new() @handler.clean(args.log_context) write_result(result, oprot, 'clean', seqid) end
process_close(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 310 def process_close(seqid, iprot, oprot) args = read_args(iprot, Close_args) result = Close_result.new() begin @handler.close(args.handle) rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error result.error = error rescue ::Impala::Protocol::Beeswax::BeeswaxException => error2 result.error2 = error2 end write_result(result, oprot, 'close', seqid) end
process_dump_config(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 285 def process_dump_config(seqid, iprot, oprot) args = read_args(iprot, Dump_config_args) result = Dump_config_result.new() result.success = @handler.dump_config() write_result(result, oprot, 'dump_config', seqid) end
process_echo(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 278 def process_echo(seqid, iprot, oprot) args = read_args(iprot, Echo_args) result = Echo_result.new() result.success = @handler.echo(args.s) write_result(result, oprot, 'echo', seqid) end
process_executeAndWait(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 221 def process_executeAndWait(seqid, iprot, oprot) args = read_args(iprot, ExecuteAndWait_args) result = ExecuteAndWait_result.new() begin result.success = @handler.executeAndWait(args.query, args.clientCtx) rescue ::Impala::Protocol::Beeswax::BeeswaxException => error result.error = error end write_result(result, oprot, 'executeAndWait', seqid) end
process_explain(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 232 def process_explain(seqid, iprot, oprot) args = read_args(iprot, Explain_args) result = Explain_result.new() begin result.success = @handler.explain(args.query) rescue ::Impala::Protocol::Beeswax::BeeswaxException => error result.error = error end write_result(result, oprot, 'explain', seqid) end
process_fetch(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 243 def process_fetch(seqid, iprot, oprot) args = read_args(iprot, Fetch_args) result = Fetch_result.new() begin result.success = @handler.fetch(args.query_id, args.start_over, args.fetch_size) rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error result.error = error rescue ::Impala::Protocol::Beeswax::BeeswaxException => error2 result.error2 = error2 end write_result(result, oprot, 'fetch', seqid) end
process_get_default_configuration(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 303 def process_get_default_configuration(seqid, iprot, oprot) args = read_args(iprot, Get_default_configuration_args) result = Get_default_configuration_result.new() result.success = @handler.get_default_configuration(args.include_hadoop) write_result(result, oprot, 'get_default_configuration', seqid) end
process_get_log(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 292 def process_get_log(seqid, iprot, oprot) args = read_args(iprot, Get_log_args) result = Get_log_result.new() begin result.success = @handler.get_log(args.context) rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error result.error = error end write_result(result, oprot, 'get_log', seqid) end
process_get_results_metadata(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 267 def process_get_results_metadata(seqid, iprot, oprot) args = read_args(iprot, Get_results_metadata_args) result = Get_results_metadata_result.new() begin result.success = @handler.get_results_metadata(args.handle) rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error result.error = error end write_result(result, oprot, 'get_results_metadata', seqid) end
process_get_state(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 256 def process_get_state(seqid, iprot, oprot) args = read_args(iprot, Get_state_args) result = Get_state_result.new() begin result.success = @handler.get_state(args.handle) rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error result.error = error end write_result(result, oprot, 'get_state', seqid) end
process_query(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/beeswax_service.rb, line 210 def process_query(seqid, iprot, oprot) args = read_args(iprot, Query_args) result = Query_result.new() begin result.success = @handler.query(args.query) rescue ::Impala::Protocol::Beeswax::BeeswaxException => error result.error = error end write_result(result, oprot, 'query', seqid) end