You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2016/01/08 01:19:30 UTC
[20/51] [partial] hive git commit: HIVE-12442: Refactor/repackage
HiveServer2's Thrift code so that it can be used in the tasks (Rohit Dholakia
reviewed by Vaibhav Gumashta)
http://git-wip-us.apache.org/repos/asf/hive/blob/2542f5cc/service-rpc/src/gen/thrift/gen-rb/t_c_l_i_service.rb
----------------------------------------------------------------------
diff --git a/service-rpc/src/gen/thrift/gen-rb/t_c_l_i_service.rb b/service-rpc/src/gen/thrift/gen-rb/t_c_l_i_service.rb
new file mode 100644
index 0000000..f754d7d
--- /dev/null
+++ b/service-rpc/src/gen/thrift/gen-rb/t_c_l_i_service.rb
@@ -0,0 +1,1050 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+require 'thrift'
+require 't_c_l_i_service_types'
+
+module TCLIService
+ class Client
+ include ::Thrift::Client
+
+ def OpenSession(req)
+ send_OpenSession(req)
+ return recv_OpenSession()
+ end
+
+ def send_OpenSession(req)
+ send_message('OpenSession', OpenSession_args, :req => req)
+ end
+
+ def recv_OpenSession()
+ result = receive_message(OpenSession_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'OpenSession failed: unknown result')
+ end
+
+ def CloseSession(req)
+ send_CloseSession(req)
+ return recv_CloseSession()
+ end
+
+ def send_CloseSession(req)
+ send_message('CloseSession', CloseSession_args, :req => req)
+ end
+
+ def recv_CloseSession()
+ result = receive_message(CloseSession_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'CloseSession failed: unknown result')
+ end
+
+ def GetInfo(req)
+ send_GetInfo(req)
+ return recv_GetInfo()
+ end
+
+ def send_GetInfo(req)
+ send_message('GetInfo', GetInfo_args, :req => req)
+ end
+
+ def recv_GetInfo()
+ result = receive_message(GetInfo_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetInfo failed: unknown result')
+ end
+
+ def ExecuteStatement(req)
+ send_ExecuteStatement(req)
+ return recv_ExecuteStatement()
+ end
+
+ def send_ExecuteStatement(req)
+ send_message('ExecuteStatement', ExecuteStatement_args, :req => req)
+ end
+
+ def recv_ExecuteStatement()
+ result = receive_message(ExecuteStatement_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'ExecuteStatement failed: unknown result')
+ end
+
+ def GetTypeInfo(req)
+ send_GetTypeInfo(req)
+ return recv_GetTypeInfo()
+ end
+
+ def send_GetTypeInfo(req)
+ send_message('GetTypeInfo', GetTypeInfo_args, :req => req)
+ end
+
+ def recv_GetTypeInfo()
+ result = receive_message(GetTypeInfo_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetTypeInfo failed: unknown result')
+ end
+
+ def GetCatalogs(req)
+ send_GetCatalogs(req)
+ return recv_GetCatalogs()
+ end
+
+ def send_GetCatalogs(req)
+ send_message('GetCatalogs', GetCatalogs_args, :req => req)
+ end
+
+ def recv_GetCatalogs()
+ result = receive_message(GetCatalogs_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetCatalogs failed: unknown result')
+ end
+
+ def GetSchemas(req)
+ send_GetSchemas(req)
+ return recv_GetSchemas()
+ end
+
+ def send_GetSchemas(req)
+ send_message('GetSchemas', GetSchemas_args, :req => req)
+ end
+
+ def recv_GetSchemas()
+ result = receive_message(GetSchemas_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetSchemas failed: unknown result')
+ end
+
+ def GetTables(req)
+ send_GetTables(req)
+ return recv_GetTables()
+ end
+
+ def send_GetTables(req)
+ send_message('GetTables', GetTables_args, :req => req)
+ end
+
+ def recv_GetTables()
+ result = receive_message(GetTables_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetTables failed: unknown result')
+ end
+
+ def GetTableTypes(req)
+ send_GetTableTypes(req)
+ return recv_GetTableTypes()
+ end
+
+ def send_GetTableTypes(req)
+ send_message('GetTableTypes', GetTableTypes_args, :req => req)
+ end
+
+ def recv_GetTableTypes()
+ result = receive_message(GetTableTypes_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetTableTypes failed: unknown result')
+ end
+
+ def GetColumns(req)
+ send_GetColumns(req)
+ return recv_GetColumns()
+ end
+
+ def send_GetColumns(req)
+ send_message('GetColumns', GetColumns_args, :req => req)
+ end
+
+ def recv_GetColumns()
+ result = receive_message(GetColumns_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetColumns failed: unknown result')
+ end
+
+ def GetFunctions(req)
+ send_GetFunctions(req)
+ return recv_GetFunctions()
+ end
+
+ def send_GetFunctions(req)
+ send_message('GetFunctions', GetFunctions_args, :req => req)
+ end
+
+ def recv_GetFunctions()
+ result = receive_message(GetFunctions_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetFunctions failed: unknown result')
+ end
+
+ def GetOperationStatus(req)
+ send_GetOperationStatus(req)
+ return recv_GetOperationStatus()
+ end
+
+ def send_GetOperationStatus(req)
+ send_message('GetOperationStatus', GetOperationStatus_args, :req => req)
+ end
+
+ def recv_GetOperationStatus()
+ result = receive_message(GetOperationStatus_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetOperationStatus failed: unknown result')
+ end
+
+ def CancelOperation(req)
+ send_CancelOperation(req)
+ return recv_CancelOperation()
+ end
+
+ def send_CancelOperation(req)
+ send_message('CancelOperation', CancelOperation_args, :req => req)
+ end
+
+ def recv_CancelOperation()
+ result = receive_message(CancelOperation_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'CancelOperation failed: unknown result')
+ end
+
+ def CloseOperation(req)
+ send_CloseOperation(req)
+ return recv_CloseOperation()
+ end
+
+ def send_CloseOperation(req)
+ send_message('CloseOperation', CloseOperation_args, :req => req)
+ end
+
+ def recv_CloseOperation()
+ result = receive_message(CloseOperation_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'CloseOperation failed: unknown result')
+ end
+
+ def GetResultSetMetadata(req)
+ send_GetResultSetMetadata(req)
+ return recv_GetResultSetMetadata()
+ end
+
+ def send_GetResultSetMetadata(req)
+ send_message('GetResultSetMetadata', GetResultSetMetadata_args, :req => req)
+ end
+
+ def recv_GetResultSetMetadata()
+ result = receive_message(GetResultSetMetadata_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetResultSetMetadata failed: unknown result')
+ end
+
+ def FetchResults(req)
+ send_FetchResults(req)
+ return recv_FetchResults()
+ end
+
+ def send_FetchResults(req)
+ send_message('FetchResults', FetchResults_args, :req => req)
+ end
+
+ def recv_FetchResults()
+ result = receive_message(FetchResults_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'FetchResults failed: unknown result')
+ end
+
+ def GetDelegationToken(req)
+ send_GetDelegationToken(req)
+ return recv_GetDelegationToken()
+ end
+
+ def send_GetDelegationToken(req)
+ send_message('GetDelegationToken', GetDelegationToken_args, :req => req)
+ end
+
+ def recv_GetDelegationToken()
+ result = receive_message(GetDelegationToken_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'GetDelegationToken failed: unknown result')
+ end
+
+ def CancelDelegationToken(req)
+ send_CancelDelegationToken(req)
+ return recv_CancelDelegationToken()
+ end
+
+ def send_CancelDelegationToken(req)
+ send_message('CancelDelegationToken', CancelDelegationToken_args, :req => req)
+ end
+
+ def recv_CancelDelegationToken()
+ result = receive_message(CancelDelegationToken_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'CancelDelegationToken failed: unknown result')
+ end
+
+ def RenewDelegationToken(req)
+ send_RenewDelegationToken(req)
+ return recv_RenewDelegationToken()
+ end
+
+ def send_RenewDelegationToken(req)
+ send_message('RenewDelegationToken', RenewDelegationToken_args, :req => req)
+ end
+
+ def recv_RenewDelegationToken()
+ result = receive_message(RenewDelegationToken_result)
+ return result.success unless result.success.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'RenewDelegationToken failed: unknown result')
+ end
+
+ end
+
+ class Processor
+ include ::Thrift::Processor
+
+ def process_OpenSession(seqid, iprot, oprot)
+ args = read_args(iprot, OpenSession_args)
+ result = OpenSession_result.new()
+ result.success = @handler.OpenSession(args.req)
+ write_result(result, oprot, 'OpenSession', seqid)
+ end
+
+ def process_CloseSession(seqid, iprot, oprot)
+ args = read_args(iprot, CloseSession_args)
+ result = CloseSession_result.new()
+ result.success = @handler.CloseSession(args.req)
+ write_result(result, oprot, 'CloseSession', seqid)
+ end
+
+ def process_GetInfo(seqid, iprot, oprot)
+ args = read_args(iprot, GetInfo_args)
+ result = GetInfo_result.new()
+ result.success = @handler.GetInfo(args.req)
+ write_result(result, oprot, 'GetInfo', seqid)
+ end
+
+ def process_ExecuteStatement(seqid, iprot, oprot)
+ args = read_args(iprot, ExecuteStatement_args)
+ result = ExecuteStatement_result.new()
+ result.success = @handler.ExecuteStatement(args.req)
+ write_result(result, oprot, 'ExecuteStatement', seqid)
+ end
+
+ def process_GetTypeInfo(seqid, iprot, oprot)
+ args = read_args(iprot, GetTypeInfo_args)
+ result = GetTypeInfo_result.new()
+ result.success = @handler.GetTypeInfo(args.req)
+ write_result(result, oprot, 'GetTypeInfo', seqid)
+ end
+
+ def process_GetCatalogs(seqid, iprot, oprot)
+ args = read_args(iprot, GetCatalogs_args)
+ result = GetCatalogs_result.new()
+ result.success = @handler.GetCatalogs(args.req)
+ write_result(result, oprot, 'GetCatalogs', seqid)
+ end
+
+ def process_GetSchemas(seqid, iprot, oprot)
+ args = read_args(iprot, GetSchemas_args)
+ result = GetSchemas_result.new()
+ result.success = @handler.GetSchemas(args.req)
+ write_result(result, oprot, 'GetSchemas', seqid)
+ end
+
+ def process_GetTables(seqid, iprot, oprot)
+ args = read_args(iprot, GetTables_args)
+ result = GetTables_result.new()
+ result.success = @handler.GetTables(args.req)
+ write_result(result, oprot, 'GetTables', seqid)
+ end
+
+ def process_GetTableTypes(seqid, iprot, oprot)
+ args = read_args(iprot, GetTableTypes_args)
+ result = GetTableTypes_result.new()
+ result.success = @handler.GetTableTypes(args.req)
+ write_result(result, oprot, 'GetTableTypes', seqid)
+ end
+
+ def process_GetColumns(seqid, iprot, oprot)
+ args = read_args(iprot, GetColumns_args)
+ result = GetColumns_result.new()
+ result.success = @handler.GetColumns(args.req)
+ write_result(result, oprot, 'GetColumns', seqid)
+ end
+
+ def process_GetFunctions(seqid, iprot, oprot)
+ args = read_args(iprot, GetFunctions_args)
+ result = GetFunctions_result.new()
+ result.success = @handler.GetFunctions(args.req)
+ write_result(result, oprot, 'GetFunctions', seqid)
+ end
+
+ def process_GetOperationStatus(seqid, iprot, oprot)
+ args = read_args(iprot, GetOperationStatus_args)
+ result = GetOperationStatus_result.new()
+ result.success = @handler.GetOperationStatus(args.req)
+ write_result(result, oprot, 'GetOperationStatus', seqid)
+ end
+
+ def process_CancelOperation(seqid, iprot, oprot)
+ args = read_args(iprot, CancelOperation_args)
+ result = CancelOperation_result.new()
+ result.success = @handler.CancelOperation(args.req)
+ write_result(result, oprot, 'CancelOperation', seqid)
+ end
+
+ def process_CloseOperation(seqid, iprot, oprot)
+ args = read_args(iprot, CloseOperation_args)
+ result = CloseOperation_result.new()
+ result.success = @handler.CloseOperation(args.req)
+ write_result(result, oprot, 'CloseOperation', seqid)
+ end
+
+ def process_GetResultSetMetadata(seqid, iprot, oprot)
+ args = read_args(iprot, GetResultSetMetadata_args)
+ result = GetResultSetMetadata_result.new()
+ result.success = @handler.GetResultSetMetadata(args.req)
+ write_result(result, oprot, 'GetResultSetMetadata', seqid)
+ end
+
+ def process_FetchResults(seqid, iprot, oprot)
+ args = read_args(iprot, FetchResults_args)
+ result = FetchResults_result.new()
+ result.success = @handler.FetchResults(args.req)
+ write_result(result, oprot, 'FetchResults', seqid)
+ end
+
+ def process_GetDelegationToken(seqid, iprot, oprot)
+ args = read_args(iprot, GetDelegationToken_args)
+ result = GetDelegationToken_result.new()
+ result.success = @handler.GetDelegationToken(args.req)
+ write_result(result, oprot, 'GetDelegationToken', seqid)
+ end
+
+ def process_CancelDelegationToken(seqid, iprot, oprot)
+ args = read_args(iprot, CancelDelegationToken_args)
+ result = CancelDelegationToken_result.new()
+ result.success = @handler.CancelDelegationToken(args.req)
+ write_result(result, oprot, 'CancelDelegationToken', seqid)
+ end
+
+ def process_RenewDelegationToken(seqid, iprot, oprot)
+ args = read_args(iprot, RenewDelegationToken_args)
+ result = RenewDelegationToken_result.new()
+ result.success = @handler.RenewDelegationToken(args.req)
+ write_result(result, oprot, 'RenewDelegationToken', seqid)
+ end
+
+ end
+
+ # HELPER FUNCTIONS AND STRUCTURES
+
+ class OpenSession_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TOpenSessionReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class OpenSession_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TOpenSessionResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class CloseSession_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TCloseSessionReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class CloseSession_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TCloseSessionResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetInfo_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetInfoReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetInfo_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetInfoResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class ExecuteStatement_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TExecuteStatementReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class ExecuteStatement_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TExecuteStatementResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetTypeInfo_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetTypeInfoReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetTypeInfo_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetTypeInfoResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetCatalogs_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetCatalogsReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetCatalogs_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetCatalogsResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetSchemas_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetSchemasReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetSchemas_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetSchemasResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetTables_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetTablesReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetTables_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetTablesResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetTableTypes_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetTableTypesReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetTableTypes_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetTableTypesResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetColumns_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetColumnsReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetColumns_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetColumnsResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetFunctions_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetFunctionsReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetFunctions_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetFunctionsResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetOperationStatus_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetOperationStatusReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetOperationStatus_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetOperationStatusResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class CancelOperation_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TCancelOperationReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class CancelOperation_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TCancelOperationResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class CloseOperation_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TCloseOperationReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class CloseOperation_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TCloseOperationResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetResultSetMetadata_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetResultSetMetadataReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetResultSetMetadata_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetResultSetMetadataResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class FetchResults_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TFetchResultsReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class FetchResults_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TFetchResultsResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetDelegationToken_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TGetDelegationTokenReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class GetDelegationToken_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TGetDelegationTokenResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class CancelDelegationToken_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TCancelDelegationTokenReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class CancelDelegationToken_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TCancelDelegationTokenResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class RenewDelegationToken_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ REQ = 1
+
+ FIELDS = {
+ REQ => {:type => ::Thrift::Types::STRUCT, :name => 'req', :class => ::TRenewDelegationTokenReq}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class RenewDelegationToken_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::TRenewDelegationTokenResp}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+end
+
http://git-wip-us.apache.org/repos/asf/hive/blob/2542f5cc/service-rpc/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb
----------------------------------------------------------------------
diff --git a/service-rpc/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb b/service-rpc/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb
new file mode 100644
index 0000000..3f72769
--- /dev/null
+++ b/service-rpc/src/gen/thrift/gen-rb/t_c_l_i_service_constants.rb
@@ -0,0 +1,72 @@
+#
+# Autogenerated by Thrift Compiler (0.9.2)
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+require 'thrift'
+require 't_c_l_i_service_types'
+
+PRIMITIVE_TYPES = Set.new([
+ 0,
+ 1,
+ 2,
+ 3,
+ 4,
+ 5,
+ 6,
+ 7,
+ 8,
+ 9,
+ 15,
+ 16,
+ 17,
+ 18,
+ 19,
+ 20,
+ 21,
+])
+
+COMPLEX_TYPES = Set.new([
+ 10,
+ 11,
+ 12,
+ 13,
+ 14,
+])
+
+COLLECTION_TYPES = Set.new([
+ 10,
+ 11,
+])
+
+TYPE_NAMES = {
+ 0 => %q"BOOLEAN",
+ 1 => %q"TINYINT",
+ 2 => %q"SMALLINT",
+ 3 => %q"INT",
+ 4 => %q"BIGINT",
+ 5 => %q"FLOAT",
+ 6 => %q"DOUBLE",
+ 7 => %q"STRING",
+ 8 => %q"TIMESTAMP",
+ 9 => %q"BINARY",
+ 10 => %q"ARRAY",
+ 11 => %q"MAP",
+ 12 => %q"STRUCT",
+ 13 => %q"UNIONTYPE",
+ 15 => %q"DECIMAL",
+ 16 => %q"NULL",
+ 17 => %q"DATE",
+ 18 => %q"VARCHAR",
+ 19 => %q"CHAR",
+ 20 => %q"INTERVAL_YEAR_MONTH",
+ 21 => %q"INTERVAL_DAY_TIME",
+}
+
+CHARACTER_MAXIMUM_LENGTH = %q"characterMaximumLength"
+
+PRECISION = %q"precision"
+
+SCALE = %q"scale"
+