class Hive::Thrift::ThriftHive::Processor
Public Instance Methods
process_execute(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb, line 149 def process_execute(seqid, iprot, oprot) args = read_args(iprot, Execute_args) result = Execute_result.new() begin @handler.execute(args.query) rescue ::Hive::Thrift::HiveServerException => ex result.ex = ex end write_result(result, oprot, 'execute', seqid) end
process_fetchAll(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb, line 182 def process_fetchAll(seqid, iprot, oprot) args = read_args(iprot, FetchAll_args) result = FetchAll_result.new() begin result.success = @handler.fetchAll() rescue ::Hive::Thrift::HiveServerException => ex result.ex = ex end write_result(result, oprot, 'fetchAll', seqid) end
process_fetchN(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb, line 171 def process_fetchN(seqid, iprot, oprot) args = read_args(iprot, FetchN_args) result = FetchN_result.new() begin result.success = @handler.fetchN(args.numRows) rescue ::Hive::Thrift::HiveServerException => ex result.ex = ex end write_result(result, oprot, 'fetchN', seqid) end
process_fetchOne(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb, line 160 def process_fetchOne(seqid, iprot, oprot) args = read_args(iprot, FetchOne_args) result = FetchOne_result.new() begin result.success = @handler.fetchOne() rescue ::Hive::Thrift::HiveServerException => ex result.ex = ex end write_result(result, oprot, 'fetchOne', seqid) end
process_getClusterStatus(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb, line 215 def process_getClusterStatus(seqid, iprot, oprot) args = read_args(iprot, GetClusterStatus_args) result = GetClusterStatus_result.new() begin result.success = @handler.getClusterStatus() rescue ::Hive::Thrift::HiveServerException => ex result.ex = ex end write_result(result, oprot, 'getClusterStatus', seqid) end
process_getQueryPlan(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb, line 226 def process_getQueryPlan(seqid, iprot, oprot) args = read_args(iprot, GetQueryPlan_args) result = GetQueryPlan_result.new() begin result.success = @handler.getQueryPlan() rescue ::Hive::Thrift::HiveServerException => ex result.ex = ex end write_result(result, oprot, 'getQueryPlan', seqid) end
process_getSchema(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb, line 193 def process_getSchema(seqid, iprot, oprot) args = read_args(iprot, GetSchema_args) result = GetSchema_result.new() begin result.success = @handler.getSchema() rescue ::Hive::Thrift::HiveServerException => ex result.ex = ex end write_result(result, oprot, 'getSchema', seqid) end
process_getThriftSchema(seqid, iprot, oprot)
click to toggle source
# File lib/thrift/thrift_hive.rb, line 204 def process_getThriftSchema(seqid, iprot, oprot) args = read_args(iprot, GetThriftSchema_args) result = GetThriftSchema_result.new() begin result.success = @handler.getThriftSchema() rescue ::Hive::Thrift::HiveServerException => ex result.ex = ex end write_result(result, oprot, 'getThriftSchema', seqid) end