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