You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2018/03/12 23:55:45 UTC
[05/18] hive git commit: HIVE-17990 Add Thrift and DB storage for
Schema Registry objects (Alan Gates, reviewed by Thejas Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
index b24c5f9..4d4429f 100644
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
@@ -211,6 +211,100 @@ class EventRequestType:
"DELETE": 3,
}
+class SerdeType:
+ HIVE = 1
+ SCHEMA_REGISTRY = 2
+
+ _VALUES_TO_NAMES = {
+ 1: "HIVE",
+ 2: "SCHEMA_REGISTRY",
+ }
+
+ _NAMES_TO_VALUES = {
+ "HIVE": 1,
+ "SCHEMA_REGISTRY": 2,
+ }
+
+class SchemaType:
+ HIVE = 1
+ AVRO = 2
+
+ _VALUES_TO_NAMES = {
+ 1: "HIVE",
+ 2: "AVRO",
+ }
+
+ _NAMES_TO_VALUES = {
+ "HIVE": 1,
+ "AVRO": 2,
+ }
+
+class SchemaCompatibility:
+ NONE = 1
+ BACKWARD = 2
+ FORWARD = 3
+ BOTH = 4
+
+ _VALUES_TO_NAMES = {
+ 1: "NONE",
+ 2: "BACKWARD",
+ 3: "FORWARD",
+ 4: "BOTH",
+ }
+
+ _NAMES_TO_VALUES = {
+ "NONE": 1,
+ "BACKWARD": 2,
+ "FORWARD": 3,
+ "BOTH": 4,
+ }
+
+class SchemaValidation:
+ LATEST = 1
+ ALL = 2
+
+ _VALUES_TO_NAMES = {
+ 1: "LATEST",
+ 2: "ALL",
+ }
+
+ _NAMES_TO_VALUES = {
+ "LATEST": 1,
+ "ALL": 2,
+ }
+
+class SchemaVersionState:
+ INITIATED = 1
+ START_REVIEW = 2
+ CHANGES_REQUIRED = 3
+ REVIEWED = 4
+ ENABLED = 5
+ DISABLED = 6
+ ARCHIVED = 7
+ DELETED = 8
+
+ _VALUES_TO_NAMES = {
+ 1: "INITIATED",
+ 2: "START_REVIEW",
+ 3: "CHANGES_REQUIRED",
+ 4: "REVIEWED",
+ 5: "ENABLED",
+ 6: "DISABLED",
+ 7: "ARCHIVED",
+ 8: "DELETED",
+ }
+
+ _NAMES_TO_VALUES = {
+ "INITIATED": 1,
+ "START_REVIEW": 2,
+ "CHANGES_REQUIRED": 3,
+ "REVIEWED": 4,
+ "ENABLED": 5,
+ "DISABLED": 6,
+ "ARCHIVED": 7,
+ "DELETED": 8,
+ }
+
class FunctionType:
JAVA = 1
@@ -3053,6 +3147,10 @@ class SerDeInfo:
- name
- serializationLib
- parameters
+ - description
+ - serializerClass
+ - deserializerClass
+ - serdeType
"""
thrift_spec = (
@@ -3060,12 +3158,20 @@ class SerDeInfo:
(1, TType.STRING, 'name', None, None, ), # 1
(2, TType.STRING, 'serializationLib', None, None, ), # 2
(3, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 3
+ (4, TType.STRING, 'description', None, None, ), # 4
+ (5, TType.STRING, 'serializerClass', None, None, ), # 5
+ (6, TType.STRING, 'deserializerClass', None, None, ), # 6
+ (7, TType.I32, 'serdeType', None, None, ), # 7
)
- def __init__(self, name=None, serializationLib=None, parameters=None,):
+ def __init__(self, name=None, serializationLib=None, parameters=None, description=None, serializerClass=None, deserializerClass=None, serdeType=None,):
self.name = name
self.serializationLib = serializationLib
self.parameters = parameters
+ self.description = description
+ self.serializerClass = serializerClass
+ self.deserializerClass = deserializerClass
+ self.serdeType = serdeType
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -3097,6 +3203,26 @@ class SerDeInfo:
iprot.readMapEnd()
else:
iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.description = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.serializerClass = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.deserializerClass = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.I32:
+ self.serdeType = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -3123,6 +3249,22 @@ class SerDeInfo:
oprot.writeString(viter100)
oprot.writeMapEnd()
oprot.writeFieldEnd()
+ if self.description is not None:
+ oprot.writeFieldBegin('description', TType.STRING, 4)
+ oprot.writeString(self.description)
+ oprot.writeFieldEnd()
+ if self.serializerClass is not None:
+ oprot.writeFieldBegin('serializerClass', TType.STRING, 5)
+ oprot.writeString(self.serializerClass)
+ oprot.writeFieldEnd()
+ if self.deserializerClass is not None:
+ oprot.writeFieldBegin('deserializerClass', TType.STRING, 6)
+ oprot.writeString(self.deserializerClass)
+ oprot.writeFieldEnd()
+ if self.serdeType is not None:
+ oprot.writeFieldBegin('serdeType', TType.I32, 7)
+ oprot.writeI32(self.serdeType)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -3135,6 +3277,10 @@ class SerDeInfo:
value = (value * 31) ^ hash(self.name)
value = (value * 31) ^ hash(self.serializationLib)
value = (value * 31) ^ hash(self.parameters)
+ value = (value * 31) ^ hash(self.description)
+ value = (value * 31) ^ hash(self.serializerClass)
+ value = (value * 31) ^ hash(self.deserializerClass)
+ value = (value * 31) ^ hash(self.serdeType)
return value
def __repr__(self):
@@ -18732,6 +18878,981 @@ class WMCreateOrDropTriggerToPoolMappingResponse:
def __ne__(self, other):
return not (self == other)
+class ISchema:
+ """
+ Attributes:
+ - schemaType
+ - name
+ - dbName
+ - compatibility
+ - validationLevel
+ - canEvolve
+ - schemaGroup
+ - description
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'schemaType', None, None, ), # 1
+ (2, TType.STRING, 'name', None, None, ), # 2
+ (3, TType.STRING, 'dbName', None, None, ), # 3
+ (4, TType.I32, 'compatibility', None, None, ), # 4
+ (5, TType.I32, 'validationLevel', None, None, ), # 5
+ (6, TType.BOOL, 'canEvolve', None, None, ), # 6
+ (7, TType.STRING, 'schemaGroup', None, None, ), # 7
+ (8, TType.STRING, 'description', None, None, ), # 8
+ )
+
+ def __init__(self, schemaType=None, name=None, dbName=None, compatibility=None, validationLevel=None, canEvolve=None, schemaGroup=None, description=None,):
+ self.schemaType = schemaType
+ self.name = name
+ self.dbName = dbName
+ self.compatibility = compatibility
+ self.validationLevel = validationLevel
+ self.canEvolve = canEvolve
+ self.schemaGroup = schemaGroup
+ self.description = description
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.I32:
+ self.schemaType = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.dbName = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I32:
+ self.compatibility = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I32:
+ self.validationLevel = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.BOOL:
+ self.canEvolve = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.schemaGroup = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.description = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('ISchema')
+ if self.schemaType is not None:
+ oprot.writeFieldBegin('schemaType', TType.I32, 1)
+ oprot.writeI32(self.schemaType)
+ oprot.writeFieldEnd()
+ if self.name is not None:
+ oprot.writeFieldBegin('name', TType.STRING, 2)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ if self.dbName is not None:
+ oprot.writeFieldBegin('dbName', TType.STRING, 3)
+ oprot.writeString(self.dbName)
+ oprot.writeFieldEnd()
+ if self.compatibility is not None:
+ oprot.writeFieldBegin('compatibility', TType.I32, 4)
+ oprot.writeI32(self.compatibility)
+ oprot.writeFieldEnd()
+ if self.validationLevel is not None:
+ oprot.writeFieldBegin('validationLevel', TType.I32, 5)
+ oprot.writeI32(self.validationLevel)
+ oprot.writeFieldEnd()
+ if self.canEvolve is not None:
+ oprot.writeFieldBegin('canEvolve', TType.BOOL, 6)
+ oprot.writeBool(self.canEvolve)
+ oprot.writeFieldEnd()
+ if self.schemaGroup is not None:
+ oprot.writeFieldBegin('schemaGroup', TType.STRING, 7)
+ oprot.writeString(self.schemaGroup)
+ oprot.writeFieldEnd()
+ if self.description is not None:
+ oprot.writeFieldBegin('description', TType.STRING, 8)
+ oprot.writeString(self.description)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.schemaType)
+ value = (value * 31) ^ hash(self.name)
+ value = (value * 31) ^ hash(self.dbName)
+ value = (value * 31) ^ hash(self.compatibility)
+ value = (value * 31) ^ hash(self.validationLevel)
+ value = (value * 31) ^ hash(self.canEvolve)
+ value = (value * 31) ^ hash(self.schemaGroup)
+ value = (value * 31) ^ hash(self.description)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class ISchemaName:
+ """
+ Attributes:
+ - dbName
+ - schemaName
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'dbName', None, None, ), # 1
+ (2, TType.STRING, 'schemaName', None, None, ), # 2
+ )
+
+ def __init__(self, dbName=None, schemaName=None,):
+ self.dbName = dbName
+ self.schemaName = schemaName
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.dbName = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.schemaName = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('ISchemaName')
+ if self.dbName is not None:
+ oprot.writeFieldBegin('dbName', TType.STRING, 1)
+ oprot.writeString(self.dbName)
+ oprot.writeFieldEnd()
+ if self.schemaName is not None:
+ oprot.writeFieldBegin('schemaName', TType.STRING, 2)
+ oprot.writeString(self.schemaName)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.dbName)
+ value = (value * 31) ^ hash(self.schemaName)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class AlterISchemaRequest:
+ """
+ Attributes:
+ - name
+ - newSchema
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'name', (ISchemaName, ISchemaName.thrift_spec), None, ), # 1
+ None, # 2
+ (3, TType.STRUCT, 'newSchema', (ISchema, ISchema.thrift_spec), None, ), # 3
+ )
+
+ def __init__(self, name=None, newSchema=None,):
+ self.name = name
+ self.newSchema = newSchema
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.name = ISchemaName()
+ self.name.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.newSchema = ISchema()
+ self.newSchema.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('AlterISchemaRequest')
+ if self.name is not None:
+ oprot.writeFieldBegin('name', TType.STRUCT, 1)
+ self.name.write(oprot)
+ oprot.writeFieldEnd()
+ if self.newSchema is not None:
+ oprot.writeFieldBegin('newSchema', TType.STRUCT, 3)
+ self.newSchema.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.name)
+ value = (value * 31) ^ hash(self.newSchema)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class SchemaVersion:
+ """
+ Attributes:
+ - schema
+ - version
+ - createdAt
+ - cols
+ - state
+ - description
+ - schemaText
+ - fingerprint
+ - name
+ - serDe
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'schema', (ISchemaName, ISchemaName.thrift_spec), None, ), # 1
+ (2, TType.I32, 'version', None, None, ), # 2
+ (3, TType.I64, 'createdAt', None, None, ), # 3
+ (4, TType.LIST, 'cols', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 4
+ (5, TType.I32, 'state', None, None, ), # 5
+ (6, TType.STRING, 'description', None, None, ), # 6
+ (7, TType.STRING, 'schemaText', None, None, ), # 7
+ (8, TType.STRING, 'fingerprint', None, None, ), # 8
+ (9, TType.STRING, 'name', None, None, ), # 9
+ (10, TType.STRUCT, 'serDe', (SerDeInfo, SerDeInfo.thrift_spec), None, ), # 10
+ )
+
+ def __init__(self, schema=None, version=None, createdAt=None, cols=None, state=None, description=None, schemaText=None, fingerprint=None, name=None, serDe=None,):
+ self.schema = schema
+ self.version = version
+ self.createdAt = createdAt
+ self.cols = cols
+ self.state = state
+ self.description = description
+ self.schemaText = schemaText
+ self.fingerprint = fingerprint
+ self.name = name
+ self.serDe = serDe
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.schema = ISchemaName()
+ self.schema.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.version = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I64:
+ self.createdAt = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.LIST:
+ self.cols = []
+ (_etype763, _size760) = iprot.readListBegin()
+ for _i764 in xrange(_size760):
+ _elem765 = FieldSchema()
+ _elem765.read(iprot)
+ self.cols.append(_elem765)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I32:
+ self.state = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.description = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.schemaText = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.fingerprint = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.STRING:
+ self.name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 10:
+ if ftype == TType.STRUCT:
+ self.serDe = SerDeInfo()
+ self.serDe.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('SchemaVersion')
+ if self.schema is not None:
+ oprot.writeFieldBegin('schema', TType.STRUCT, 1)
+ self.schema.write(oprot)
+ oprot.writeFieldEnd()
+ if self.version is not None:
+ oprot.writeFieldBegin('version', TType.I32, 2)
+ oprot.writeI32(self.version)
+ oprot.writeFieldEnd()
+ if self.createdAt is not None:
+ oprot.writeFieldBegin('createdAt', TType.I64, 3)
+ oprot.writeI64(self.createdAt)
+ oprot.writeFieldEnd()
+ if self.cols is not None:
+ oprot.writeFieldBegin('cols', TType.LIST, 4)
+ oprot.writeListBegin(TType.STRUCT, len(self.cols))
+ for iter766 in self.cols:
+ iter766.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 5)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ if self.description is not None:
+ oprot.writeFieldBegin('description', TType.STRING, 6)
+ oprot.writeString(self.description)
+ oprot.writeFieldEnd()
+ if self.schemaText is not None:
+ oprot.writeFieldBegin('schemaText', TType.STRING, 7)
+ oprot.writeString(self.schemaText)
+ oprot.writeFieldEnd()
+ if self.fingerprint is not None:
+ oprot.writeFieldBegin('fingerprint', TType.STRING, 8)
+ oprot.writeString(self.fingerprint)
+ oprot.writeFieldEnd()
+ if self.name is not None:
+ oprot.writeFieldBegin('name', TType.STRING, 9)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ if self.serDe is not None:
+ oprot.writeFieldBegin('serDe', TType.STRUCT, 10)
+ self.serDe.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.schema)
+ value = (value * 31) ^ hash(self.version)
+ value = (value * 31) ^ hash(self.createdAt)
+ value = (value * 31) ^ hash(self.cols)
+ value = (value * 31) ^ hash(self.state)
+ value = (value * 31) ^ hash(self.description)
+ value = (value * 31) ^ hash(self.schemaText)
+ value = (value * 31) ^ hash(self.fingerprint)
+ value = (value * 31) ^ hash(self.name)
+ value = (value * 31) ^ hash(self.serDe)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class SchemaVersionDescriptor:
+ """
+ Attributes:
+ - schema
+ - version
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'schema', (ISchemaName, ISchemaName.thrift_spec), None, ), # 1
+ (2, TType.I32, 'version', None, None, ), # 2
+ )
+
+ def __init__(self, schema=None, version=None,):
+ self.schema = schema
+ self.version = version
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.schema = ISchemaName()
+ self.schema.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.version = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('SchemaVersionDescriptor')
+ if self.schema is not None:
+ oprot.writeFieldBegin('schema', TType.STRUCT, 1)
+ self.schema.write(oprot)
+ oprot.writeFieldEnd()
+ if self.version is not None:
+ oprot.writeFieldBegin('version', TType.I32, 2)
+ oprot.writeI32(self.version)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.schema)
+ value = (value * 31) ^ hash(self.version)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class FindSchemasByColsRqst:
+ """
+ Attributes:
+ - colName
+ - colNamespace
+ - type
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'colName', None, None, ), # 1
+ (2, TType.STRING, 'colNamespace', None, None, ), # 2
+ (3, TType.STRING, 'type', None, None, ), # 3
+ )
+
+ def __init__(self, colName=None, colNamespace=None, type=None,):
+ self.colName = colName
+ self.colNamespace = colNamespace
+ self.type = type
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.colName = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.colNamespace = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.type = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('FindSchemasByColsRqst')
+ if self.colName is not None:
+ oprot.writeFieldBegin('colName', TType.STRING, 1)
+ oprot.writeString(self.colName)
+ oprot.writeFieldEnd()
+ if self.colNamespace is not None:
+ oprot.writeFieldBegin('colNamespace', TType.STRING, 2)
+ oprot.writeString(self.colNamespace)
+ oprot.writeFieldEnd()
+ if self.type is not None:
+ oprot.writeFieldBegin('type', TType.STRING, 3)
+ oprot.writeString(self.type)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.colName)
+ value = (value * 31) ^ hash(self.colNamespace)
+ value = (value * 31) ^ hash(self.type)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class FindSchemasByColsResp:
+ """
+ Attributes:
+ - schemaVersions
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'schemaVersions', (TType.STRUCT,(SchemaVersionDescriptor, SchemaVersionDescriptor.thrift_spec)), None, ), # 1
+ )
+
+ def __init__(self, schemaVersions=None,):
+ self.schemaVersions = schemaVersions
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.LIST:
+ self.schemaVersions = []
+ (_etype770, _size767) = iprot.readListBegin()
+ for _i771 in xrange(_size767):
+ _elem772 = SchemaVersionDescriptor()
+ _elem772.read(iprot)
+ self.schemaVersions.append(_elem772)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('FindSchemasByColsResp')
+ if self.schemaVersions is not None:
+ oprot.writeFieldBegin('schemaVersions', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.schemaVersions))
+ for iter773 in self.schemaVersions:
+ iter773.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.schemaVersions)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class MapSchemaVersionToSerdeRequest:
+ """
+ Attributes:
+ - schemaVersion
+ - serdeName
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'schemaVersion', (SchemaVersionDescriptor, SchemaVersionDescriptor.thrift_spec), None, ), # 1
+ (2, TType.STRING, 'serdeName', None, None, ), # 2
+ )
+
+ def __init__(self, schemaVersion=None, serdeName=None,):
+ self.schemaVersion = schemaVersion
+ self.serdeName = serdeName
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.schemaVersion = SchemaVersionDescriptor()
+ self.schemaVersion.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.serdeName = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('MapSchemaVersionToSerdeRequest')
+ if self.schemaVersion is not None:
+ oprot.writeFieldBegin('schemaVersion', TType.STRUCT, 1)
+ self.schemaVersion.write(oprot)
+ oprot.writeFieldEnd()
+ if self.serdeName is not None:
+ oprot.writeFieldBegin('serdeName', TType.STRING, 2)
+ oprot.writeString(self.serdeName)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.schemaVersion)
+ value = (value * 31) ^ hash(self.serdeName)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class SetSchemaVersionStateRequest:
+ """
+ Attributes:
+ - schemaVersion
+ - state
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'schemaVersion', (SchemaVersionDescriptor, SchemaVersionDescriptor.thrift_spec), None, ), # 1
+ (2, TType.I32, 'state', None, None, ), # 2
+ )
+
+ def __init__(self, schemaVersion=None, state=None,):
+ self.schemaVersion = schemaVersion
+ self.state = state
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.schemaVersion = SchemaVersionDescriptor()
+ self.schemaVersion.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.state = iprot.readI32()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('SetSchemaVersionStateRequest')
+ if self.schemaVersion is not None:
+ oprot.writeFieldBegin('schemaVersion', TType.STRUCT, 1)
+ self.schemaVersion.write(oprot)
+ oprot.writeFieldEnd()
+ if self.state is not None:
+ oprot.writeFieldBegin('state', TType.I32, 2)
+ oprot.writeI32(self.state)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.schemaVersion)
+ value = (value * 31) ^ hash(self.state)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class GetSerdeRequest:
+ """
+ Attributes:
+ - serdeName
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'serdeName', None, None, ), # 1
+ )
+
+ def __init__(self, serdeName=None,):
+ self.serdeName = serdeName
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.serdeName = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('GetSerdeRequest')
+ if self.serdeName is not None:
+ oprot.writeFieldBegin('serdeName', TType.STRING, 1)
+ oprot.writeString(self.serdeName)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.serdeName)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
class MetaException(TException):
"""
Attributes:
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb b/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
index 29ad1bc..6b6746f 100644
--- a/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
+++ b/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
@@ -98,6 +98,49 @@ module EventRequestType
VALID_VALUES = Set.new([INSERT, UPDATE, DELETE]).freeze
end
+module SerdeType
+ HIVE = 1
+ SCHEMA_REGISTRY = 2
+ VALUE_MAP = {1 => "HIVE", 2 => "SCHEMA_REGISTRY"}
+ VALID_VALUES = Set.new([HIVE, SCHEMA_REGISTRY]).freeze
+end
+
+module SchemaType
+ HIVE = 1
+ AVRO = 2
+ VALUE_MAP = {1 => "HIVE", 2 => "AVRO"}
+ VALID_VALUES = Set.new([HIVE, AVRO]).freeze
+end
+
+module SchemaCompatibility
+ NONE = 1
+ BACKWARD = 2
+ FORWARD = 3
+ BOTH = 4
+ VALUE_MAP = {1 => "NONE", 2 => "BACKWARD", 3 => "FORWARD", 4 => "BOTH"}
+ VALID_VALUES = Set.new([NONE, BACKWARD, FORWARD, BOTH]).freeze
+end
+
+module SchemaValidation
+ LATEST = 1
+ ALL = 2
+ VALUE_MAP = {1 => "LATEST", 2 => "ALL"}
+ VALID_VALUES = Set.new([LATEST, ALL]).freeze
+end
+
+module SchemaVersionState
+ INITIATED = 1
+ START_REVIEW = 2
+ CHANGES_REQUIRED = 3
+ REVIEWED = 4
+ ENABLED = 5
+ DISABLED = 6
+ ARCHIVED = 7
+ DELETED = 8
+ VALUE_MAP = {1 => "INITIATED", 2 => "START_REVIEW", 3 => "CHANGES_REQUIRED", 4 => "REVIEWED", 5 => "ENABLED", 6 => "DISABLED", 7 => "ARCHIVED", 8 => "DELETED"}
+ VALID_VALUES = Set.new([INITIATED, START_REVIEW, CHANGES_REQUIRED, REVIEWED, ENABLED, DISABLED, ARCHIVED, DELETED]).freeze
+end
+
module FunctionType
JAVA = 1
VALUE_MAP = {1 => "JAVA"}
@@ -731,16 +774,27 @@ class SerDeInfo
NAME = 1
SERIALIZATIONLIB = 2
PARAMETERS = 3
+ DESCRIPTION = 4
+ SERIALIZERCLASS = 5
+ DESERIALIZERCLASS = 6
+ SERDETYPE = 7
FIELDS = {
NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
SERIALIZATIONLIB => {:type => ::Thrift::Types::STRING, :name => 'serializationLib'},
- PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}
+ PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}},
+ DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description', :optional => true},
+ SERIALIZERCLASS => {:type => ::Thrift::Types::STRING, :name => 'serializerClass', :optional => true},
+ DESERIALIZERCLASS => {:type => ::Thrift::Types::STRING, :name => 'deserializerClass', :optional => true},
+ SERDETYPE => {:type => ::Thrift::Types::I32, :name => 'serdeType', :optional => true, :enum_class => ::SerdeType}
}
def struct_fields; FIELDS; end
def validate
+ unless @serdeType.nil? || ::SerdeType::VALID_VALUES.include?(@serdeType)
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field serdeType!')
+ end
end
::Thrift::Struct.generate_accessors self
@@ -4280,6 +4334,227 @@ class WMCreateOrDropTriggerToPoolMappingResponse
::Thrift::Struct.generate_accessors self
end
+class ISchema
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMATYPE = 1
+ NAME = 2
+ DBNAME = 3
+ COMPATIBILITY = 4
+ VALIDATIONLEVEL = 5
+ CANEVOLVE = 6
+ SCHEMAGROUP = 7
+ DESCRIPTION = 8
+
+ FIELDS = {
+ SCHEMATYPE => {:type => ::Thrift::Types::I32, :name => 'schemaType', :enum_class => ::SchemaType},
+ NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
+ DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'},
+ COMPATIBILITY => {:type => ::Thrift::Types::I32, :name => 'compatibility', :enum_class => ::SchemaCompatibility},
+ VALIDATIONLEVEL => {:type => ::Thrift::Types::I32, :name => 'validationLevel', :enum_class => ::SchemaValidation},
+ CANEVOLVE => {:type => ::Thrift::Types::BOOL, :name => 'canEvolve'},
+ SCHEMAGROUP => {:type => ::Thrift::Types::STRING, :name => 'schemaGroup', :optional => true},
+ DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description', :optional => true}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ unless @schemaType.nil? || ::SchemaType::VALID_VALUES.include?(@schemaType)
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field schemaType!')
+ end
+ unless @compatibility.nil? || ::SchemaCompatibility::VALID_VALUES.include?(@compatibility)
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field compatibility!')
+ end
+ unless @validationLevel.nil? || ::SchemaValidation::VALID_VALUES.include?(@validationLevel)
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field validationLevel!')
+ end
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class ISchemaName
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ DBNAME = 1
+ SCHEMANAME = 2
+
+ FIELDS = {
+ DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'},
+ SCHEMANAME => {:type => ::Thrift::Types::STRING, :name => 'schemaName'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class AlterISchemaRequest
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ NAME = 1
+ NEWSCHEMA = 3
+
+ FIELDS = {
+ NAME => {:type => ::Thrift::Types::STRUCT, :name => 'name', :class => ::ISchemaName},
+ NEWSCHEMA => {:type => ::Thrift::Types::STRUCT, :name => 'newSchema', :class => ::ISchema}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class SchemaVersion
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMA = 1
+ VERSION = 2
+ CREATEDAT = 3
+ COLS = 4
+ STATE = 5
+ DESCRIPTION = 6
+ SCHEMATEXT = 7
+ FINGERPRINT = 8
+ NAME = 9
+ SERDE = 10
+
+ FIELDS = {
+ SCHEMA => {:type => ::Thrift::Types::STRUCT, :name => 'schema', :class => ::ISchemaName},
+ VERSION => {:type => ::Thrift::Types::I32, :name => 'version'},
+ CREATEDAT => {:type => ::Thrift::Types::I64, :name => 'createdAt'},
+ COLS => {:type => ::Thrift::Types::LIST, :name => 'cols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::FieldSchema}},
+ STATE => {:type => ::Thrift::Types::I32, :name => 'state', :optional => true, :enum_class => ::SchemaVersionState},
+ DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description', :optional => true},
+ SCHEMATEXT => {:type => ::Thrift::Types::STRING, :name => 'schemaText', :optional => true},
+ FINGERPRINT => {:type => ::Thrift::Types::STRING, :name => 'fingerprint', :optional => true},
+ NAME => {:type => ::Thrift::Types::STRING, :name => 'name', :optional => true},
+ SERDE => {:type => ::Thrift::Types::STRUCT, :name => 'serDe', :class => ::SerDeInfo, :optional => true}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ unless @state.nil? || ::SchemaVersionState::VALID_VALUES.include?(@state)
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!')
+ end
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class SchemaVersionDescriptor
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMA = 1
+ VERSION = 2
+
+ FIELDS = {
+ SCHEMA => {:type => ::Thrift::Types::STRUCT, :name => 'schema', :class => ::ISchemaName},
+ VERSION => {:type => ::Thrift::Types::I32, :name => 'version'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class FindSchemasByColsRqst
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ COLNAME = 1
+ COLNAMESPACE = 2
+ TYPE = 3
+
+ FIELDS = {
+ COLNAME => {:type => ::Thrift::Types::STRING, :name => 'colName', :optional => true},
+ COLNAMESPACE => {:type => ::Thrift::Types::STRING, :name => 'colNamespace', :optional => true},
+ TYPE => {:type => ::Thrift::Types::STRING, :name => 'type', :optional => true}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class FindSchemasByColsResp
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMAVERSIONS = 1
+
+ FIELDS = {
+ SCHEMAVERSIONS => {:type => ::Thrift::Types::LIST, :name => 'schemaVersions', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SchemaVersionDescriptor}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class MapSchemaVersionToSerdeRequest
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMAVERSION = 1
+ SERDENAME = 2
+
+ FIELDS = {
+ SCHEMAVERSION => {:type => ::Thrift::Types::STRUCT, :name => 'schemaVersion', :class => ::SchemaVersionDescriptor},
+ SERDENAME => {:type => ::Thrift::Types::STRING, :name => 'serdeName'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class SetSchemaVersionStateRequest
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMAVERSION = 1
+ STATE = 2
+
+ FIELDS = {
+ SCHEMAVERSION => {:type => ::Thrift::Types::STRUCT, :name => 'schemaVersion', :class => ::SchemaVersionDescriptor},
+ STATE => {:type => ::Thrift::Types::I32, :name => 'state', :enum_class => ::SchemaVersionState}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ unless @state.nil? || ::SchemaVersionState::VALID_VALUES.include?(@state)
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Invalid value of field state!')
+ end
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class GetSerdeRequest
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SERDENAME = 1
+
+ FIELDS = {
+ SERDENAME => {:type => ::Thrift::Types::STRING, :name => 'serdeName'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
class MetaException < ::Thrift::Exception
include ::Thrift::Struct, ::Thrift::Struct_Union
def initialize(message=nil)
http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb b/standalone-metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
index 4990fed..e6787c1 100644
--- a/standalone-metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
+++ b/standalone-metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
@@ -3015,6 +3015,239 @@ module ThriftHiveMetastore
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'create_or_drop_wm_trigger_to_pool_mapping failed: unknown result')
end
+ def create_ischema(schema)
+ send_create_ischema(schema)
+ recv_create_ischema()
+ end
+
+ def send_create_ischema(schema)
+ send_message('create_ischema', Create_ischema_args, :schema => schema)
+ end
+
+ def recv_create_ischema()
+ result = receive_message(Create_ischema_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise result.o3 unless result.o3.nil?
+ return
+ end
+
+ def alter_ischema(rqst)
+ send_alter_ischema(rqst)
+ recv_alter_ischema()
+ end
+
+ def send_alter_ischema(rqst)
+ send_message('alter_ischema', Alter_ischema_args, :rqst => rqst)
+ end
+
+ def recv_alter_ischema()
+ result = receive_message(Alter_ischema_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ return
+ end
+
+ def get_ischema(name)
+ send_get_ischema(name)
+ return recv_get_ischema()
+ end
+
+ def send_get_ischema(name)
+ send_message('get_ischema', Get_ischema_args, :name => name)
+ end
+
+ def recv_get_ischema()
+ result = receive_message(Get_ischema_result)
+ return result.success unless result.success.nil?
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_ischema failed: unknown result')
+ end
+
+ def drop_ischema(name)
+ send_drop_ischema(name)
+ recv_drop_ischema()
+ end
+
+ def send_drop_ischema(name)
+ send_message('drop_ischema', Drop_ischema_args, :name => name)
+ end
+
+ def recv_drop_ischema()
+ result = receive_message(Drop_ischema_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise result.o3 unless result.o3.nil?
+ return
+ end
+
+ def add_schema_version(schemaVersion)
+ send_add_schema_version(schemaVersion)
+ recv_add_schema_version()
+ end
+
+ def send_add_schema_version(schemaVersion)
+ send_message('add_schema_version', Add_schema_version_args, :schemaVersion => schemaVersion)
+ end
+
+ def recv_add_schema_version()
+ result = receive_message(Add_schema_version_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise result.o3 unless result.o3.nil?
+ return
+ end
+
+ def get_schema_version(schemaVersion)
+ send_get_schema_version(schemaVersion)
+ return recv_get_schema_version()
+ end
+
+ def send_get_schema_version(schemaVersion)
+ send_message('get_schema_version', Get_schema_version_args, :schemaVersion => schemaVersion)
+ end
+
+ def recv_get_schema_version()
+ result = receive_message(Get_schema_version_result)
+ return result.success unless result.success.nil?
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_schema_version failed: unknown result')
+ end
+
+ def get_schema_latest_version(schemaName)
+ send_get_schema_latest_version(schemaName)
+ return recv_get_schema_latest_version()
+ end
+
+ def send_get_schema_latest_version(schemaName)
+ send_message('get_schema_latest_version', Get_schema_latest_version_args, :schemaName => schemaName)
+ end
+
+ def recv_get_schema_latest_version()
+ result = receive_message(Get_schema_latest_version_result)
+ return result.success unless result.success.nil?
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_schema_latest_version failed: unknown result')
+ end
+
+ def get_schema_all_versions(schemaName)
+ send_get_schema_all_versions(schemaName)
+ return recv_get_schema_all_versions()
+ end
+
+ def send_get_schema_all_versions(schemaName)
+ send_message('get_schema_all_versions', Get_schema_all_versions_args, :schemaName => schemaName)
+ end
+
+ def recv_get_schema_all_versions()
+ result = receive_message(Get_schema_all_versions_result)
+ return result.success unless result.success.nil?
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_schema_all_versions failed: unknown result')
+ end
+
+ def drop_schema_version(schemaVersion)
+ send_drop_schema_version(schemaVersion)
+ recv_drop_schema_version()
+ end
+
+ def send_drop_schema_version(schemaVersion)
+ send_message('drop_schema_version', Drop_schema_version_args, :schemaVersion => schemaVersion)
+ end
+
+ def recv_drop_schema_version()
+ result = receive_message(Drop_schema_version_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ return
+ end
+
+ def get_schemas_by_cols(rqst)
+ send_get_schemas_by_cols(rqst)
+ return recv_get_schemas_by_cols()
+ end
+
+ def send_get_schemas_by_cols(rqst)
+ send_message('get_schemas_by_cols', Get_schemas_by_cols_args, :rqst => rqst)
+ end
+
+ def recv_get_schemas_by_cols()
+ result = receive_message(Get_schemas_by_cols_result)
+ return result.success unless result.success.nil?
+ raise result.o1 unless result.o1.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_schemas_by_cols failed: unknown result')
+ end
+
+ def map_schema_version_to_serde(rqst)
+ send_map_schema_version_to_serde(rqst)
+ recv_map_schema_version_to_serde()
+ end
+
+ def send_map_schema_version_to_serde(rqst)
+ send_message('map_schema_version_to_serde', Map_schema_version_to_serde_args, :rqst => rqst)
+ end
+
+ def recv_map_schema_version_to_serde()
+ result = receive_message(Map_schema_version_to_serde_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ return
+ end
+
+ def set_schema_version_state(rqst)
+ send_set_schema_version_state(rqst)
+ recv_set_schema_version_state()
+ end
+
+ def send_set_schema_version_state(rqst)
+ send_message('set_schema_version_state', Set_schema_version_state_args, :rqst => rqst)
+ end
+
+ def recv_set_schema_version_state()
+ result = receive_message(Set_schema_version_state_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise result.o3 unless result.o3.nil?
+ return
+ end
+
+ def add_serde(serde)
+ send_add_serde(serde)
+ recv_add_serde()
+ end
+
+ def send_add_serde(serde)
+ send_message('add_serde', Add_serde_args, :serde => serde)
+ end
+
+ def recv_add_serde()
+ result = receive_message(Add_serde_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ return
+ end
+
+ def get_serde(rqst)
+ send_get_serde(rqst)
+ return recv_get_serde()
+ end
+
+ def send_get_serde(rqst)
+ send_message('get_serde', Get_serde_args, :rqst => rqst)
+ end
+
+ def recv_get_serde()
+ result = receive_message(Get_serde_result)
+ return result.success unless result.success.nil?
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'get_serde failed: unknown result')
+ end
+
end
class Processor < ::FacebookService::Processor
@@ -5274,6 +5507,194 @@ module ThriftHiveMetastore
write_result(result, oprot, 'create_or_drop_wm_trigger_to_pool_mapping', seqid)
end
+ def process_create_ischema(seqid, iprot, oprot)
+ args = read_args(iprot, Create_ischema_args)
+ result = Create_ischema_result.new()
+ begin
+ @handler.create_ischema(args.schema)
+ rescue ::AlreadyExistsException => o1
+ result.o1 = o1
+ rescue ::NoSuchObjectException => o2
+ result.o2 = o2
+ rescue ::MetaException => o3
+ result.o3 = o3
+ end
+ write_result(result, oprot, 'create_ischema', seqid)
+ end
+
+ def process_alter_ischema(seqid, iprot, oprot)
+ args = read_args(iprot, Alter_ischema_args)
+ result = Alter_ischema_result.new()
+ begin
+ @handler.alter_ischema(args.rqst)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'alter_ischema', seqid)
+ end
+
+ def process_get_ischema(seqid, iprot, oprot)
+ args = read_args(iprot, Get_ischema_args)
+ result = Get_ischema_result.new()
+ begin
+ result.success = @handler.get_ischema(args.name)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'get_ischema', seqid)
+ end
+
+ def process_drop_ischema(seqid, iprot, oprot)
+ args = read_args(iprot, Drop_ischema_args)
+ result = Drop_ischema_result.new()
+ begin
+ @handler.drop_ischema(args.name)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::InvalidOperationException => o2
+ result.o2 = o2
+ rescue ::MetaException => o3
+ result.o3 = o3
+ end
+ write_result(result, oprot, 'drop_ischema', seqid)
+ end
+
+ def process_add_schema_version(seqid, iprot, oprot)
+ args = read_args(iprot, Add_schema_version_args)
+ result = Add_schema_version_result.new()
+ begin
+ @handler.add_schema_version(args.schemaVersion)
+ rescue ::AlreadyExistsException => o1
+ result.o1 = o1
+ rescue ::NoSuchObjectException => o2
+ result.o2 = o2
+ rescue ::MetaException => o3
+ result.o3 = o3
+ end
+ write_result(result, oprot, 'add_schema_version', seqid)
+ end
+
+ def process_get_schema_version(seqid, iprot, oprot)
+ args = read_args(iprot, Get_schema_version_args)
+ result = Get_schema_version_result.new()
+ begin
+ result.success = @handler.get_schema_version(args.schemaVersion)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'get_schema_version', seqid)
+ end
+
+ def process_get_schema_latest_version(seqid, iprot, oprot)
+ args = read_args(iprot, Get_schema_latest_version_args)
+ result = Get_schema_latest_version_result.new()
+ begin
+ result.success = @handler.get_schema_latest_version(args.schemaName)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'get_schema_latest_version', seqid)
+ end
+
+ def process_get_schema_all_versions(seqid, iprot, oprot)
+ args = read_args(iprot, Get_schema_all_versions_args)
+ result = Get_schema_all_versions_result.new()
+ begin
+ result.success = @handler.get_schema_all_versions(args.schemaName)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'get_schema_all_versions', seqid)
+ end
+
+ def process_drop_schema_version(seqid, iprot, oprot)
+ args = read_args(iprot, Drop_schema_version_args)
+ result = Drop_schema_version_result.new()
+ begin
+ @handler.drop_schema_version(args.schemaVersion)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'drop_schema_version', seqid)
+ end
+
+ def process_get_schemas_by_cols(seqid, iprot, oprot)
+ args = read_args(iprot, Get_schemas_by_cols_args)
+ result = Get_schemas_by_cols_result.new()
+ begin
+ result.success = @handler.get_schemas_by_cols(args.rqst)
+ rescue ::MetaException => o1
+ result.o1 = o1
+ end
+ write_result(result, oprot, 'get_schemas_by_cols', seqid)
+ end
+
+ def process_map_schema_version_to_serde(seqid, iprot, oprot)
+ args = read_args(iprot, Map_schema_version_to_serde_args)
+ result = Map_schema_version_to_serde_result.new()
+ begin
+ @handler.map_schema_version_to_serde(args.rqst)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'map_schema_version_to_serde', seqid)
+ end
+
+ def process_set_schema_version_state(seqid, iprot, oprot)
+ args = read_args(iprot, Set_schema_version_state_args)
+ result = Set_schema_version_state_result.new()
+ begin
+ @handler.set_schema_version_state(args.rqst)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::InvalidOperationException => o2
+ result.o2 = o2
+ rescue ::MetaException => o3
+ result.o3 = o3
+ end
+ write_result(result, oprot, 'set_schema_version_state', seqid)
+ end
+
+ def process_add_serde(seqid, iprot, oprot)
+ args = read_args(iprot, Add_serde_args)
+ result = Add_serde_result.new()
+ begin
+ @handler.add_serde(args.serde)
+ rescue ::AlreadyExistsException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'add_serde', seqid)
+ end
+
+ def process_get_serde(seqid, iprot, oprot)
+ args = read_args(iprot, Get_serde_args)
+ result = Get_serde_result.new()
+ begin
+ result.success = @handler.get_serde(args.rqst)
+ rescue ::NoSuchObjectException => o1
+ result.o1 = o1
+ rescue ::MetaException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'get_serde', seqid)
+ end
+
end
# HELPER FUNCTIONS AND STRUCTURES
@@ -11991,5 +12412,499 @@ module ThriftHiveMetastore
::Thrift::Struct.generate_accessors self
end
+ class Create_ischema_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMA = 1
+
+ FIELDS = {
+ SCHEMA => {:type => ::Thrift::Types::STRUCT, :name => 'schema', :class => ::ISchema}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Create_ischema_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = -1
+ O3 = 3
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::AlreadyExistsException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::NoSuchObjectException},
+ O3 => {:type => ::Thrift::Types::STRUCT, :name => 'o3', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Alter_ischema_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ RQST = 1
+
+ FIELDS = {
+ RQST => {:type => ::Thrift::Types::STRUCT, :name => 'rqst', :class => ::AlterISchemaRequest}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Alter_ischema_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_ischema_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ NAME = 1
+
+ FIELDS = {
+ NAME => {:type => ::Thrift::Types::STRUCT, :name => 'name', :class => ::ISchemaName}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_ischema_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::ISchema},
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Drop_ischema_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ NAME = 1
+
+ FIELDS = {
+ NAME => {:type => ::Thrift::Types::STRUCT, :name => 'name', :class => ::ISchemaName}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Drop_ischema_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = 2
+ O3 = 3
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::InvalidOperationException},
+ O3 => {:type => ::Thrift::Types::STRUCT, :name => 'o3', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Add_schema_version_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMAVERSION = 1
+
+ FIELDS = {
+ SCHEMAVERSION => {:type => ::Thrift::Types::STRUCT, :name => 'schemaVersion', :class => ::SchemaVersion}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Add_schema_version_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = 2
+ O3 = 3
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::AlreadyExistsException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::NoSuchObjectException},
+ O3 => {:type => ::Thrift::Types::STRUCT, :name => 'o3', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_schema_version_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMAVERSION = 1
+
+ FIELDS = {
+ SCHEMAVERSION => {:type => ::Thrift::Types::STRUCT, :name => 'schemaVersion', :class => ::SchemaVersionDescriptor}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_schema_version_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::SchemaVersion},
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_schema_latest_version_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMANAME = 1
+
+ FIELDS = {
+ SCHEMANAME => {:type => ::Thrift::Types::STRUCT, :name => 'schemaName', :class => ::ISchemaName}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_schema_latest_version_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::SchemaVersion},
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_schema_all_versions_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMANAME = 1
+
+ FIELDS = {
+ SCHEMANAME => {:type => ::Thrift::Types::STRUCT, :name => 'schemaName', :class => ::ISchemaName}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_schema_all_versions_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::LIST, :name => 'success', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SchemaVersion}},
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Drop_schema_version_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SCHEMAVERSION = 1
+
+ FIELDS = {
+ SCHEMAVERSION => {:type => ::Thrift::Types::STRUCT, :name => 'schemaVersion', :class => ::SchemaVersionDescriptor}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Drop_schema_version_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_schemas_by_cols_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ RQST = 1
+
+ FIELDS = {
+ RQST => {:type => ::Thrift::Types::STRUCT, :name => 'rqst', :class => ::FindSchemasByColsRqst}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_schemas_by_cols_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+ O1 = 1
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::FindSchemasByColsResp},
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Map_schema_version_to_serde_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ RQST = 1
+
+ FIELDS = {
+ RQST => {:type => ::Thrift::Types::STRUCT, :name => 'rqst', :class => ::MapSchemaVersionToSerdeRequest}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Map_schema_version_to_serde_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Set_schema_version_state_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ RQST = 1
+
+ FIELDS = {
+ RQST => {:type => ::Thrift::Types::STRUCT, :name => 'rqst', :class => ::SetSchemaVersionStateRequest}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Set_schema_version_state_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = 2
+ O3 = 3
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::InvalidOperationException},
+ O3 => {:type => ::Thrift::Types::STRUCT, :name => 'o3', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Add_serde_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SERDE = 1
+
+ FIELDS = {
+ SERDE => {:type => ::Thrift::Types::STRUCT, :name => 'serde', :class => ::SerDeInfo}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Add_serde_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::AlreadyExistsException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_serde_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ RQST = 1
+
+ FIELDS = {
+ RQST => {:type => ::Thrift::Types::STRUCT, :name => 'rqst', :class => ::GetSerdeRequest}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Get_serde_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ SUCCESS = 0
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ SUCCESS => {:type => ::Thrift::Types::STRUCT, :name => 'success', :class => ::SerDeInfo},
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchObjectException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::MetaException}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
end