You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by nz...@apache.org on 2010/12/09 19:31:09 UTC
svn commit: r1044070 [15/29] - in /hive/trunk: ./ eclipse-templates/ ivy/
lib/ metastore/ metastore/if/ metastore/src/gen-cpp/
metastore/src/gen-javabean/org/apache/hadoop/hive/metastore/api/
metastore/src/gen-php/ metastore/src/gen-py/hive_metastore/ ...
Added: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/__init__.py
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/__init__.py?rev=1044070&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/__init__.py (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/__init__.py Thu Dec 9 18:30:58 2010
@@ -0,0 +1 @@
+__all__ = ['ttypes', 'constants', 'ThriftHiveMetastore']
Added: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py?rev=1044070&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/constants.py Thu Dec 9 18:30:58 2010
@@ -0,0 +1,25 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+from thrift.Thrift import *
+from ttypes import *
+
+DDL_TIME = "transient_lastDdlTime"
+IS_ARCHIVED = "is_archived"
+ORIGINAL_LOCATION = "original_location"
+META_TABLE_COLUMNS = "columns"
+META_TABLE_COLUMN_TYPES = "columns.types"
+BUCKET_FIELD_NAME = "bucket_field_name"
+BUCKET_COUNT = "bucket_count"
+FIELD_TO_DIMENSION = "field_to_dimension"
+META_TABLE_NAME = "name"
+META_TABLE_DB = "db"
+META_TABLE_LOCATION = "location"
+META_TABLE_SERDE = "serde"
+META_TABLE_PARTITION_COLUMNS = "partition_columns"
+FILE_INPUT_FORMAT = "file.inputformat"
+FILE_OUTPUT_FORMAT = "file.outputformat"
+META_TABLE_STORAGE = "storage_handler"
Added: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py?rev=1044070&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py Thu Dec 9 18:30:58 2010
@@ -0,0 +1,1936 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+from thrift.Thrift import *
+import fb303.ttypes
+
+
+from thrift.transport import TTransport
+from thrift.protocol import TBinaryProtocol, TProtocol
+try:
+ from thrift.protocol import fastbinary
+except:
+ fastbinary = None
+
+
+
+class Version:
+ """
+ Attributes:
+ - version
+ - comments
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'version', None, None, ), # 1
+ (2, TType.STRING, 'comments', None, None, ), # 2
+ )
+
+ def __init__(self, version=None, comments=None,):
+ self.version = version
+ self.comments = comments
+
+ 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.version = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.comments = 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('Version')
+ if self.version != None:
+ oprot.writeFieldBegin('version', TType.STRING, 1)
+ oprot.writeString(self.version)
+ oprot.writeFieldEnd()
+ if self.comments != None:
+ oprot.writeFieldBegin('comments', TType.STRING, 2)
+ oprot.writeString(self.comments)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 FieldSchema:
+ """
+ Attributes:
+ - name
+ - type
+ - comment
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.STRING, 'type', None, None, ), # 2
+ (3, TType.STRING, 'comment', None, None, ), # 3
+ )
+
+ def __init__(self, name=None, type=None, comment=None,):
+ self.name = name
+ self.type = type
+ self.comment = comment
+
+ 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.name = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.type = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.comment = 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('FieldSchema')
+ if self.name != None:
+ oprot.writeFieldBegin('name', TType.STRING, 1)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ if self.type != None:
+ oprot.writeFieldBegin('type', TType.STRING, 2)
+ oprot.writeString(self.type)
+ oprot.writeFieldEnd()
+ if self.comment != None:
+ oprot.writeFieldBegin('comment', TType.STRING, 3)
+ oprot.writeString(self.comment)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 Type:
+ """
+ Attributes:
+ - name
+ - type1
+ - type2
+ - fields
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.STRING, 'type1', None, None, ), # 2
+ (3, TType.STRING, 'type2', None, None, ), # 3
+ (4, TType.LIST, 'fields', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 4
+ )
+
+ def __init__(self, name=None, type1=None, type2=None, fields=None,):
+ self.name = name
+ self.type1 = type1
+ self.type2 = type2
+ self.fields = fields
+
+ 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.name = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.type1 = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.type2 = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.LIST:
+ self.fields = []
+ (_etype3, _size0) = iprot.readListBegin()
+ for _i4 in xrange(_size0):
+ _elem5 = FieldSchema()
+ _elem5.read(iprot)
+ self.fields.append(_elem5)
+ 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('Type')
+ if self.name != None:
+ oprot.writeFieldBegin('name', TType.STRING, 1)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ if self.type1 != None:
+ oprot.writeFieldBegin('type1', TType.STRING, 2)
+ oprot.writeString(self.type1)
+ oprot.writeFieldEnd()
+ if self.type2 != None:
+ oprot.writeFieldBegin('type2', TType.STRING, 3)
+ oprot.writeString(self.type2)
+ oprot.writeFieldEnd()
+ if self.fields != None:
+ oprot.writeFieldBegin('fields', TType.LIST, 4)
+ oprot.writeListBegin(TType.STRUCT, len(self.fields))
+ for iter6 in self.fields:
+ iter6.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 Database:
+ """
+ Attributes:
+ - name
+ - description
+ - locationUri
+ - parameters
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.STRING, 'description', None, None, ), # 2
+ (3, TType.STRING, 'locationUri', None, None, ), # 3
+ (4, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 4
+ )
+
+ def __init__(self, name=None, description=None, locationUri=None, parameters=None,):
+ self.name = name
+ self.description = description
+ self.locationUri = locationUri
+ self.parameters = parameters
+
+ 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.name = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.description = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.locationUri = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.MAP:
+ self.parameters = {}
+ (_ktype8, _vtype9, _size7 ) = iprot.readMapBegin()
+ for _i11 in xrange(_size7):
+ _key12 = iprot.readString();
+ _val13 = iprot.readString();
+ self.parameters[_key12] = _val13
+ iprot.readMapEnd()
+ 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('Database')
+ if self.name != None:
+ oprot.writeFieldBegin('name', TType.STRING, 1)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ if self.description != None:
+ oprot.writeFieldBegin('description', TType.STRING, 2)
+ oprot.writeString(self.description)
+ oprot.writeFieldEnd()
+ if self.locationUri != None:
+ oprot.writeFieldBegin('locationUri', TType.STRING, 3)
+ oprot.writeString(self.locationUri)
+ oprot.writeFieldEnd()
+ if self.parameters != None:
+ oprot.writeFieldBegin('parameters', TType.MAP, 4)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
+ for kiter14,viter15 in self.parameters.items():
+ oprot.writeString(kiter14)
+ oprot.writeString(viter15)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 SerDeInfo:
+ """
+ Attributes:
+ - name
+ - serializationLib
+ - parameters
+ """
+
+ thrift_spec = (
+ None, # 0
+ (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
+ )
+
+ def __init__(self, name=None, serializationLib=None, parameters=None,):
+ self.name = name
+ self.serializationLib = serializationLib
+ self.parameters = parameters
+
+ 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.name = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.serializationLib = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.MAP:
+ self.parameters = {}
+ (_ktype17, _vtype18, _size16 ) = iprot.readMapBegin()
+ for _i20 in xrange(_size16):
+ _key21 = iprot.readString();
+ _val22 = iprot.readString();
+ self.parameters[_key21] = _val22
+ iprot.readMapEnd()
+ 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('SerDeInfo')
+ if self.name != None:
+ oprot.writeFieldBegin('name', TType.STRING, 1)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ if self.serializationLib != None:
+ oprot.writeFieldBegin('serializationLib', TType.STRING, 2)
+ oprot.writeString(self.serializationLib)
+ oprot.writeFieldEnd()
+ if self.parameters != None:
+ oprot.writeFieldBegin('parameters', TType.MAP, 3)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
+ for kiter23,viter24 in self.parameters.items():
+ oprot.writeString(kiter23)
+ oprot.writeString(viter24)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 Order:
+ """
+ Attributes:
+ - col
+ - order
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'col', None, None, ), # 1
+ (2, TType.I32, 'order', None, None, ), # 2
+ )
+
+ def __init__(self, col=None, order=None,):
+ self.col = col
+ self.order = order
+
+ 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.col = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.order = 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('Order')
+ if self.col != None:
+ oprot.writeFieldBegin('col', TType.STRING, 1)
+ oprot.writeString(self.col)
+ oprot.writeFieldEnd()
+ if self.order != None:
+ oprot.writeFieldBegin('order', TType.I32, 2)
+ oprot.writeI32(self.order)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 StorageDescriptor:
+ """
+ Attributes:
+ - cols
+ - location
+ - inputFormat
+ - outputFormat
+ - compressed
+ - numBuckets
+ - serdeInfo
+ - bucketCols
+ - sortCols
+ - parameters
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'cols', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 1
+ (2, TType.STRING, 'location', None, None, ), # 2
+ (3, TType.STRING, 'inputFormat', None, None, ), # 3
+ (4, TType.STRING, 'outputFormat', None, None, ), # 4
+ (5, TType.BOOL, 'compressed', None, None, ), # 5
+ (6, TType.I32, 'numBuckets', None, None, ), # 6
+ (7, TType.STRUCT, 'serdeInfo', (SerDeInfo, SerDeInfo.thrift_spec), None, ), # 7
+ (8, TType.LIST, 'bucketCols', (TType.STRING,None), None, ), # 8
+ (9, TType.LIST, 'sortCols', (TType.STRUCT,(Order, Order.thrift_spec)), None, ), # 9
+ (10, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 10
+ )
+
+ def __init__(self, cols=None, location=None, inputFormat=None, outputFormat=None, compressed=None, numBuckets=None, serdeInfo=None, bucketCols=None, sortCols=None, parameters=None,):
+ self.cols = cols
+ self.location = location
+ self.inputFormat = inputFormat
+ self.outputFormat = outputFormat
+ self.compressed = compressed
+ self.numBuckets = numBuckets
+ self.serdeInfo = serdeInfo
+ self.bucketCols = bucketCols
+ self.sortCols = sortCols
+ self.parameters = parameters
+
+ 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.cols = []
+ (_etype28, _size25) = iprot.readListBegin()
+ for _i29 in xrange(_size25):
+ _elem30 = FieldSchema()
+ _elem30.read(iprot)
+ self.cols.append(_elem30)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.location = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.inputFormat = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.outputFormat = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.BOOL:
+ self.compressed = iprot.readBool();
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.I32:
+ self.numBuckets = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRUCT:
+ self.serdeInfo = SerDeInfo()
+ self.serdeInfo.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.LIST:
+ self.bucketCols = []
+ (_etype34, _size31) = iprot.readListBegin()
+ for _i35 in xrange(_size31):
+ _elem36 = iprot.readString();
+ self.bucketCols.append(_elem36)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.LIST:
+ self.sortCols = []
+ (_etype40, _size37) = iprot.readListBegin()
+ for _i41 in xrange(_size37):
+ _elem42 = Order()
+ _elem42.read(iprot)
+ self.sortCols.append(_elem42)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 10:
+ if ftype == TType.MAP:
+ self.parameters = {}
+ (_ktype44, _vtype45, _size43 ) = iprot.readMapBegin()
+ for _i47 in xrange(_size43):
+ _key48 = iprot.readString();
+ _val49 = iprot.readString();
+ self.parameters[_key48] = _val49
+ iprot.readMapEnd()
+ 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('StorageDescriptor')
+ if self.cols != None:
+ oprot.writeFieldBegin('cols', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.cols))
+ for iter50 in self.cols:
+ iter50.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.location != None:
+ oprot.writeFieldBegin('location', TType.STRING, 2)
+ oprot.writeString(self.location)
+ oprot.writeFieldEnd()
+ if self.inputFormat != None:
+ oprot.writeFieldBegin('inputFormat', TType.STRING, 3)
+ oprot.writeString(self.inputFormat)
+ oprot.writeFieldEnd()
+ if self.outputFormat != None:
+ oprot.writeFieldBegin('outputFormat', TType.STRING, 4)
+ oprot.writeString(self.outputFormat)
+ oprot.writeFieldEnd()
+ if self.compressed != None:
+ oprot.writeFieldBegin('compressed', TType.BOOL, 5)
+ oprot.writeBool(self.compressed)
+ oprot.writeFieldEnd()
+ if self.numBuckets != None:
+ oprot.writeFieldBegin('numBuckets', TType.I32, 6)
+ oprot.writeI32(self.numBuckets)
+ oprot.writeFieldEnd()
+ if self.serdeInfo != None:
+ oprot.writeFieldBegin('serdeInfo', TType.STRUCT, 7)
+ self.serdeInfo.write(oprot)
+ oprot.writeFieldEnd()
+ if self.bucketCols != None:
+ oprot.writeFieldBegin('bucketCols', TType.LIST, 8)
+ oprot.writeListBegin(TType.STRING, len(self.bucketCols))
+ for iter51 in self.bucketCols:
+ oprot.writeString(iter51)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.sortCols != None:
+ oprot.writeFieldBegin('sortCols', TType.LIST, 9)
+ oprot.writeListBegin(TType.STRUCT, len(self.sortCols))
+ for iter52 in self.sortCols:
+ iter52.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.parameters != None:
+ oprot.writeFieldBegin('parameters', TType.MAP, 10)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
+ for kiter53,viter54 in self.parameters.items():
+ oprot.writeString(kiter53)
+ oprot.writeString(viter54)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 Table:
+ """
+ Attributes:
+ - tableName
+ - dbName
+ - owner
+ - createTime
+ - lastAccessTime
+ - retention
+ - sd
+ - partitionKeys
+ - parameters
+ - viewOriginalText
+ - viewExpandedText
+ - tableType
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'tableName', None, None, ), # 1
+ (2, TType.STRING, 'dbName', None, None, ), # 2
+ (3, TType.STRING, 'owner', None, None, ), # 3
+ (4, TType.I32, 'createTime', None, None, ), # 4
+ (5, TType.I32, 'lastAccessTime', None, None, ), # 5
+ (6, TType.I32, 'retention', None, None, ), # 6
+ (7, TType.STRUCT, 'sd', (StorageDescriptor, StorageDescriptor.thrift_spec), None, ), # 7
+ (8, TType.LIST, 'partitionKeys', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 8
+ (9, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 9
+ (10, TType.STRING, 'viewOriginalText', None, None, ), # 10
+ (11, TType.STRING, 'viewExpandedText', None, None, ), # 11
+ (12, TType.STRING, 'tableType', None, None, ), # 12
+ )
+
+ def __init__(self, tableName=None, dbName=None, owner=None, createTime=None, lastAccessTime=None, retention=None, sd=None, partitionKeys=None, parameters=None, viewOriginalText=None, viewExpandedText=None, tableType=None,):
+ self.tableName = tableName
+ self.dbName = dbName
+ self.owner = owner
+ self.createTime = createTime
+ self.lastAccessTime = lastAccessTime
+ self.retention = retention
+ self.sd = sd
+ self.partitionKeys = partitionKeys
+ self.parameters = parameters
+ self.viewOriginalText = viewOriginalText
+ self.viewExpandedText = viewExpandedText
+ self.tableType = tableType
+
+ 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.tableName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.dbName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.owner = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I32:
+ self.createTime = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I32:
+ self.lastAccessTime = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.I32:
+ self.retention = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRUCT:
+ self.sd = StorageDescriptor()
+ self.sd.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.LIST:
+ self.partitionKeys = []
+ (_etype58, _size55) = iprot.readListBegin()
+ for _i59 in xrange(_size55):
+ _elem60 = FieldSchema()
+ _elem60.read(iprot)
+ self.partitionKeys.append(_elem60)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.MAP:
+ self.parameters = {}
+ (_ktype62, _vtype63, _size61 ) = iprot.readMapBegin()
+ for _i65 in xrange(_size61):
+ _key66 = iprot.readString();
+ _val67 = iprot.readString();
+ self.parameters[_key66] = _val67
+ iprot.readMapEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 10:
+ if ftype == TType.STRING:
+ self.viewOriginalText = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 11:
+ if ftype == TType.STRING:
+ self.viewExpandedText = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 12:
+ if ftype == TType.STRING:
+ self.tableType = 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('Table')
+ if self.tableName != None:
+ oprot.writeFieldBegin('tableName', TType.STRING, 1)
+ oprot.writeString(self.tableName)
+ oprot.writeFieldEnd()
+ if self.dbName != None:
+ oprot.writeFieldBegin('dbName', TType.STRING, 2)
+ oprot.writeString(self.dbName)
+ oprot.writeFieldEnd()
+ if self.owner != None:
+ oprot.writeFieldBegin('owner', TType.STRING, 3)
+ oprot.writeString(self.owner)
+ oprot.writeFieldEnd()
+ if self.createTime != None:
+ oprot.writeFieldBegin('createTime', TType.I32, 4)
+ oprot.writeI32(self.createTime)
+ oprot.writeFieldEnd()
+ if self.lastAccessTime != None:
+ oprot.writeFieldBegin('lastAccessTime', TType.I32, 5)
+ oprot.writeI32(self.lastAccessTime)
+ oprot.writeFieldEnd()
+ if self.retention != None:
+ oprot.writeFieldBegin('retention', TType.I32, 6)
+ oprot.writeI32(self.retention)
+ oprot.writeFieldEnd()
+ if self.sd != None:
+ oprot.writeFieldBegin('sd', TType.STRUCT, 7)
+ self.sd.write(oprot)
+ oprot.writeFieldEnd()
+ if self.partitionKeys != None:
+ oprot.writeFieldBegin('partitionKeys', TType.LIST, 8)
+ oprot.writeListBegin(TType.STRUCT, len(self.partitionKeys))
+ for iter68 in self.partitionKeys:
+ iter68.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.parameters != None:
+ oprot.writeFieldBegin('parameters', TType.MAP, 9)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
+ for kiter69,viter70 in self.parameters.items():
+ oprot.writeString(kiter69)
+ oprot.writeString(viter70)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ if self.viewOriginalText != None:
+ oprot.writeFieldBegin('viewOriginalText', TType.STRING, 10)
+ oprot.writeString(self.viewOriginalText)
+ oprot.writeFieldEnd()
+ if self.viewExpandedText != None:
+ oprot.writeFieldBegin('viewExpandedText', TType.STRING, 11)
+ oprot.writeString(self.viewExpandedText)
+ oprot.writeFieldEnd()
+ if self.tableType != None:
+ oprot.writeFieldBegin('tableType', TType.STRING, 12)
+ oprot.writeString(self.tableType)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 Partition:
+ """
+ Attributes:
+ - values
+ - dbName
+ - tableName
+ - createTime
+ - lastAccessTime
+ - sd
+ - parameters
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'values', (TType.STRING,None), None, ), # 1
+ (2, TType.STRING, 'dbName', None, None, ), # 2
+ (3, TType.STRING, 'tableName', None, None, ), # 3
+ (4, TType.I32, 'createTime', None, None, ), # 4
+ (5, TType.I32, 'lastAccessTime', None, None, ), # 5
+ (6, TType.STRUCT, 'sd', (StorageDescriptor, StorageDescriptor.thrift_spec), None, ), # 6
+ (7, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 7
+ )
+
+ def __init__(self, values=None, dbName=None, tableName=None, createTime=None, lastAccessTime=None, sd=None, parameters=None,):
+ self.values = values
+ self.dbName = dbName
+ self.tableName = tableName
+ self.createTime = createTime
+ self.lastAccessTime = lastAccessTime
+ self.sd = sd
+ self.parameters = parameters
+
+ 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.values = []
+ (_etype74, _size71) = iprot.readListBegin()
+ for _i75 in xrange(_size71):
+ _elem76 = iprot.readString();
+ self.values.append(_elem76)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.dbName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.tableName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.I32:
+ self.createTime = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I32:
+ self.lastAccessTime = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRUCT:
+ self.sd = StorageDescriptor()
+ self.sd.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.MAP:
+ self.parameters = {}
+ (_ktype78, _vtype79, _size77 ) = iprot.readMapBegin()
+ for _i81 in xrange(_size77):
+ _key82 = iprot.readString();
+ _val83 = iprot.readString();
+ self.parameters[_key82] = _val83
+ iprot.readMapEnd()
+ 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('Partition')
+ if self.values != None:
+ oprot.writeFieldBegin('values', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRING, len(self.values))
+ for iter84 in self.values:
+ oprot.writeString(iter84)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.dbName != None:
+ oprot.writeFieldBegin('dbName', TType.STRING, 2)
+ oprot.writeString(self.dbName)
+ oprot.writeFieldEnd()
+ if self.tableName != None:
+ oprot.writeFieldBegin('tableName', TType.STRING, 3)
+ oprot.writeString(self.tableName)
+ oprot.writeFieldEnd()
+ if self.createTime != None:
+ oprot.writeFieldBegin('createTime', TType.I32, 4)
+ oprot.writeI32(self.createTime)
+ oprot.writeFieldEnd()
+ if self.lastAccessTime != None:
+ oprot.writeFieldBegin('lastAccessTime', TType.I32, 5)
+ oprot.writeI32(self.lastAccessTime)
+ oprot.writeFieldEnd()
+ if self.sd != None:
+ oprot.writeFieldBegin('sd', TType.STRUCT, 6)
+ self.sd.write(oprot)
+ oprot.writeFieldEnd()
+ if self.parameters != None:
+ oprot.writeFieldBegin('parameters', TType.MAP, 7)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
+ for kiter85,viter86 in self.parameters.items():
+ oprot.writeString(kiter85)
+ oprot.writeString(viter86)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 Index:
+ """
+ Attributes:
+ - indexName
+ - indexHandlerClass
+ - dbName
+ - origTableName
+ - createTime
+ - lastAccessTime
+ - indexTableName
+ - sd
+ - parameters
+ - deferredRebuild
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'indexName', None, None, ), # 1
+ (2, TType.STRING, 'indexHandlerClass', None, None, ), # 2
+ (3, TType.STRING, 'dbName', None, None, ), # 3
+ (4, TType.STRING, 'origTableName', None, None, ), # 4
+ (5, TType.I32, 'createTime', None, None, ), # 5
+ (6, TType.I32, 'lastAccessTime', None, None, ), # 6
+ (7, TType.STRING, 'indexTableName', None, None, ), # 7
+ (8, TType.STRUCT, 'sd', (StorageDescriptor, StorageDescriptor.thrift_spec), None, ), # 8
+ (9, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 9
+ (10, TType.BOOL, 'deferredRebuild', None, None, ), # 10
+ )
+
+ def __init__(self, indexName=None, indexHandlerClass=None, dbName=None, origTableName=None, createTime=None, lastAccessTime=None, indexTableName=None, sd=None, parameters=None, deferredRebuild=None,):
+ self.indexName = indexName
+ self.indexHandlerClass = indexHandlerClass
+ self.dbName = dbName
+ self.origTableName = origTableName
+ self.createTime = createTime
+ self.lastAccessTime = lastAccessTime
+ self.indexTableName = indexTableName
+ self.sd = sd
+ self.parameters = parameters
+ self.deferredRebuild = deferredRebuild
+
+ 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.indexName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.indexHandlerClass = 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.STRING:
+ self.origTableName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I32:
+ self.createTime = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.I32:
+ self.lastAccessTime = iprot.readI32();
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.indexTableName = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRUCT:
+ self.sd = StorageDescriptor()
+ self.sd.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.MAP:
+ self.parameters = {}
+ (_ktype88, _vtype89, _size87 ) = iprot.readMapBegin()
+ for _i91 in xrange(_size87):
+ _key92 = iprot.readString();
+ _val93 = iprot.readString();
+ self.parameters[_key92] = _val93
+ iprot.readMapEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 10:
+ if ftype == TType.BOOL:
+ self.deferredRebuild = iprot.readBool();
+ 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('Index')
+ if self.indexName != None:
+ oprot.writeFieldBegin('indexName', TType.STRING, 1)
+ oprot.writeString(self.indexName)
+ oprot.writeFieldEnd()
+ if self.indexHandlerClass != None:
+ oprot.writeFieldBegin('indexHandlerClass', TType.STRING, 2)
+ oprot.writeString(self.indexHandlerClass)
+ oprot.writeFieldEnd()
+ if self.dbName != None:
+ oprot.writeFieldBegin('dbName', TType.STRING, 3)
+ oprot.writeString(self.dbName)
+ oprot.writeFieldEnd()
+ if self.origTableName != None:
+ oprot.writeFieldBegin('origTableName', TType.STRING, 4)
+ oprot.writeString(self.origTableName)
+ oprot.writeFieldEnd()
+ if self.createTime != None:
+ oprot.writeFieldBegin('createTime', TType.I32, 5)
+ oprot.writeI32(self.createTime)
+ oprot.writeFieldEnd()
+ if self.lastAccessTime != None:
+ oprot.writeFieldBegin('lastAccessTime', TType.I32, 6)
+ oprot.writeI32(self.lastAccessTime)
+ oprot.writeFieldEnd()
+ if self.indexTableName != None:
+ oprot.writeFieldBegin('indexTableName', TType.STRING, 7)
+ oprot.writeString(self.indexTableName)
+ oprot.writeFieldEnd()
+ if self.sd != None:
+ oprot.writeFieldBegin('sd', TType.STRUCT, 8)
+ self.sd.write(oprot)
+ oprot.writeFieldEnd()
+ if self.parameters != None:
+ oprot.writeFieldBegin('parameters', TType.MAP, 9)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.parameters))
+ for kiter94,viter95 in self.parameters.items():
+ oprot.writeString(kiter94)
+ oprot.writeString(viter95)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ if self.deferredRebuild != None:
+ oprot.writeFieldBegin('deferredRebuild', TType.BOOL, 10)
+ oprot.writeBool(self.deferredRebuild)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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 Schema:
+ """
+ Attributes:
+ - fieldSchemas
+ - properties
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'fieldSchemas', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 1
+ (2, TType.MAP, 'properties', (TType.STRING,None,TType.STRING,None), None, ), # 2
+ )
+
+ def __init__(self, fieldSchemas=None, properties=None,):
+ self.fieldSchemas = fieldSchemas
+ self.properties = properties
+
+ 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.fieldSchemas = []
+ (_etype99, _size96) = iprot.readListBegin()
+ for _i100 in xrange(_size96):
+ _elem101 = FieldSchema()
+ _elem101.read(iprot)
+ self.fieldSchemas.append(_elem101)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.MAP:
+ self.properties = {}
+ (_ktype103, _vtype104, _size102 ) = iprot.readMapBegin()
+ for _i106 in xrange(_size102):
+ _key107 = iprot.readString();
+ _val108 = iprot.readString();
+ self.properties[_key107] = _val108
+ iprot.readMapEnd()
+ 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('Schema')
+ if self.fieldSchemas != None:
+ oprot.writeFieldBegin('fieldSchemas', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.fieldSchemas))
+ for iter109 in self.fieldSchemas:
+ iter109.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.properties != None:
+ oprot.writeFieldBegin('properties', TType.MAP, 2)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties))
+ for kiter110,viter111 in self.properties.items():
+ oprot.writeString(kiter110)
+ oprot.writeString(viter111)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ 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(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('MetaException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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 UnknownTableException(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('UnknownTableException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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 UnknownDBException(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('UnknownDBException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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 AlreadyExistsException(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('AlreadyExistsException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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 InvalidObjectException(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('InvalidObjectException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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 NoSuchObjectException(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('NoSuchObjectException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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 IndexAlreadyExistsException(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('IndexAlreadyExistsException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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 InvalidOperationException(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('InvalidOperationException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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 ConfigValSecurityException(Exception):
+ """
+ Attributes:
+ - message
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'message', None, None, ), # 1
+ )
+
+ def __init__(self, message=None,):
+ self.message = message
+
+ 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.message = 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('ConfigValSecurityException')
+ if self.message != None:
+ oprot.writeFieldBegin('message', TType.STRING, 1)
+ oprot.writeString(self.message)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+ def validate(self):
+ return
+
+
+ def __str__(self):
+ return repr(self)
+
+ 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)
Added: hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb?rev=1044070&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_constants.rb Thu Dec 9 18:30:58 2010
@@ -0,0 +1,40 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+require 'hive_metastore_types'
+
+DDL_TIME = %q"transient_lastDdlTime"
+
+IS_ARCHIVED = %q"is_archived"
+
+ORIGINAL_LOCATION = %q"original_location"
+
+META_TABLE_COLUMNS = %q"columns"
+
+META_TABLE_COLUMN_TYPES = %q"columns.types"
+
+BUCKET_FIELD_NAME = %q"bucket_field_name"
+
+BUCKET_COUNT = %q"bucket_count"
+
+FIELD_TO_DIMENSION = %q"field_to_dimension"
+
+META_TABLE_NAME = %q"name"
+
+META_TABLE_DB = %q"db"
+
+META_TABLE_LOCATION = %q"location"
+
+META_TABLE_SERDE = %q"serde"
+
+META_TABLE_PARTITION_COLUMNS = %q"partition_columns"
+
+FILE_INPUT_FORMAT = %q"file.inputformat"
+
+FILE_OUTPUT_FORMAT = %q"file.outputformat"
+
+META_TABLE_STORAGE = %q"storage_handler"
+
Added: hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb?rev=1044070&view=auto
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb (added)
+++ hive/trunk/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb Thu Dec 9 18:30:58 2010
@@ -0,0 +1,470 @@
+#
+# Autogenerated by Thrift
+#
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+#
+
+require 'fb303_types'
+
+
+class Version
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ VERSION = 1
+ COMMENTS = 2
+
+ FIELDS = {
+ VERSION => {:type => ::Thrift::Types::STRING, :name => 'version'},
+ COMMENTS => {:type => ::Thrift::Types::STRING, :name => 'comments'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class FieldSchema
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ NAME = 1
+ TYPE = 2
+ COMMENT = 3
+
+ FIELDS = {
+ NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
+ TYPE => {:type => ::Thrift::Types::STRING, :name => 'type'},
+ COMMENT => {:type => ::Thrift::Types::STRING, :name => 'comment'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class Type
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ NAME = 1
+ TYPE1 = 2
+ TYPE2 = 3
+ FIELDS = 4
+
+ FIELDS = {
+ NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
+ TYPE1 => {:type => ::Thrift::Types::STRING, :name => 'type1', :optional => true},
+ TYPE2 => {:type => ::Thrift::Types::STRING, :name => 'type2', :optional => true},
+ FIELDS => {:type => ::Thrift::Types::LIST, :name => 'fields', :element => {:type => ::Thrift::Types::STRUCT, :class => FieldSchema}, :optional => true}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class Database
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ NAME = 1
+ DESCRIPTION = 2
+ LOCATIONURI = 3
+ PARAMETERS = 4
+
+ FIELDS = {
+ NAME => {:type => ::Thrift::Types::STRING, :name => 'name'},
+ DESCRIPTION => {:type => ::Thrift::Types::STRING, :name => 'description'},
+ LOCATIONURI => {:type => ::Thrift::Types::STRING, :name => 'locationUri'},
+ PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class SerDeInfo
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ NAME = 1
+ SERIALIZATIONLIB = 2
+ PARAMETERS = 3
+
+ 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}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class Order
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ COL = 1
+ ORDER = 2
+
+ FIELDS = {
+ COL => {:type => ::Thrift::Types::STRING, :name => 'col'},
+ ORDER => {:type => ::Thrift::Types::I32, :name => 'order'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class StorageDescriptor
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ COLS = 1
+ LOCATION = 2
+ INPUTFORMAT = 3
+ OUTPUTFORMAT = 4
+ COMPRESSED = 5
+ NUMBUCKETS = 6
+ SERDEINFO = 7
+ BUCKETCOLS = 8
+ SORTCOLS = 9
+ PARAMETERS = 10
+
+ FIELDS = {
+ COLS => {:type => ::Thrift::Types::LIST, :name => 'cols', :element => {:type => ::Thrift::Types::STRUCT, :class => FieldSchema}},
+ LOCATION => {:type => ::Thrift::Types::STRING, :name => 'location'},
+ INPUTFORMAT => {:type => ::Thrift::Types::STRING, :name => 'inputFormat'},
+ OUTPUTFORMAT => {:type => ::Thrift::Types::STRING, :name => 'outputFormat'},
+ COMPRESSED => {:type => ::Thrift::Types::BOOL, :name => 'compressed'},
+ NUMBUCKETS => {:type => ::Thrift::Types::I32, :name => 'numBuckets'},
+ SERDEINFO => {:type => ::Thrift::Types::STRUCT, :name => 'serdeInfo', :class => SerDeInfo},
+ BUCKETCOLS => {:type => ::Thrift::Types::LIST, :name => 'bucketCols', :element => {:type => ::Thrift::Types::STRING}},
+ SORTCOLS => {:type => ::Thrift::Types::LIST, :name => 'sortCols', :element => {:type => ::Thrift::Types::STRUCT, :class => Order}},
+ PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class Table
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ TABLENAME = 1
+ DBNAME = 2
+ OWNER = 3
+ CREATETIME = 4
+ LASTACCESSTIME = 5
+ RETENTION = 6
+ SD = 7
+ PARTITIONKEYS = 8
+ PARAMETERS = 9
+ VIEWORIGINALTEXT = 10
+ VIEWEXPANDEDTEXT = 11
+ TABLETYPE = 12
+
+ FIELDS = {
+ TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'},
+ DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'},
+ OWNER => {:type => ::Thrift::Types::STRING, :name => 'owner'},
+ CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'},
+ LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'},
+ RETENTION => {:type => ::Thrift::Types::I32, :name => 'retention'},
+ SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => StorageDescriptor},
+ PARTITIONKEYS => {:type => ::Thrift::Types::LIST, :name => 'partitionKeys', :element => {:type => ::Thrift::Types::STRUCT, :class => FieldSchema}},
+ PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}},
+ VIEWORIGINALTEXT => {:type => ::Thrift::Types::STRING, :name => 'viewOriginalText'},
+ VIEWEXPANDEDTEXT => {:type => ::Thrift::Types::STRING, :name => 'viewExpandedText'},
+ TABLETYPE => {:type => ::Thrift::Types::STRING, :name => 'tableType'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class Partition
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ VALUES = 1
+ DBNAME = 2
+ TABLENAME = 3
+ CREATETIME = 4
+ LASTACCESSTIME = 5
+ SD = 6
+ PARAMETERS = 7
+
+ FIELDS = {
+ VALUES => {:type => ::Thrift::Types::LIST, :name => 'values', :element => {:type => ::Thrift::Types::STRING}},
+ DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'},
+ TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tableName'},
+ CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'},
+ LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'},
+ SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => StorageDescriptor},
+ PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class Index
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ INDEXNAME = 1
+ INDEXHANDLERCLASS = 2
+ DBNAME = 3
+ ORIGTABLENAME = 4
+ CREATETIME = 5
+ LASTACCESSTIME = 6
+ INDEXTABLENAME = 7
+ SD = 8
+ PARAMETERS = 9
+ DEFERREDREBUILD = 10
+
+ FIELDS = {
+ INDEXNAME => {:type => ::Thrift::Types::STRING, :name => 'indexName'},
+ INDEXHANDLERCLASS => {:type => ::Thrift::Types::STRING, :name => 'indexHandlerClass'},
+ DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbName'},
+ ORIGTABLENAME => {:type => ::Thrift::Types::STRING, :name => 'origTableName'},
+ CREATETIME => {:type => ::Thrift::Types::I32, :name => 'createTime'},
+ LASTACCESSTIME => {:type => ::Thrift::Types::I32, :name => 'lastAccessTime'},
+ INDEXTABLENAME => {:type => ::Thrift::Types::STRING, :name => 'indexTableName'},
+ SD => {:type => ::Thrift::Types::STRUCT, :name => 'sd', :class => StorageDescriptor},
+ PARAMETERS => {:type => ::Thrift::Types::MAP, :name => 'parameters', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}},
+ DEFERREDREBUILD => {:type => ::Thrift::Types::BOOL, :name => 'deferredRebuild'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class Schema
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ FIELDSCHEMAS = 1
+ PROPERTIES = 2
+
+ FIELDS = {
+ FIELDSCHEMAS => {:type => ::Thrift::Types::LIST, :name => 'fieldSchemas', :element => {:type => ::Thrift::Types::STRUCT, :class => FieldSchema}},
+ PROPERTIES => {:type => ::Thrift::Types::MAP, :name => 'properties', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}}
+ }
+
+ 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)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class UnknownTableException < ::Thrift::Exception
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ def initialize(message=nil)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class UnknownDBException < ::Thrift::Exception
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ def initialize(message=nil)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class AlreadyExistsException < ::Thrift::Exception
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ def initialize(message=nil)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class InvalidObjectException < ::Thrift::Exception
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ def initialize(message=nil)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class NoSuchObjectException < ::Thrift::Exception
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ def initialize(message=nil)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class IndexAlreadyExistsException < ::Thrift::Exception
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ def initialize(message=nil)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class InvalidOperationException < ::Thrift::Exception
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ def initialize(message=nil)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class ConfigValSecurityException < ::Thrift::Exception
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ def initialize(message=nil)
+ super()
+ self.message = message
+ end
+
+ MESSAGE = 1
+
+ FIELDS = {
+ MESSAGE => {:type => ::Thrift::Types::STRING, :name => 'message'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+