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