class Impala::Protocol::ImpalaService::Processor
Public Instance Methods
process_Cancel(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb 133 def process_Cancel(seqid, iprot, oprot) 134 args = read_args(iprot, Cancel_args) 135 result = Cancel_result.new() 136 begin 137 result.success = @handler.Cancel(args.query_id) 138 rescue ::Impala::Protocol::Beeswax::BeeswaxException => error 139 result.error = error 140 end 141 write_result(result, oprot, 'Cancel', seqid) 142 end
process_CloseInsert(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb 169 def process_CloseInsert(seqid, iprot, oprot) 170 args = read_args(iprot, CloseInsert_args) 171 result = CloseInsert_result.new() 172 begin 173 result.success = @handler.CloseInsert(args.handle) 174 rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error 175 result.error = error 176 rescue ::Impala::Protocol::Beeswax::BeeswaxException => error2 177 result.error2 = error2 178 end 179 write_result(result, oprot, 'CloseInsert', seqid) 180 end
process_GetExecSummary(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb 189 def process_GetExecSummary(seqid, iprot, oprot) 190 args = read_args(iprot, GetExecSummary_args) 191 result = GetExecSummary_result.new() 192 begin 193 result.success = @handler.GetExecSummary(args.handle) 194 rescue ::Impala::Protocol::Beeswax::QueryNotFoundException => error 195 result.error = error 196 rescue ::Impala::Protocol::Beeswax::BeeswaxException => error2 197 result.error2 = error2 198 end 199 write_result(result, oprot, 'GetExecSummary', seqid) 200 end
process_GetRuntimeProfile(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb 158 def process_GetRuntimeProfile(seqid, iprot, oprot) 159 args = read_args(iprot, GetRuntimeProfile_args) 160 result = GetRuntimeProfile_result.new() 161 begin 162 result.success = @handler.GetRuntimeProfile(args.query_id) 163 rescue ::Impala::Protocol::Beeswax::BeeswaxException => error 164 result.error = error 165 end 166 write_result(result, oprot, 'GetRuntimeProfile', seqid) 167 end
process_PingImpalaService(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb 182 def process_PingImpalaService(seqid, iprot, oprot) 183 args = read_args(iprot, PingImpalaService_args) 184 result = PingImpalaService_result.new() 185 result.success = @handler.PingImpalaService() 186 write_result(result, oprot, 'PingImpalaService', seqid) 187 end
process_ResetCatalog(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb 144 def process_ResetCatalog(seqid, iprot, oprot) 145 args = read_args(iprot, ResetCatalog_args) 146 result = ResetCatalog_result.new() 147 result.success = @handler.ResetCatalog() 148 write_result(result, oprot, 'ResetCatalog', seqid) 149 end
process_ResetTable(seqid, iprot, oprot)
click to toggle source
# File lib/impala/protocol/impala_service.rb 151 def process_ResetTable(seqid, iprot, oprot) 152 args = read_args(iprot, ResetTable_args) 153 result = ResetTable_result.new() 154 result.success = @handler.ResetTable(args.request) 155 write_result(result, oprot, 'ResetTable', seqid) 156 end