lib/thrift/thrift_hive.rb
#
# Autogenerated by Thrift Compiler (0.9.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
require 'thrift'
require_relative 'thrift_hive_metastore'
require_relative 'hive_service_types'
module Hive
module Thrift
module ThriftHive
class Client < ::ThriftHiveMetastore::Client
include ::Thrift::Client
def execute(query)
send_execute(query)
recv_execute()
end
def send_execute(query)
send_message('execute', Execute_args, :query => query)
end
def recv_execute()
result = receive_message(Execute_result)
raise result.ex unless result.ex.nil?
return
end
def fetchOne()
send_fetchOne()
return recv_fetchOne()
end
def send_fetchOne()
send_message('fetchOne', FetchOne_args)
end
def recv_fetchOne()
result = receive_message(FetchOne_result)
return result.success unless result.success.nil?
raise result.ex unless result.ex.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetchOne failed: unknown result')
end
def fetchN(numRows)
send_fetchN(numRows)
return recv_fetchN()
end
def send_fetchN(numRows)
send_message('fetchN', FetchN_args, :numRows => numRows)
end
def recv_fetchN()
result = receive_message(FetchN_result)
return result.success unless result.success.nil?
raise result.ex unless result.ex.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetchN failed: unknown result')
end
def fetchAll()
send_fetchAll()
return recv_fetchAll()
end
def send_fetchAll()
send_message('fetchAll', FetchAll_args)
end
def recv_fetchAll()
result = receive_message(FetchAll_result)
return result.success unless result.success.nil?
raise result.ex unless result.ex.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'fetchAll failed: unknown result')
end
def getSchema()
send_getSchema()
return recv_getSchema()
end
def send_getSchema()
send_message('getSchema', GetSchema_args)
end
def recv_getSchema()
result = receive_message(GetSchema_result)
return result.success unless result.success.nil?
raise result.ex unless result.ex.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getSchema failed: unknown result')
end
def getThriftSchema()
send_getThriftSchema()
return recv_getThriftSchema()
end
def send_getThriftSchema()
send_message('getThriftSchema', GetThriftSchema_args)
end
def recv_getThriftSchema()
result = receive_message(GetThriftSchema_result)
return result.success unless result.success.nil?
raise result.ex unless result.ex.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getThriftSchema failed: unknown result')
end
def getClusterStatus()
send_getClusterStatus()
return recv_getClusterStatus()
end
def send_getClusterStatus()
send_message('getClusterStatus', GetClusterStatus_args)
end
def recv_getClusterStatus()
result = receive_message(GetClusterStatus_result)
return result.success unless result.success.nil?
raise result.ex unless result.ex.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getClusterStatus failed: unknown result')
end
def getQueryPlan()
send_getQueryPlan()
return recv_getQueryPlan()
end
def send_getQueryPlan()
send_message('getQueryPlan', GetQueryPlan_args)
end
def recv_getQueryPlan()
result = receive_message(GetQueryPlan_result)
return result.success unless result.success.nil?
raise result.ex unless result.ex.nil?
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'getQueryPlan failed: unknown result')
end
end
class Processor < ::ThriftHiveMetastore::Processor
include ::Thrift::Processor
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
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
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
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
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
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
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
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
end
# HELPER FUNCTIONS AND STRUCTURES
class Execute_args
include ::Thrift::Struct, ::Thrift::Struct_Union
QUERY = 1
FIELDS = {
QUERY => {:type => ::Thrift::Types::STRING, :name => 'query'}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class Execute_result
include ::Thrift::Struct, ::Thrift::Struct_Union
EX = 1
FIELDS = {
EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Hive::Thrift::HiveServerException}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class FetchOne_args
include ::Thrift::Struct, ::Thrift::Struct_Union
FIELDS = {
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class FetchOne_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
EX = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::STRING, :name => 'success'},
EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Hive::Thrift::HiveServerException}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class FetchN_args
include ::Thrift::Struct, ::Thrift::Struct_Union
NUMROWS = 1
FIELDS = {
NUMROWS => {:type => ::Thrift::Types::I32, :name => 'numRows'}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class FetchN_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
EX = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Hive::Thrift::HiveServerException}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class FetchAll_args
include ::Thrift::Struct, ::Thrift::Struct_Union
FIELDS = {
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class FetchAll_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
EX = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRING}},
EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Hive::Thrift::HiveServerException}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetSchema_args
include ::Thrift::Struct, ::Thrift::Struct_Union
FIELDS = {
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetSchema_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
EX = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Schema},
EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Hive::Thrift::HiveServerException}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetThriftSchema_args
include ::Thrift::Struct, ::Thrift::Struct_Union
FIELDS = {
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetThriftSchema_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
EX = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Schema},
EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Hive::Thrift::HiveServerException}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetClusterStatus_args
include ::Thrift::Struct, ::Thrift::Struct_Union
FIELDS = {
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetClusterStatus_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
EX = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Hive::Thrift::HiveClusterStatus},
EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Hive::Thrift::HiveServerException}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetQueryPlan_args
include ::Thrift::Struct, ::Thrift::Struct_Union
FIELDS = {
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
class GetQueryPlan_result
include ::Thrift::Struct, ::Thrift::Struct_Union
SUCCESS = 0
EX = 1
FIELDS = {
SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::Hive::Thrift::QueryPlan},
EX => {:type => ::Thrift::Types::STRUCT, :name => 'ex', :class => ::Hive::Thrift::HiveServerException}
}
def struct_fields; FIELDS; end
def validate
end
::Thrift::Struct.generate_accessors self
end
end
end
end