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