class Hive::Thrift::ThriftHive::Processor

Public Instance Methods

process_execute(seqid, iprot, oprot) click to toggle source
    # File lib/thrift/thrift_hive.rb
149 def process_execute(seqid, iprot, oprot)
150   args = read_args(iprot, Execute_args)
151   result = Execute_result.new()
152   begin
153     @handler.execute(args.query)
154   rescue ::Hive::Thrift::HiveServerException => ex
155     result.ex = ex
156   end
157   write_result(result, oprot, 'execute', seqid)
158 end
process_fetchAll(seqid, iprot, oprot) click to toggle source
    # File lib/thrift/thrift_hive.rb
182 def process_fetchAll(seqid, iprot, oprot)
183   args = read_args(iprot, FetchAll_args)
184   result = FetchAll_result.new()
185   begin
186     result.success = @handler.fetchAll()
187   rescue ::Hive::Thrift::HiveServerException => ex
188     result.ex = ex
189   end
190   write_result(result, oprot, 'fetchAll', seqid)
191 end
process_fetchN(seqid, iprot, oprot) click to toggle source
    # File lib/thrift/thrift_hive.rb
171 def process_fetchN(seqid, iprot, oprot)
172   args = read_args(iprot, FetchN_args)
173   result = FetchN_result.new()
174   begin
175     result.success = @handler.fetchN(args.numRows)
176   rescue ::Hive::Thrift::HiveServerException => ex
177     result.ex = ex
178   end
179   write_result(result, oprot, 'fetchN', seqid)
180 end
process_fetchOne(seqid, iprot, oprot) click to toggle source
    # File lib/thrift/thrift_hive.rb
160 def process_fetchOne(seqid, iprot, oprot)
161   args = read_args(iprot, FetchOne_args)
162   result = FetchOne_result.new()
163   begin
164     result.success = @handler.fetchOne()
165   rescue ::Hive::Thrift::HiveServerException => ex
166     result.ex = ex
167   end
168   write_result(result, oprot, 'fetchOne', seqid)
169 end
process_getClusterStatus(seqid, iprot, oprot) click to toggle source
    # File lib/thrift/thrift_hive.rb
215 def process_getClusterStatus(seqid, iprot, oprot)
216   args = read_args(iprot, GetClusterStatus_args)
217   result = GetClusterStatus_result.new()
218   begin
219     result.success = @handler.getClusterStatus()
220   rescue ::Hive::Thrift::HiveServerException => ex
221     result.ex = ex
222   end
223   write_result(result, oprot, 'getClusterStatus', seqid)
224 end
process_getQueryPlan(seqid, iprot, oprot) click to toggle source
    # File lib/thrift/thrift_hive.rb
226 def process_getQueryPlan(seqid, iprot, oprot)
227   args = read_args(iprot, GetQueryPlan_args)
228   result = GetQueryPlan_result.new()
229   begin
230     result.success = @handler.getQueryPlan()
231   rescue ::Hive::Thrift::HiveServerException => ex
232     result.ex = ex
233   end
234   write_result(result, oprot, 'getQueryPlan', seqid)
235 end
process_getSchema(seqid, iprot, oprot) click to toggle source
    # File lib/thrift/thrift_hive.rb
193 def process_getSchema(seqid, iprot, oprot)
194   args = read_args(iprot, GetSchema_args)
195   result = GetSchema_result.new()
196   begin
197     result.success = @handler.getSchema()
198   rescue ::Hive::Thrift::HiveServerException => ex
199     result.ex = ex
200   end
201   write_result(result, oprot, 'getSchema', seqid)
202 end
process_getThriftSchema(seqid, iprot, oprot) click to toggle source
    # File lib/thrift/thrift_hive.rb
204 def process_getThriftSchema(seqid, iprot, oprot)
205   args = read_args(iprot, GetThriftSchema_args)
206   result = GetThriftSchema_result.new()
207   begin
208     result.success = @handler.getThriftSchema()
209   rescue ::Hive::Thrift::HiveServerException => ex
210     result.ex = ex
211   end
212   write_result(result, oprot, 'getThriftSchema', seqid)
213 end