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