class Impala::Protocol::TCLIService::Processor

Public Instance Methods

process_CancelDelegationToken(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
440 def process_CancelDelegationToken(seqid, iprot, oprot)
441   args = read_args(iprot, CancelDelegationToken_args)
442   result = CancelDelegationToken_result.new()
443   result.success = @handler.CancelDelegationToken(args.req)
444   write_result(result, oprot, 'CancelDelegationToken', seqid)
445 end
process_CancelOperation(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
405 def process_CancelOperation(seqid, iprot, oprot)
406   args = read_args(iprot, CancelOperation_args)
407   result = CancelOperation_result.new()
408   result.success = @handler.CancelOperation(args.req)
409   write_result(result, oprot, 'CancelOperation', seqid)
410 end
process_CloseOperation(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
412 def process_CloseOperation(seqid, iprot, oprot)
413   args = read_args(iprot, CloseOperation_args)
414   result = CloseOperation_result.new()
415   result.success = @handler.CloseOperation(args.req)
416   write_result(result, oprot, 'CloseOperation', seqid)
417 end
process_CloseSession(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
328 def process_CloseSession(seqid, iprot, oprot)
329   args = read_args(iprot, CloseSession_args)
330   result = CloseSession_result.new()
331   result.success = @handler.CloseSession(args.req)
332   write_result(result, oprot, 'CloseSession', seqid)
333 end
process_ExecuteStatement(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
342 def process_ExecuteStatement(seqid, iprot, oprot)
343   args = read_args(iprot, ExecuteStatement_args)
344   result = ExecuteStatement_result.new()
345   result.success = @handler.ExecuteStatement(args.req)
346   write_result(result, oprot, 'ExecuteStatement', seqid)
347 end
process_FetchResults(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
426 def process_FetchResults(seqid, iprot, oprot)
427   args = read_args(iprot, FetchResults_args)
428   result = FetchResults_result.new()
429   result.success = @handler.FetchResults(args.req)
430   write_result(result, oprot, 'FetchResults', seqid)
431 end
process_GetCatalogs(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
356 def process_GetCatalogs(seqid, iprot, oprot)
357   args = read_args(iprot, GetCatalogs_args)
358   result = GetCatalogs_result.new()
359   result.success = @handler.GetCatalogs(args.req)
360   write_result(result, oprot, 'GetCatalogs', seqid)
361 end
process_GetColumns(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
384 def process_GetColumns(seqid, iprot, oprot)
385   args = read_args(iprot, GetColumns_args)
386   result = GetColumns_result.new()
387   result.success = @handler.GetColumns(args.req)
388   write_result(result, oprot, 'GetColumns', seqid)
389 end
process_GetDelegationToken(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
433 def process_GetDelegationToken(seqid, iprot, oprot)
434   args = read_args(iprot, GetDelegationToken_args)
435   result = GetDelegationToken_result.new()
436   result.success = @handler.GetDelegationToken(args.req)
437   write_result(result, oprot, 'GetDelegationToken', seqid)
438 end
process_GetFunctions(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
391 def process_GetFunctions(seqid, iprot, oprot)
392   args = read_args(iprot, GetFunctions_args)
393   result = GetFunctions_result.new()
394   result.success = @handler.GetFunctions(args.req)
395   write_result(result, oprot, 'GetFunctions', seqid)
396 end
process_GetInfo(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
335 def process_GetInfo(seqid, iprot, oprot)
336   args = read_args(iprot, GetInfo_args)
337   result = GetInfo_result.new()
338   result.success = @handler.GetInfo(args.req)
339   write_result(result, oprot, 'GetInfo', seqid)
340 end
process_GetLog(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
454 def process_GetLog(seqid, iprot, oprot)
455   args = read_args(iprot, GetLog_args)
456   result = GetLog_result.new()
457   result.success = @handler.GetLog(args.req)
458   write_result(result, oprot, 'GetLog', seqid)
459 end
process_GetOperationStatus(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
398 def process_GetOperationStatus(seqid, iprot, oprot)
399   args = read_args(iprot, GetOperationStatus_args)
400   result = GetOperationStatus_result.new()
401   result.success = @handler.GetOperationStatus(args.req)
402   write_result(result, oprot, 'GetOperationStatus', seqid)
403 end
process_GetResultSetMetadata(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
419 def process_GetResultSetMetadata(seqid, iprot, oprot)
420   args = read_args(iprot, GetResultSetMetadata_args)
421   result = GetResultSetMetadata_result.new()
422   result.success = @handler.GetResultSetMetadata(args.req)
423   write_result(result, oprot, 'GetResultSetMetadata', seqid)
424 end
process_GetSchemas(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
363 def process_GetSchemas(seqid, iprot, oprot)
364   args = read_args(iprot, GetSchemas_args)
365   result = GetSchemas_result.new()
366   result.success = @handler.GetSchemas(args.req)
367   write_result(result, oprot, 'GetSchemas', seqid)
368 end
process_GetTableTypes(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
377 def process_GetTableTypes(seqid, iprot, oprot)
378   args = read_args(iprot, GetTableTypes_args)
379   result = GetTableTypes_result.new()
380   result.success = @handler.GetTableTypes(args.req)
381   write_result(result, oprot, 'GetTableTypes', seqid)
382 end
process_GetTables(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
370 def process_GetTables(seqid, iprot, oprot)
371   args = read_args(iprot, GetTables_args)
372   result = GetTables_result.new()
373   result.success = @handler.GetTables(args.req)
374   write_result(result, oprot, 'GetTables', seqid)
375 end
process_GetTypeInfo(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
349 def process_GetTypeInfo(seqid, iprot, oprot)
350   args = read_args(iprot, GetTypeInfo_args)
351   result = GetTypeInfo_result.new()
352   result.success = @handler.GetTypeInfo(args.req)
353   write_result(result, oprot, 'GetTypeInfo', seqid)
354 end
process_OpenSession(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
321 def process_OpenSession(seqid, iprot, oprot)
322   args = read_args(iprot, OpenSession_args)
323   result = OpenSession_result.new()
324   result.success = @handler.OpenSession(args.req)
325   write_result(result, oprot, 'OpenSession', seqid)
326 end
process_RenewDelegationToken(seqid, iprot, oprot) click to toggle source
    # File lib/impala/protocol/t_c_l_i_service.rb
447 def process_RenewDelegationToken(seqid, iprot, oprot)
448   args = read_args(iprot, RenewDelegationToken_args)
449   result = RenewDelegationToken_result.new()
450   result.success = @handler.RenewDelegationToken(args.req)
451   write_result(result, oprot, 'RenewDelegationToken', seqid)
452 end