Class: Impala::Protocol::ImpalaInternalService::Processor

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

Instance Method Summary collapse

Instance Method Details

#process_CancelPlanFragment(seqid, iprot, oprot) ⇒ Object 



95
96
97
98
99
100
 
# File 'lib/impala/protocol/impala_internal_service.rb', line 95

def process_CancelPlanFragment(seqid, iprot, oprot)
  args = read_args(iprot, CancelPlanFragment_args)
  result = CancelPlanFragment_result.new()
  result.success = @handler.CancelPlanFragment(args.params)
  write_result(result, oprot, 'CancelPlanFragment', seqid)
end

#process_ExecPlanFragment(seqid, iprot, oprot) ⇒ Object 



81
82
83
84
85
86
 
# File 'lib/impala/protocol/impala_internal_service.rb', line 81

def process_ExecPlanFragment(seqid, iprot, oprot)
  args = read_args(iprot, ExecPlanFragment_args)
  result = ExecPlanFragment_result.new()
  result.success = @handler.ExecPlanFragment(args.params)
  write_result(result, oprot, 'ExecPlanFragment', seqid)
end

#process_ReportExecStatus(seqid, iprot, oprot) ⇒ Object 



88
89
90
91
92
93
 
# File 'lib/impala/protocol/impala_internal_service.rb', line 88

def process_ReportExecStatus(seqid, iprot, oprot)
  args = read_args(iprot, ReportExecStatus_args)
  result = ReportExecStatus_result.new()
  result.success = @handler.ReportExecStatus(args.params)
  write_result(result, oprot, 'ReportExecStatus', seqid)
end

#process_TransmitData(seqid, iprot, oprot) ⇒ Object 



102
103
104
105
106
107
 
# File 'lib/impala/protocol/impala_internal_service.rb', line 102

def process_TransmitData(seqid, iprot, oprot)
  args = read_args(iprot, TransmitData_args)
  result = TransmitData_result.new()
  result.success = @handler.TransmitData(args.params)
  write_result(result, oprot, 'TransmitData', seqid)
end