Class: Impala::Protocol::Beeswax::BeeswaxService::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/impala/protocol/beeswax_service.rb

Direct Known Subclasses

ImpalaService::Processor

Instance Method Summary collapse

Instance Method Details

#process_clean(seqid, iprot, oprot) ⇒ Object 



323
324
325
326
327
328
 
# 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) ⇒ Object 



310
311
312
313
314
315
316
317
318
319
320
321
 
# 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) ⇒ Object 



285
286
287
288
289
290
 
# 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) ⇒ Object 



278
279
280
281
282
283
 
# 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) ⇒ Object 



221
222
223
224
225
226
227
228
229
230
 
# 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) ⇒ Object 



232
233
234
235
236
237
238
239
240
241
 
# 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) ⇒ Object 



243
244
245
246
247
248
249
250
251
252
253
254
 
# 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) ⇒ Object 



303
304
305
306
307
308
 
# 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) ⇒ Object 



292
293
294
295
296
297
298
299
300
301
 
# 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) ⇒ Object 



267
268
269
270
271
272
273
274
275
276
 
# 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) ⇒ Object 



256
257
258
259
260
261
262
263
264
265
 
# 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) ⇒ Object 



210
211
212
213
214
215
216
217
218
219
 
# 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