class Impala::Protocol::ImpalaService::Processor
Public Instance Methods
process_Cancel(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb, line 116 def process_Cancel(seqid, iprot, oprot) args = read_args(iprot, Cancel_args) result = Cancel_result.new() begin result.success = @handler.Cancel(args.query_id) rescue ::Impala::Protocol::Beeswax::BeeswaxException => error result.error = error end write_result(result, oprot, 'Cancel', seqid) end
process_CloseInsert(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb, line 152 def process_CloseInsert(seqid, iprot, oprot) args = read_args(iprot, CloseInsert_args) result = CloseInsert_result.new() begin result.success = @handler.CloseInsert(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, 'CloseInsert', seqid) end
process_GetRuntimeProfile(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb, line 141 def process_GetRuntimeProfile(seqid, iprot, oprot) args = read_args(iprot, GetRuntimeProfile_args) result = GetRuntimeProfile_result.new() begin result.success = @handler.GetRuntimeProfile(args.query_id) rescue ::Impala::Protocol::Beeswax::BeeswaxException => error result.error = error end write_result(result, oprot, 'GetRuntimeProfile', seqid) end
process_PingImpalaService(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb, line 165 def process_PingImpalaService(seqid, iprot, oprot) args = read_args(iprot, PingImpalaService_args) result = PingImpalaService_result.new() result.success = @handler.PingImpalaService() write_result(result, oprot, 'PingImpalaService', seqid) end
process_ResetCatalog(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb, line 127 def process_ResetCatalog(seqid, iprot, oprot) args = read_args(iprot, ResetCatalog_args) result = ResetCatalog_result.new() result.success = @handler.ResetCatalog() write_result(result, oprot, 'ResetCatalog', seqid) end
process_ResetTable(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb, line 134 def process_ResetTable(seqid, iprot, oprot) args = read_args(iprot, ResetTable_args) result = ResetTable_result.new() result.success = @handler.ResetTable(args.request) write_result(result, oprot, 'ResetTable', seqid) end