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