You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2018/03/04 07:25:56 UTC
[02/19] hive git commit: HIVE-18726 : Implement DEFAULT constraint (Vineet Garg, reviewed by Ashutosh Chauhan, Jesús Camacho Rodríguez)
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/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 0c60aff..883ecfe 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
@@ -1154,6 +1154,162 @@ class SQLNotNullConstraint:
def __ne__(self, other):
return not (self == other)
+class SQLDefaultConstraint:
+ """
+ Attributes:
+ - table_db
+ - table_name
+ - column_name
+ - default_value
+ - dc_name
+ - enable_cstr
+ - validate_cstr
+ - rely_cstr
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'table_db', None, None, ), # 1
+ (2, TType.STRING, 'table_name', None, None, ), # 2
+ (3, TType.STRING, 'column_name', None, None, ), # 3
+ (4, TType.STRING, 'default_value', None, None, ), # 4
+ (5, TType.STRING, 'dc_name', None, None, ), # 5
+ (6, TType.BOOL, 'enable_cstr', None, None, ), # 6
+ (7, TType.BOOL, 'validate_cstr', None, None, ), # 7
+ (8, TType.BOOL, 'rely_cstr', None, None, ), # 8
+ )
+
+ def __init__(self, table_db=None, table_name=None, column_name=None, default_value=None, dc_name=None, enable_cstr=None, validate_cstr=None, rely_cstr=None,):
+ self.table_db = table_db
+ self.table_name = table_name
+ self.column_name = column_name
+ self.default_value = default_value
+ self.dc_name = dc_name
+ self.enable_cstr = enable_cstr
+ self.validate_cstr = validate_cstr
+ self.rely_cstr = rely_cstr
+
+ 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.table_db = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.table_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.column_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.default_value = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.dc_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.BOOL:
+ self.enable_cstr = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.BOOL:
+ self.validate_cstr = iprot.readBool()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.BOOL:
+ self.rely_cstr = 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('SQLDefaultConstraint')
+ if self.table_db is not None:
+ oprot.writeFieldBegin('table_db', TType.STRING, 1)
+ oprot.writeString(self.table_db)
+ oprot.writeFieldEnd()
+ if self.table_name is not None:
+ oprot.writeFieldBegin('table_name', TType.STRING, 2)
+ oprot.writeString(self.table_name)
+ oprot.writeFieldEnd()
+ if self.column_name is not None:
+ oprot.writeFieldBegin('column_name', TType.STRING, 3)
+ oprot.writeString(self.column_name)
+ oprot.writeFieldEnd()
+ if self.default_value is not None:
+ oprot.writeFieldBegin('default_value', TType.STRING, 4)
+ oprot.writeString(self.default_value)
+ oprot.writeFieldEnd()
+ if self.dc_name is not None:
+ oprot.writeFieldBegin('dc_name', TType.STRING, 5)
+ oprot.writeString(self.dc_name)
+ oprot.writeFieldEnd()
+ if self.enable_cstr is not None:
+ oprot.writeFieldBegin('enable_cstr', TType.BOOL, 6)
+ oprot.writeBool(self.enable_cstr)
+ oprot.writeFieldEnd()
+ if self.validate_cstr is not None:
+ oprot.writeFieldBegin('validate_cstr', TType.BOOL, 7)
+ oprot.writeBool(self.validate_cstr)
+ oprot.writeFieldEnd()
+ if self.rely_cstr is not None:
+ oprot.writeFieldBegin('rely_cstr', TType.BOOL, 8)
+ oprot.writeBool(self.rely_cstr)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.table_db)
+ value = (value * 31) ^ hash(self.table_name)
+ value = (value * 31) ^ hash(self.column_name)
+ value = (value * 31) ^ hash(self.default_value)
+ value = (value * 31) ^ hash(self.dc_name)
+ value = (value * 31) ^ hash(self.enable_cstr)
+ value = (value * 31) ^ hash(self.validate_cstr)
+ value = (value * 31) ^ hash(self.rely_cstr)
+ 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 Type:
"""
Attributes:
@@ -6982,6 +7138,164 @@ class NotNullConstraintsResponse:
def __ne__(self, other):
return not (self == other)
+class DefaultConstraintsRequest:
+ """
+ Attributes:
+ - db_name
+ - tbl_name
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'tbl_name', None, None, ), # 2
+ )
+
+ def __init__(self, db_name=None, tbl_name=None,):
+ self.db_name = db_name
+ self.tbl_name = tbl_name
+
+ 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.db_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.tbl_name = 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('DefaultConstraintsRequest')
+ if self.db_name is not None:
+ oprot.writeFieldBegin('db_name', TType.STRING, 1)
+ oprot.writeString(self.db_name)
+ oprot.writeFieldEnd()
+ if self.tbl_name is not None:
+ oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
+ oprot.writeString(self.tbl_name)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.db_name is None:
+ raise TProtocol.TProtocolException(message='Required field db_name is unset!')
+ if self.tbl_name is None:
+ raise TProtocol.TProtocolException(message='Required field tbl_name is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.db_name)
+ value = (value * 31) ^ hash(self.tbl_name)
+ 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 DefaultConstraintsResponse:
+ """
+ Attributes:
+ - defaultConstraints
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'defaultConstraints', (TType.STRUCT,(SQLDefaultConstraint, SQLDefaultConstraint.thrift_spec)), None, ), # 1
+ )
+
+ def __init__(self, defaultConstraints=None,):
+ self.defaultConstraints = defaultConstraints
+
+ 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.defaultConstraints = []
+ (_etype316, _size313) = iprot.readListBegin()
+ for _i317 in xrange(_size313):
+ _elem318 = SQLDefaultConstraint()
+ _elem318.read(iprot)
+ self.defaultConstraints.append(_elem318)
+ 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('DefaultConstraintsResponse')
+ if self.defaultConstraints is not None:
+ oprot.writeFieldBegin('defaultConstraints', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints))
+ for iter319 in self.defaultConstraints:
+ iter319.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.defaultConstraints is None:
+ raise TProtocol.TProtocolException(message='Required field defaultConstraints is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.defaultConstraints)
+ 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 DropConstraintRequest:
"""
Attributes:
@@ -7105,11 +7419,11 @@ class AddPrimaryKeyRequest:
if fid == 1:
if ftype == TType.LIST:
self.primaryKeyCols = []
- (_etype316, _size313) = iprot.readListBegin()
- for _i317 in xrange(_size313):
- _elem318 = SQLPrimaryKey()
- _elem318.read(iprot)
- self.primaryKeyCols.append(_elem318)
+ (_etype323, _size320) = iprot.readListBegin()
+ for _i324 in xrange(_size320):
+ _elem325 = SQLPrimaryKey()
+ _elem325.read(iprot)
+ self.primaryKeyCols.append(_elem325)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7126,8 +7440,8 @@ class AddPrimaryKeyRequest:
if self.primaryKeyCols is not None:
oprot.writeFieldBegin('primaryKeyCols', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.primaryKeyCols))
- for iter319 in self.primaryKeyCols:
- iter319.write(oprot)
+ for iter326 in self.primaryKeyCols:
+ iter326.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -7181,11 +7495,87 @@ class AddForeignKeyRequest:
if fid == 1:
if ftype == TType.LIST:
self.foreignKeyCols = []
- (_etype323, _size320) = iprot.readListBegin()
- for _i324 in xrange(_size320):
- _elem325 = SQLForeignKey()
- _elem325.read(iprot)
- self.foreignKeyCols.append(_elem325)
+ (_etype330, _size327) = iprot.readListBegin()
+ for _i331 in xrange(_size327):
+ _elem332 = SQLForeignKey()
+ _elem332.read(iprot)
+ self.foreignKeyCols.append(_elem332)
+ 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('AddForeignKeyRequest')
+ if self.foreignKeyCols is not None:
+ oprot.writeFieldBegin('foreignKeyCols', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.foreignKeyCols))
+ for iter333 in self.foreignKeyCols:
+ iter333.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.foreignKeyCols is None:
+ raise TProtocol.TProtocolException(message='Required field foreignKeyCols is unset!')
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.foreignKeyCols)
+ 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 AddUniqueConstraintRequest:
+ """
+ Attributes:
+ - uniqueConstraintCols
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'uniqueConstraintCols', (TType.STRUCT,(SQLUniqueConstraint, SQLUniqueConstraint.thrift_spec)), None, ), # 1
+ )
+
+ def __init__(self, uniqueConstraintCols=None,):
+ self.uniqueConstraintCols = uniqueConstraintCols
+
+ 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.uniqueConstraintCols = []
+ (_etype337, _size334) = iprot.readListBegin()
+ for _i338 in xrange(_size334):
+ _elem339 = SQLUniqueConstraint()
+ _elem339.read(iprot)
+ self.uniqueConstraintCols.append(_elem339)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7198,26 +7588,26 @@ class AddForeignKeyRequest:
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('AddForeignKeyRequest')
- if self.foreignKeyCols is not None:
- oprot.writeFieldBegin('foreignKeyCols', TType.LIST, 1)
- oprot.writeListBegin(TType.STRUCT, len(self.foreignKeyCols))
- for iter326 in self.foreignKeyCols:
- iter326.write(oprot)
+ oprot.writeStructBegin('AddUniqueConstraintRequest')
+ if self.uniqueConstraintCols is not None:
+ oprot.writeFieldBegin('uniqueConstraintCols', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraintCols))
+ for iter340 in self.uniqueConstraintCols:
+ iter340.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
def validate(self):
- if self.foreignKeyCols is None:
- raise TProtocol.TProtocolException(message='Required field foreignKeyCols is unset!')
+ if self.uniqueConstraintCols is None:
+ raise TProtocol.TProtocolException(message='Required field uniqueConstraintCols is unset!')
return
def __hash__(self):
value = 17
- value = (value * 31) ^ hash(self.foreignKeyCols)
+ value = (value * 31) ^ hash(self.uniqueConstraintCols)
return value
def __repr__(self):
@@ -7231,19 +7621,19 @@ class AddForeignKeyRequest:
def __ne__(self, other):
return not (self == other)
-class AddUniqueConstraintRequest:
+class AddNotNullConstraintRequest:
"""
Attributes:
- - uniqueConstraintCols
+ - notNullConstraintCols
"""
thrift_spec = (
None, # 0
- (1, TType.LIST, 'uniqueConstraintCols', (TType.STRUCT,(SQLUniqueConstraint, SQLUniqueConstraint.thrift_spec)), None, ), # 1
+ (1, TType.LIST, 'notNullConstraintCols', (TType.STRUCT,(SQLNotNullConstraint, SQLNotNullConstraint.thrift_spec)), None, ), # 1
)
- def __init__(self, uniqueConstraintCols=None,):
- self.uniqueConstraintCols = uniqueConstraintCols
+ def __init__(self, notNullConstraintCols=None,):
+ self.notNullConstraintCols = notNullConstraintCols
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:
@@ -7256,12 +7646,12 @@ class AddUniqueConstraintRequest:
break
if fid == 1:
if ftype == TType.LIST:
- self.uniqueConstraintCols = []
- (_etype330, _size327) = iprot.readListBegin()
- for _i331 in xrange(_size327):
- _elem332 = SQLUniqueConstraint()
- _elem332.read(iprot)
- self.uniqueConstraintCols.append(_elem332)
+ self.notNullConstraintCols = []
+ (_etype344, _size341) = iprot.readListBegin()
+ for _i345 in xrange(_size341):
+ _elem346 = SQLNotNullConstraint()
+ _elem346.read(iprot)
+ self.notNullConstraintCols.append(_elem346)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7274,26 +7664,26 @@ class AddUniqueConstraintRequest:
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('AddUniqueConstraintRequest')
- if self.uniqueConstraintCols is not None:
- oprot.writeFieldBegin('uniqueConstraintCols', TType.LIST, 1)
- oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraintCols))
- for iter333 in self.uniqueConstraintCols:
- iter333.write(oprot)
+ oprot.writeStructBegin('AddNotNullConstraintRequest')
+ if self.notNullConstraintCols is not None:
+ oprot.writeFieldBegin('notNullConstraintCols', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraintCols))
+ for iter347 in self.notNullConstraintCols:
+ iter347.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
def validate(self):
- if self.uniqueConstraintCols is None:
- raise TProtocol.TProtocolException(message='Required field uniqueConstraintCols is unset!')
+ if self.notNullConstraintCols is None:
+ raise TProtocol.TProtocolException(message='Required field notNullConstraintCols is unset!')
return
def __hash__(self):
value = 17
- value = (value * 31) ^ hash(self.uniqueConstraintCols)
+ value = (value * 31) ^ hash(self.notNullConstraintCols)
return value
def __repr__(self):
@@ -7307,19 +7697,19 @@ class AddUniqueConstraintRequest:
def __ne__(self, other):
return not (self == other)
-class AddNotNullConstraintRequest:
+class AddDefaultConstraintRequest:
"""
Attributes:
- - notNullConstraintCols
+ - defaultConstraintCols
"""
thrift_spec = (
None, # 0
- (1, TType.LIST, 'notNullConstraintCols', (TType.STRUCT,(SQLNotNullConstraint, SQLNotNullConstraint.thrift_spec)), None, ), # 1
+ (1, TType.LIST, 'defaultConstraintCols', (TType.STRUCT,(SQLDefaultConstraint, SQLDefaultConstraint.thrift_spec)), None, ), # 1
)
- def __init__(self, notNullConstraintCols=None,):
- self.notNullConstraintCols = notNullConstraintCols
+ def __init__(self, defaultConstraintCols=None,):
+ self.defaultConstraintCols = defaultConstraintCols
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:
@@ -7332,12 +7722,12 @@ class AddNotNullConstraintRequest:
break
if fid == 1:
if ftype == TType.LIST:
- self.notNullConstraintCols = []
- (_etype337, _size334) = iprot.readListBegin()
- for _i338 in xrange(_size334):
- _elem339 = SQLNotNullConstraint()
- _elem339.read(iprot)
- self.notNullConstraintCols.append(_elem339)
+ self.defaultConstraintCols = []
+ (_etype351, _size348) = iprot.readListBegin()
+ for _i352 in xrange(_size348):
+ _elem353 = SQLDefaultConstraint()
+ _elem353.read(iprot)
+ self.defaultConstraintCols.append(_elem353)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7350,26 +7740,26 @@ class AddNotNullConstraintRequest:
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('AddNotNullConstraintRequest')
- if self.notNullConstraintCols is not None:
- oprot.writeFieldBegin('notNullConstraintCols', TType.LIST, 1)
- oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraintCols))
- for iter340 in self.notNullConstraintCols:
- iter340.write(oprot)
+ oprot.writeStructBegin('AddDefaultConstraintRequest')
+ if self.defaultConstraintCols is not None:
+ oprot.writeFieldBegin('defaultConstraintCols', TType.LIST, 1)
+ oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraintCols))
+ for iter354 in self.defaultConstraintCols:
+ iter354.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
def validate(self):
- if self.notNullConstraintCols is None:
- raise TProtocol.TProtocolException(message='Required field notNullConstraintCols is unset!')
+ if self.defaultConstraintCols is None:
+ raise TProtocol.TProtocolException(message='Required field defaultConstraintCols is unset!')
return
def __hash__(self):
value = 17
- value = (value * 31) ^ hash(self.notNullConstraintCols)
+ value = (value * 31) ^ hash(self.defaultConstraintCols)
return value
def __repr__(self):
@@ -7412,11 +7802,11 @@ class PartitionsByExprResult:
if fid == 1:
if ftype == TType.LIST:
self.partitions = []
- (_etype344, _size341) = iprot.readListBegin()
- for _i345 in xrange(_size341):
- _elem346 = Partition()
- _elem346.read(iprot)
- self.partitions.append(_elem346)
+ (_etype358, _size355) = iprot.readListBegin()
+ for _i359 in xrange(_size355):
+ _elem360 = Partition()
+ _elem360.read(iprot)
+ self.partitions.append(_elem360)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7438,8 +7828,8 @@ class PartitionsByExprResult:
if self.partitions is not None:
oprot.writeFieldBegin('partitions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitions))
- for iter347 in self.partitions:
- iter347.write(oprot)
+ for iter361 in self.partitions:
+ iter361.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.hasUnknownPartitions is not None:
@@ -7623,11 +8013,11 @@ class TableStatsResult:
if fid == 1:
if ftype == TType.LIST:
self.tableStats = []
- (_etype351, _size348) = iprot.readListBegin()
- for _i352 in xrange(_size348):
- _elem353 = ColumnStatisticsObj()
- _elem353.read(iprot)
- self.tableStats.append(_elem353)
+ (_etype365, _size362) = iprot.readListBegin()
+ for _i366 in xrange(_size362):
+ _elem367 = ColumnStatisticsObj()
+ _elem367.read(iprot)
+ self.tableStats.append(_elem367)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7644,8 +8034,8 @@ class TableStatsResult:
if self.tableStats is not None:
oprot.writeFieldBegin('tableStats', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.tableStats))
- for iter354 in self.tableStats:
- iter354.write(oprot)
+ for iter368 in self.tableStats:
+ iter368.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -7699,17 +8089,17 @@ class PartitionsStatsResult:
if fid == 1:
if ftype == TType.MAP:
self.partStats = {}
- (_ktype356, _vtype357, _size355 ) = iprot.readMapBegin()
- for _i359 in xrange(_size355):
- _key360 = iprot.readString()
- _val361 = []
- (_etype365, _size362) = iprot.readListBegin()
- for _i366 in xrange(_size362):
- _elem367 = ColumnStatisticsObj()
- _elem367.read(iprot)
- _val361.append(_elem367)
+ (_ktype370, _vtype371, _size369 ) = iprot.readMapBegin()
+ for _i373 in xrange(_size369):
+ _key374 = iprot.readString()
+ _val375 = []
+ (_etype379, _size376) = iprot.readListBegin()
+ for _i380 in xrange(_size376):
+ _elem381 = ColumnStatisticsObj()
+ _elem381.read(iprot)
+ _val375.append(_elem381)
iprot.readListEnd()
- self.partStats[_key360] = _val361
+ self.partStats[_key374] = _val375
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -7726,11 +8116,11 @@ class PartitionsStatsResult:
if self.partStats is not None:
oprot.writeFieldBegin('partStats', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.LIST, len(self.partStats))
- for kiter368,viter369 in self.partStats.items():
- oprot.writeString(kiter368)
- oprot.writeListBegin(TType.STRUCT, len(viter369))
- for iter370 in viter369:
- iter370.write(oprot)
+ for kiter382,viter383 in self.partStats.items():
+ oprot.writeString(kiter382)
+ oprot.writeListBegin(TType.STRUCT, len(viter383))
+ for iter384 in viter383:
+ iter384.write(oprot)
oprot.writeListEnd()
oprot.writeMapEnd()
oprot.writeFieldEnd()
@@ -7801,10 +8191,10 @@ class TableStatsRequest:
elif fid == 3:
if ftype == TType.LIST:
self.colNames = []
- (_etype374, _size371) = iprot.readListBegin()
- for _i375 in xrange(_size371):
- _elem376 = iprot.readString()
- self.colNames.append(_elem376)
+ (_etype388, _size385) = iprot.readListBegin()
+ for _i389 in xrange(_size385):
+ _elem390 = iprot.readString()
+ self.colNames.append(_elem390)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7829,8 +8219,8 @@ class TableStatsRequest:
if self.colNames is not None:
oprot.writeFieldBegin('colNames', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.colNames))
- for iter377 in self.colNames:
- oprot.writeString(iter377)
+ for iter391 in self.colNames:
+ oprot.writeString(iter391)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -7909,20 +8299,20 @@ class PartitionsStatsRequest:
elif fid == 3:
if ftype == TType.LIST:
self.colNames = []
- (_etype381, _size378) = iprot.readListBegin()
- for _i382 in xrange(_size378):
- _elem383 = iprot.readString()
- self.colNames.append(_elem383)
+ (_etype395, _size392) = iprot.readListBegin()
+ for _i396 in xrange(_size392):
+ _elem397 = iprot.readString()
+ self.colNames.append(_elem397)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.partNames = []
- (_etype387, _size384) = iprot.readListBegin()
- for _i388 in xrange(_size384):
- _elem389 = iprot.readString()
- self.partNames.append(_elem389)
+ (_etype401, _size398) = iprot.readListBegin()
+ for _i402 in xrange(_size398):
+ _elem403 = iprot.readString()
+ self.partNames.append(_elem403)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7947,15 +8337,15 @@ class PartitionsStatsRequest:
if self.colNames is not None:
oprot.writeFieldBegin('colNames', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.colNames))
- for iter390 in self.colNames:
- oprot.writeString(iter390)
+ for iter404 in self.colNames:
+ oprot.writeString(iter404)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.partNames is not None:
oprot.writeFieldBegin('partNames', TType.LIST, 4)
oprot.writeListBegin(TType.STRING, len(self.partNames))
- for iter391 in self.partNames:
- oprot.writeString(iter391)
+ for iter405 in self.partNames:
+ oprot.writeString(iter405)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8018,11 +8408,11 @@ class AddPartitionsResult:
if fid == 1:
if ftype == TType.LIST:
self.partitions = []
- (_etype395, _size392) = iprot.readListBegin()
- for _i396 in xrange(_size392):
- _elem397 = Partition()
- _elem397.read(iprot)
- self.partitions.append(_elem397)
+ (_etype409, _size406) = iprot.readListBegin()
+ for _i410 in xrange(_size406):
+ _elem411 = Partition()
+ _elem411.read(iprot)
+ self.partitions.append(_elem411)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8039,8 +8429,8 @@ class AddPartitionsResult:
if self.partitions is not None:
oprot.writeFieldBegin('partitions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitions))
- for iter398 in self.partitions:
- iter398.write(oprot)
+ for iter412 in self.partitions:
+ iter412.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8114,11 +8504,11 @@ class AddPartitionsRequest:
elif fid == 3:
if ftype == TType.LIST:
self.parts = []
- (_etype402, _size399) = iprot.readListBegin()
- for _i403 in xrange(_size399):
- _elem404 = Partition()
- _elem404.read(iprot)
- self.parts.append(_elem404)
+ (_etype416, _size413) = iprot.readListBegin()
+ for _i417 in xrange(_size413):
+ _elem418 = Partition()
+ _elem418.read(iprot)
+ self.parts.append(_elem418)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8153,8 +8543,8 @@ class AddPartitionsRequest:
if self.parts is not None:
oprot.writeFieldBegin('parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.parts))
- for iter405 in self.parts:
- iter405.write(oprot)
+ for iter419 in self.parts:
+ iter419.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ifNotExists is not None:
@@ -8226,11 +8616,11 @@ class DropPartitionsResult:
if fid == 1:
if ftype == TType.LIST:
self.partitions = []
- (_etype409, _size406) = iprot.readListBegin()
- for _i410 in xrange(_size406):
- _elem411 = Partition()
- _elem411.read(iprot)
- self.partitions.append(_elem411)
+ (_etype423, _size420) = iprot.readListBegin()
+ for _i424 in xrange(_size420):
+ _elem425 = Partition()
+ _elem425.read(iprot)
+ self.partitions.append(_elem425)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8247,8 +8637,8 @@ class DropPartitionsResult:
if self.partitions is not None:
oprot.writeFieldBegin('partitions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitions))
- for iter412 in self.partitions:
- iter412.write(oprot)
+ for iter426 in self.partitions:
+ iter426.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8383,21 +8773,21 @@ class RequestPartsSpec:
if fid == 1:
if ftype == TType.LIST:
self.names = []
- (_etype416, _size413) = iprot.readListBegin()
- for _i417 in xrange(_size413):
- _elem418 = iprot.readString()
- self.names.append(_elem418)
+ (_etype430, _size427) = iprot.readListBegin()
+ for _i431 in xrange(_size427):
+ _elem432 = iprot.readString()
+ self.names.append(_elem432)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.LIST:
self.exprs = []
- (_etype422, _size419) = iprot.readListBegin()
- for _i423 in xrange(_size419):
- _elem424 = DropPartitionsExpr()
- _elem424.read(iprot)
- self.exprs.append(_elem424)
+ (_etype436, _size433) = iprot.readListBegin()
+ for _i437 in xrange(_size433):
+ _elem438 = DropPartitionsExpr()
+ _elem438.read(iprot)
+ self.exprs.append(_elem438)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8414,15 +8804,15 @@ class RequestPartsSpec:
if self.names is not None:
oprot.writeFieldBegin('names', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.names))
- for iter425 in self.names:
- oprot.writeString(iter425)
+ for iter439 in self.names:
+ oprot.writeString(iter439)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.exprs is not None:
oprot.writeFieldBegin('exprs', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.exprs))
- for iter426 in self.exprs:
- iter426.write(oprot)
+ for iter440 in self.exprs:
+ iter440.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8670,11 +9060,11 @@ class PartitionValuesRequest:
elif fid == 3:
if ftype == TType.LIST:
self.partitionKeys = []
- (_etype430, _size427) = iprot.readListBegin()
- for _i431 in xrange(_size427):
- _elem432 = FieldSchema()
- _elem432.read(iprot)
- self.partitionKeys.append(_elem432)
+ (_etype444, _size441) = iprot.readListBegin()
+ for _i445 in xrange(_size441):
+ _elem446 = FieldSchema()
+ _elem446.read(iprot)
+ self.partitionKeys.append(_elem446)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8691,11 +9081,11 @@ class PartitionValuesRequest:
elif fid == 6:
if ftype == TType.LIST:
self.partitionOrder = []
- (_etype436, _size433) = iprot.readListBegin()
- for _i437 in xrange(_size433):
- _elem438 = FieldSchema()
- _elem438.read(iprot)
- self.partitionOrder.append(_elem438)
+ (_etype450, _size447) = iprot.readListBegin()
+ for _i451 in xrange(_size447):
+ _elem452 = FieldSchema()
+ _elem452.read(iprot)
+ self.partitionOrder.append(_elem452)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8730,8 +9120,8 @@ class PartitionValuesRequest:
if self.partitionKeys is not None:
oprot.writeFieldBegin('partitionKeys', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.partitionKeys))
- for iter439 in self.partitionKeys:
- iter439.write(oprot)
+ for iter453 in self.partitionKeys:
+ iter453.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.applyDistinct is not None:
@@ -8745,8 +9135,8 @@ class PartitionValuesRequest:
if self.partitionOrder is not None:
oprot.writeFieldBegin('partitionOrder', TType.LIST, 6)
oprot.writeListBegin(TType.STRUCT, len(self.partitionOrder))
- for iter440 in self.partitionOrder:
- iter440.write(oprot)
+ for iter454 in self.partitionOrder:
+ iter454.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.ascending is not None:
@@ -8819,10 +9209,10 @@ class PartitionValuesRow:
if fid == 1:
if ftype == TType.LIST:
self.row = []
- (_etype444, _size441) = iprot.readListBegin()
- for _i445 in xrange(_size441):
- _elem446 = iprot.readString()
- self.row.append(_elem446)
+ (_etype458, _size455) = iprot.readListBegin()
+ for _i459 in xrange(_size455):
+ _elem460 = iprot.readString()
+ self.row.append(_elem460)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8839,8 +9229,8 @@ class PartitionValuesRow:
if self.row is not None:
oprot.writeFieldBegin('row', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.row))
- for iter447 in self.row:
- oprot.writeString(iter447)
+ for iter461 in self.row:
+ oprot.writeString(iter461)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8894,11 +9284,11 @@ class PartitionValuesResponse:
if fid == 1:
if ftype == TType.LIST:
self.partitionValues = []
- (_etype451, _size448) = iprot.readListBegin()
- for _i452 in xrange(_size448):
- _elem453 = PartitionValuesRow()
- _elem453.read(iprot)
- self.partitionValues.append(_elem453)
+ (_etype465, _size462) = iprot.readListBegin()
+ for _i466 in xrange(_size462):
+ _elem467 = PartitionValuesRow()
+ _elem467.read(iprot)
+ self.partitionValues.append(_elem467)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8915,8 +9305,8 @@ class PartitionValuesResponse:
if self.partitionValues is not None:
oprot.writeFieldBegin('partitionValues', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.partitionValues))
- for iter454 in self.partitionValues:
- iter454.write(oprot)
+ for iter468 in self.partitionValues:
+ iter468.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9104,11 +9494,11 @@ class Function:
elif fid == 8:
if ftype == TType.LIST:
self.resourceUris = []
- (_etype458, _size455) = iprot.readListBegin()
- for _i459 in xrange(_size455):
- _elem460 = ResourceUri()
- _elem460.read(iprot)
- self.resourceUris.append(_elem460)
+ (_etype472, _size469) = iprot.readListBegin()
+ for _i473 in xrange(_size469):
+ _elem474 = ResourceUri()
+ _elem474.read(iprot)
+ self.resourceUris.append(_elem474)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9153,8 +9543,8 @@ class Function:
if self.resourceUris is not None:
oprot.writeFieldBegin('resourceUris', TType.LIST, 8)
oprot.writeListBegin(TType.STRUCT, len(self.resourceUris))
- for iter461 in self.resourceUris:
- iter461.write(oprot)
+ for iter475 in self.resourceUris:
+ iter475.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9398,11 +9788,11 @@ class GetOpenTxnsInfoResponse:
elif fid == 2:
if ftype == TType.LIST:
self.open_txns = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = TxnInfo()
- _elem467.read(iprot)
- self.open_txns.append(_elem467)
+ (_etype479, _size476) = iprot.readListBegin()
+ for _i480 in xrange(_size476):
+ _elem481 = TxnInfo()
+ _elem481.read(iprot)
+ self.open_txns.append(_elem481)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9423,8 +9813,8 @@ class GetOpenTxnsInfoResponse:
if self.open_txns is not None:
oprot.writeFieldBegin('open_txns', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.open_txns))
- for iter468 in self.open_txns:
- iter468.write(oprot)
+ for iter482 in self.open_txns:
+ iter482.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9495,10 +9885,10 @@ class GetOpenTxnsResponse:
elif fid == 2:
if ftype == TType.LIST:
self.open_txns = []
- (_etype472, _size469) = iprot.readListBegin()
- for _i473 in xrange(_size469):
- _elem474 = iprot.readI64()
- self.open_txns.append(_elem474)
+ (_etype486, _size483) = iprot.readListBegin()
+ for _i487 in xrange(_size483):
+ _elem488 = iprot.readI64()
+ self.open_txns.append(_elem488)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9529,8 +9919,8 @@ class GetOpenTxnsResponse:
if self.open_txns is not None:
oprot.writeFieldBegin('open_txns', TType.LIST, 2)
oprot.writeListBegin(TType.I64, len(self.open_txns))
- for iter475 in self.open_txns:
- oprot.writeI64(iter475)
+ for iter489 in self.open_txns:
+ oprot.writeI64(iter489)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.min_open_txn is not None:
@@ -9709,10 +10099,10 @@ class OpenTxnsResponse:
if fid == 1:
if ftype == TType.LIST:
self.txn_ids = []
- (_etype479, _size476) = iprot.readListBegin()
- for _i480 in xrange(_size476):
- _elem481 = iprot.readI64()
- self.txn_ids.append(_elem481)
+ (_etype493, _size490) = iprot.readListBegin()
+ for _i494 in xrange(_size490):
+ _elem495 = iprot.readI64()
+ self.txn_ids.append(_elem495)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9729,8 +10119,8 @@ class OpenTxnsResponse:
if self.txn_ids is not None:
oprot.writeFieldBegin('txn_ids', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.txn_ids))
- for iter482 in self.txn_ids:
- oprot.writeI64(iter482)
+ for iter496 in self.txn_ids:
+ oprot.writeI64(iter496)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9851,10 +10241,10 @@ class AbortTxnsRequest:
if fid == 1:
if ftype == TType.LIST:
self.txn_ids = []
- (_etype486, _size483) = iprot.readListBegin()
- for _i487 in xrange(_size483):
- _elem488 = iprot.readI64()
- self.txn_ids.append(_elem488)
+ (_etype500, _size497) = iprot.readListBegin()
+ for _i501 in xrange(_size497):
+ _elem502 = iprot.readI64()
+ self.txn_ids.append(_elem502)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9871,8 +10261,8 @@ class AbortTxnsRequest:
if self.txn_ids is not None:
oprot.writeFieldBegin('txn_ids', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.txn_ids))
- for iter489 in self.txn_ids:
- oprot.writeI64(iter489)
+ for iter503 in self.txn_ids:
+ oprot.writeI64(iter503)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9996,10 +10386,10 @@ class GetValidWriteIdsRequest:
if fid == 1:
if ftype == TType.LIST:
self.fullTableNames = []
- (_etype493, _size490) = iprot.readListBegin()
- for _i494 in xrange(_size490):
- _elem495 = iprot.readString()
- self.fullTableNames.append(_elem495)
+ (_etype507, _size504) = iprot.readListBegin()
+ for _i508 in xrange(_size504):
+ _elem509 = iprot.readString()
+ self.fullTableNames.append(_elem509)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10021,8 +10411,8 @@ class GetValidWriteIdsRequest:
if self.fullTableNames is not None:
oprot.writeFieldBegin('fullTableNames', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.fullTableNames))
- for iter496 in self.fullTableNames:
- oprot.writeString(iter496)
+ for iter510 in self.fullTableNames:
+ oprot.writeString(iter510)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.validTxnList is not None:
@@ -10105,10 +10495,10 @@ class TableValidWriteIds:
elif fid == 3:
if ftype == TType.LIST:
self.invalidWriteIds = []
- (_etype500, _size497) = iprot.readListBegin()
- for _i501 in xrange(_size497):
- _elem502 = iprot.readI64()
- self.invalidWriteIds.append(_elem502)
+ (_etype514, _size511) = iprot.readListBegin()
+ for _i515 in xrange(_size511):
+ _elem516 = iprot.readI64()
+ self.invalidWriteIds.append(_elem516)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10143,8 +10533,8 @@ class TableValidWriteIds:
if self.invalidWriteIds is not None:
oprot.writeFieldBegin('invalidWriteIds', TType.LIST, 3)
oprot.writeListBegin(TType.I64, len(self.invalidWriteIds))
- for iter503 in self.invalidWriteIds:
- oprot.writeI64(iter503)
+ for iter517 in self.invalidWriteIds:
+ oprot.writeI64(iter517)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.minOpenWriteId is not None:
@@ -10216,11 +10606,11 @@ class GetValidWriteIdsResponse:
if fid == 1:
if ftype == TType.LIST:
self.tblValidWriteIds = []
- (_etype507, _size504) = iprot.readListBegin()
- for _i508 in xrange(_size504):
- _elem509 = TableValidWriteIds()
- _elem509.read(iprot)
- self.tblValidWriteIds.append(_elem509)
+ (_etype521, _size518) = iprot.readListBegin()
+ for _i522 in xrange(_size518):
+ _elem523 = TableValidWriteIds()
+ _elem523.read(iprot)
+ self.tblValidWriteIds.append(_elem523)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10237,8 +10627,8 @@ class GetValidWriteIdsResponse:
if self.tblValidWriteIds is not None:
oprot.writeFieldBegin('tblValidWriteIds', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.tblValidWriteIds))
- for iter510 in self.tblValidWriteIds:
- iter510.write(oprot)
+ for iter524 in self.tblValidWriteIds:
+ iter524.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10298,10 +10688,10 @@ class AllocateTableWriteIdsRequest:
if fid == 1:
if ftype == TType.LIST:
self.txnIds = []
- (_etype514, _size511) = iprot.readListBegin()
- for _i515 in xrange(_size511):
- _elem516 = iprot.readI64()
- self.txnIds.append(_elem516)
+ (_etype528, _size525) = iprot.readListBegin()
+ for _i529 in xrange(_size525):
+ _elem530 = iprot.readI64()
+ self.txnIds.append(_elem530)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10328,8 +10718,8 @@ class AllocateTableWriteIdsRequest:
if self.txnIds is not None:
oprot.writeFieldBegin('txnIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.txnIds))
- for iter517 in self.txnIds:
- oprot.writeI64(iter517)
+ for iter531 in self.txnIds:
+ oprot.writeI64(iter531)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.dbName is not None:
@@ -10479,11 +10869,11 @@ class AllocateTableWriteIdsResponse:
if fid == 1:
if ftype == TType.LIST:
self.txnToWriteIds = []
- (_etype521, _size518) = iprot.readListBegin()
- for _i522 in xrange(_size518):
- _elem523 = TxnToWriteId()
- _elem523.read(iprot)
- self.txnToWriteIds.append(_elem523)
+ (_etype535, _size532) = iprot.readListBegin()
+ for _i536 in xrange(_size532):
+ _elem537 = TxnToWriteId()
+ _elem537.read(iprot)
+ self.txnToWriteIds.append(_elem537)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10500,8 +10890,8 @@ class AllocateTableWriteIdsResponse:
if self.txnToWriteIds is not None:
oprot.writeFieldBegin('txnToWriteIds', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.txnToWriteIds))
- for iter524 in self.txnToWriteIds:
- iter524.write(oprot)
+ for iter538 in self.txnToWriteIds:
+ iter538.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10729,11 +11119,11 @@ class LockRequest:
if fid == 1:
if ftype == TType.LIST:
self.component = []
- (_etype528, _size525) = iprot.readListBegin()
- for _i529 in xrange(_size525):
- _elem530 = LockComponent()
- _elem530.read(iprot)
- self.component.append(_elem530)
+ (_etype542, _size539) = iprot.readListBegin()
+ for _i543 in xrange(_size539):
+ _elem544 = LockComponent()
+ _elem544.read(iprot)
+ self.component.append(_elem544)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10770,8 +11160,8 @@ class LockRequest:
if self.component is not None:
oprot.writeFieldBegin('component', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.component))
- for iter531 in self.component:
- iter531.write(oprot)
+ for iter545 in self.component:
+ iter545.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.txnid is not None:
@@ -11469,11 +11859,11 @@ class ShowLocksResponse:
if fid == 1:
if ftype == TType.LIST:
self.locks = []
- (_etype535, _size532) = iprot.readListBegin()
- for _i536 in xrange(_size532):
- _elem537 = ShowLocksResponseElement()
- _elem537.read(iprot)
- self.locks.append(_elem537)
+ (_etype549, _size546) = iprot.readListBegin()
+ for _i550 in xrange(_size546):
+ _elem551 = ShowLocksResponseElement()
+ _elem551.read(iprot)
+ self.locks.append(_elem551)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11490,8 +11880,8 @@ class ShowLocksResponse:
if self.locks is not None:
oprot.writeFieldBegin('locks', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.locks))
- for iter538 in self.locks:
- iter538.write(oprot)
+ for iter552 in self.locks:
+ iter552.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11706,20 +12096,20 @@ class HeartbeatTxnRangeResponse:
if fid == 1:
if ftype == TType.SET:
self.aborted = set()
- (_etype542, _size539) = iprot.readSetBegin()
- for _i543 in xrange(_size539):
- _elem544 = iprot.readI64()
- self.aborted.add(_elem544)
+ (_etype556, _size553) = iprot.readSetBegin()
+ for _i557 in xrange(_size553):
+ _elem558 = iprot.readI64()
+ self.aborted.add(_elem558)
iprot.readSetEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.SET:
self.nosuch = set()
- (_etype548, _size545) = iprot.readSetBegin()
- for _i549 in xrange(_size545):
- _elem550 = iprot.readI64()
- self.nosuch.add(_elem550)
+ (_etype562, _size559) = iprot.readSetBegin()
+ for _i563 in xrange(_size559):
+ _elem564 = iprot.readI64()
+ self.nosuch.add(_elem564)
iprot.readSetEnd()
else:
iprot.skip(ftype)
@@ -11736,15 +12126,15 @@ class HeartbeatTxnRangeResponse:
if self.aborted is not None:
oprot.writeFieldBegin('aborted', TType.SET, 1)
oprot.writeSetBegin(TType.I64, len(self.aborted))
- for iter551 in self.aborted:
- oprot.writeI64(iter551)
+ for iter565 in self.aborted:
+ oprot.writeI64(iter565)
oprot.writeSetEnd()
oprot.writeFieldEnd()
if self.nosuch is not None:
oprot.writeFieldBegin('nosuch', TType.SET, 2)
oprot.writeSetBegin(TType.I64, len(self.nosuch))
- for iter552 in self.nosuch:
- oprot.writeI64(iter552)
+ for iter566 in self.nosuch:
+ oprot.writeI64(iter566)
oprot.writeSetEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11841,11 +12231,11 @@ class CompactionRequest:
elif fid == 6:
if ftype == TType.MAP:
self.properties = {}
- (_ktype554, _vtype555, _size553 ) = iprot.readMapBegin()
- for _i557 in xrange(_size553):
- _key558 = iprot.readString()
- _val559 = iprot.readString()
- self.properties[_key558] = _val559
+ (_ktype568, _vtype569, _size567 ) = iprot.readMapBegin()
+ for _i571 in xrange(_size567):
+ _key572 = iprot.readString()
+ _val573 = iprot.readString()
+ self.properties[_key572] = _val573
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -11882,9 +12272,9 @@ class CompactionRequest:
if self.properties is not None:
oprot.writeFieldBegin('properties', TType.MAP, 6)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties))
- for kiter560,viter561 in self.properties.items():
- oprot.writeString(kiter560)
- oprot.writeString(viter561)
+ for kiter574,viter575 in self.properties.items():
+ oprot.writeString(kiter574)
+ oprot.writeString(viter575)
oprot.writeMapEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12319,11 +12709,11 @@ class ShowCompactResponse:
if fid == 1:
if ftype == TType.LIST:
self.compacts = []
- (_etype565, _size562) = iprot.readListBegin()
- for _i566 in xrange(_size562):
- _elem567 = ShowCompactResponseElement()
- _elem567.read(iprot)
- self.compacts.append(_elem567)
+ (_etype579, _size576) = iprot.readListBegin()
+ for _i580 in xrange(_size576):
+ _elem581 = ShowCompactResponseElement()
+ _elem581.read(iprot)
+ self.compacts.append(_elem581)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12340,8 +12730,8 @@ class ShowCompactResponse:
if self.compacts is not None:
oprot.writeFieldBegin('compacts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.compacts))
- for iter568 in self.compacts:
- iter568.write(oprot)
+ for iter582 in self.compacts:
+ iter582.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12430,10 +12820,10 @@ class AddDynamicPartitions:
elif fid == 5:
if ftype == TType.LIST:
self.partitionnames = []
- (_etype572, _size569) = iprot.readListBegin()
- for _i573 in xrange(_size569):
- _elem574 = iprot.readString()
- self.partitionnames.append(_elem574)
+ (_etype586, _size583) = iprot.readListBegin()
+ for _i587 in xrange(_size583):
+ _elem588 = iprot.readString()
+ self.partitionnames.append(_elem588)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12471,8 +12861,8 @@ class AddDynamicPartitions:
if self.partitionnames is not None:
oprot.writeFieldBegin('partitionnames', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.partitionnames))
- for iter575 in self.partitionnames:
- oprot.writeString(iter575)
+ for iter589 in self.partitionnames:
+ oprot.writeString(iter589)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.operationType is not None:
@@ -12694,10 +13084,10 @@ class CreationMetadata:
elif fid == 3:
if ftype == TType.SET:
self.tablesUsed = set()
- (_etype579, _size576) = iprot.readSetBegin()
- for _i580 in xrange(_size576):
- _elem581 = iprot.readString()
- self.tablesUsed.add(_elem581)
+ (_etype593, _size590) = iprot.readSetBegin()
+ for _i594 in xrange(_size590):
+ _elem595 = iprot.readString()
+ self.tablesUsed.add(_elem595)
iprot.readSetEnd()
else:
iprot.skip(ftype)
@@ -12727,8 +13117,8 @@ class CreationMetadata:
if self.tablesUsed is not None:
oprot.writeFieldBegin('tablesUsed', TType.SET, 3)
oprot.writeSetBegin(TType.STRING, len(self.tablesUsed))
- for iter582 in self.tablesUsed:
- oprot.writeString(iter582)
+ for iter596 in self.tablesUsed:
+ oprot.writeString(iter596)
oprot.writeSetEnd()
oprot.writeFieldEnd()
if self.validTxnList is not None:
@@ -13024,11 +13414,11 @@ class NotificationEventResponse:
if fid == 1:
if ftype == TType.LIST:
self.events = []
- (_etype586, _size583) = iprot.readListBegin()
- for _i587 in xrange(_size583):
- _elem588 = NotificationEvent()
- _elem588.read(iprot)
- self.events.append(_elem588)
+ (_etype600, _size597) = iprot.readListBegin()
+ for _i601 in xrange(_size597):
+ _elem602 = NotificationEvent()
+ _elem602.read(iprot)
+ self.events.append(_elem602)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13045,8 +13435,8 @@ class NotificationEventResponse:
if self.events is not None:
oprot.writeFieldBegin('events', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.events))
- for iter589 in self.events:
- iter589.write(oprot)
+ for iter603 in self.events:
+ iter603.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13327,20 +13717,20 @@ class InsertEventRequestData:
elif fid == 2:
if ftype == TType.LIST:
self.filesAdded = []
- (_etype593, _size590) = iprot.readListBegin()
- for _i594 in xrange(_size590):
- _elem595 = iprot.readString()
- self.filesAdded.append(_elem595)
+ (_etype607, _size604) = iprot.readListBegin()
+ for _i608 in xrange(_size604):
+ _elem609 = iprot.readString()
+ self.filesAdded.append(_elem609)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.filesAddedChecksum = []
- (_etype599, _size596) = iprot.readListBegin()
- for _i600 in xrange(_size596):
- _elem601 = iprot.readString()
- self.filesAddedChecksum.append(_elem601)
+ (_etype613, _size610) = iprot.readListBegin()
+ for _i614 in xrange(_size610):
+ _elem615 = iprot.readString()
+ self.filesAddedChecksum.append(_elem615)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13361,15 +13751,15 @@ class InsertEventRequestData:
if self.filesAdded is not None:
oprot.writeFieldBegin('filesAdded', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.filesAdded))
- for iter602 in self.filesAdded:
- oprot.writeString(iter602)
+ for iter616 in self.filesAdded:
+ oprot.writeString(iter616)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.filesAddedChecksum is not None:
oprot.writeFieldBegin('filesAddedChecksum', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.filesAddedChecksum))
- for iter603 in self.filesAddedChecksum:
- oprot.writeString(iter603)
+ for iter617 in self.filesAddedChecksum:
+ oprot.writeString(iter617)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13524,10 +13914,10 @@ class FireEventRequest:
elif fid == 5:
if ftype == TType.LIST:
self.partitionVals = []
- (_etype607, _size604) = iprot.readListBegin()
- for _i608 in xrange(_size604):
- _elem609 = iprot.readString()
- self.partitionVals.append(_elem609)
+ (_etype621, _size618) = iprot.readListBegin()
+ for _i622 in xrange(_size618):
+ _elem623 = iprot.readString()
+ self.partitionVals.append(_elem623)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13560,8 +13950,8 @@ class FireEventRequest:
if self.partitionVals is not None:
oprot.writeFieldBegin('partitionVals', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.partitionVals))
- for iter610 in self.partitionVals:
- oprot.writeString(iter610)
+ for iter624 in self.partitionVals:
+ oprot.writeString(iter624)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13748,12 +14138,12 @@ class GetFileMetadataByExprResult:
if fid == 1:
if ftype == TType.MAP:
self.metadata = {}
- (_ktype612, _vtype613, _size611 ) = iprot.readMapBegin()
- for _i615 in xrange(_size611):
- _key616 = iprot.readI64()
- _val617 = MetadataPpdResult()
- _val617.read(iprot)
- self.metadata[_key616] = _val617
+ (_ktype626, _vtype627, _size625 ) = iprot.readMapBegin()
+ for _i629 in xrange(_size625):
+ _key630 = iprot.readI64()
+ _val631 = MetadataPpdResult()
+ _val631.read(iprot)
+ self.metadata[_key630] = _val631
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -13775,9 +14165,9 @@ class GetFileMetadataByExprResult:
if self.metadata is not None:
oprot.writeFieldBegin('metadata', TType.MAP, 1)
oprot.writeMapBegin(TType.I64, TType.STRUCT, len(self.metadata))
- for kiter618,viter619 in self.metadata.items():
- oprot.writeI64(kiter618)
- viter619.write(oprot)
+ for kiter632,viter633 in self.metadata.items():
+ oprot.writeI64(kiter632)
+ viter633.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.isSupported is not None:
@@ -13847,10 +14237,10 @@ class GetFileMetadataByExprRequest:
if fid == 1:
if ftype == TType.LIST:
self.fileIds = []
- (_etype623, _size620) = iprot.readListBegin()
- for _i624 in xrange(_size620):
- _elem625 = iprot.readI64()
- self.fileIds.append(_elem625)
+ (_etype637, _size634) = iprot.readListBegin()
+ for _i638 in xrange(_size634):
+ _elem639 = iprot.readI64()
+ self.fileIds.append(_elem639)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13882,8 +14272,8 @@ class GetFileMetadataByExprRequest:
if self.fileIds is not None:
oprot.writeFieldBegin('fileIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.fileIds))
- for iter626 in self.fileIds:
- oprot.writeI64(iter626)
+ for iter640 in self.fileIds:
+ oprot.writeI64(iter640)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.expr is not None:
@@ -13957,11 +14347,11 @@ class GetFileMetadataResult:
if fid == 1:
if ftype == TType.MAP:
self.metadata = {}
- (_ktype628, _vtype629, _size627 ) = iprot.readMapBegin()
- for _i631 in xrange(_size627):
- _key632 = iprot.readI64()
- _val633 = iprot.readString()
- self.metadata[_key632] = _val633
+ (_ktype642, _vtype643, _size641 ) = iprot.readMapBegin()
+ for _i645 in xrange(_size641):
+ _key646 = iprot.readI64()
+ _val647 = iprot.readString()
+ self.metadata[_key646] = _val647
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -13983,9 +14373,9 @@ class GetFileMetadataResult:
if self.metadata is not None:
oprot.writeFieldBegin('metadata', TType.MAP, 1)
oprot.writeMapBegin(TType.I64, TType.STRING, len(self.metadata))
- for kiter634,viter635 in self.metadata.items():
- oprot.writeI64(kiter634)
- oprot.writeString(viter635)
+ for kiter648,viter649 in self.metadata.items():
+ oprot.writeI64(kiter648)
+ oprot.writeString(viter649)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.isSupported is not None:
@@ -14046,10 +14436,10 @@ class GetFileMetadataRequest:
if fid == 1:
if ftype == TType.LIST:
self.fileIds = []
- (_etype639, _size636) = iprot.readListBegin()
- for _i640 in xrange(_size636):
- _elem641 = iprot.readI64()
- self.fileIds.append(_elem641)
+ (_etype653, _size650) = iprot.readListBegin()
+ for _i654 in xrange(_size650):
+ _elem655 = iprot.readI64()
+ self.fileIds.append(_elem655)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14066,8 +14456,8 @@ class GetFileMetadataRequest:
if self.fileIds is not None:
oprot.writeFieldBegin('fileIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.fileIds))
- for iter642 in self.fileIds:
- oprot.writeI64(iter642)
+ for iter656 in self.fileIds:
+ oprot.writeI64(iter656)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14173,20 +14563,20 @@ class PutFileMetadataRequest:
if fid == 1:
if ftype == TType.LIST:
self.fileIds = []
- (_etype646, _size643) = iprot.readListBegin()
- for _i647 in xrange(_size643):
- _elem648 = iprot.readI64()
- self.fileIds.append(_elem648)
+ (_etype660, _size657) = iprot.readListBegin()
+ for _i661 in xrange(_size657):
+ _elem662 = iprot.readI64()
+ self.fileIds.append(_elem662)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.LIST:
self.metadata = []
- (_etype652, _size649) = iprot.readListBegin()
- for _i653 in xrange(_size649):
- _elem654 = iprot.readString()
- self.metadata.append(_elem654)
+ (_etype666, _size663) = iprot.readListBegin()
+ for _i667 in xrange(_size663):
+ _elem668 = iprot.readString()
+ self.metadata.append(_elem668)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14208,15 +14598,15 @@ class PutFileMetadataRequest:
if self.fileIds is not None:
oprot.writeFieldBegin('fileIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.fileIds))
- for iter655 in self.fileIds:
- oprot.writeI64(iter655)
+ for iter669 in self.fileIds:
+ oprot.writeI64(iter669)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.metadata is not None:
oprot.writeFieldBegin('metadata', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.metadata))
- for iter656 in self.metadata:
- oprot.writeString(iter656)
+ for iter670 in self.metadata:
+ oprot.writeString(iter670)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.type is not None:
@@ -14324,10 +14714,10 @@ class ClearFileMetadataRequest:
if fid == 1:
if ftype == TType.LIST:
self.fileIds = []
- (_etype660, _size657) = iprot.readListBegin()
- for _i661 in xrange(_size657):
- _elem662 = iprot.readI64()
- self.fileIds.append(_elem662)
+ (_etype674, _size671) = iprot.readListBegin()
+ for _i675 in xrange(_size671):
+ _elem676 = iprot.readI64()
+ self.fileIds.append(_elem676)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14344,8 +14734,8 @@ class ClearFileMetadataRequest:
if self.fileIds is not None:
oprot.writeFieldBegin('fileIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.fileIds))
- for iter663 in self.fileIds:
- oprot.writeI64(iter663)
+ for iter677 in self.fileIds:
+ oprot.writeI64(iter677)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14574,11 +14964,11 @@ class GetAllFunctionsResponse:
if fid == 1:
if ftype == TType.LIST:
self.functions = []
- (_etype667, _size664) = iprot.readListBegin()
- for _i668 in xrange(_size664):
- _elem669 = Function()
- _elem669.read(iprot)
- self.functions.append(_elem669)
+ (_etype681, _size678) = iprot.readListBegin()
+ for _i682 in xrange(_size678):
+ _elem683 = Function()
+ _elem683.read(iprot)
+ self.functions.append(_elem683)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14595,8 +14985,8 @@ class GetAllFunctionsResponse:
if self.functions is not None:
oprot.writeFieldBegin('functions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.functions))
- for iter670 in self.functions:
- iter670.write(oprot)
+ for iter684 in self.functions:
+ iter684.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14648,10 +15038,10 @@ class ClientCapabilities:
if fid == 1:
if ftype == TType.LIST:
self.values = []
- (_etype674, _size671) = iprot.readListBegin()
- for _i675 in xrange(_size671):
- _elem676 = iprot.readI32()
- self.values.append(_elem676)
+ (_etype688, _size685) = iprot.readListBegin()
+ for _i689 in xrange(_size685):
+ _elem690 = iprot.readI32()
+ self.values.append(_elem690)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14668,8 +15058,8 @@ class ClientCapabilities:
if self.values is not None:
oprot.writeFieldBegin('values', TType.LIST, 1)
oprot.writeListBegin(TType.I32, len(self.values))
- for iter677 in self.values:
- oprot.writeI32(iter677)
+ for iter691 in self.values:
+ oprot.writeI32(iter691)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14898,10 +15288,10 @@ class GetTablesRequest:
elif fid == 2:
if ftype == TType.LIST:
self.tblNames = []
- (_etype681, _size678) = iprot.readListBegin()
- for _i682 in xrange(_size678):
- _elem683 = iprot.readString()
- self.tblNames.append(_elem683)
+ (_etype695, _size692) = iprot.readListBegin()
+ for _i696 in xrange(_size692):
+ _elem697 = iprot.readString()
+ self.tblNames.append(_elem697)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14928,8 +15318,8 @@ class GetTablesRequest:
if self.tblNames is not None:
oprot.writeFieldBegin('tblNames', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tblNames))
- for iter684 in self.tblNames:
- oprot.writeString(iter684)
+ for iter698 in self.tblNames:
+ oprot.writeString(iter698)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.capabilities is not None:
@@ -14989,11 +15379,11 @@ class GetTablesResult:
if fid == 1:
if ftype == TType.LIST:
self.tables = []
- (_etype688, _size685) = iprot.readListBegin()
- for _i689 in xrange(_size685):
- _elem690 = Table()
- _elem690.read(iprot)
- self.tables.append(_elem690)
+ (_etype702, _size699) = iprot.readListBegin()
+ for _i703 in xrange(_size699):
+ _elem704 = Table()
+ _elem704.read(iprot)
+ self.tables.append(_elem704)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15010,8 +15400,8 @@ class GetTablesResult:
if self.tables is not None:
oprot.writeFieldBegin('tables', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.tables))
- for iter691 in self.tables:
- iter691.write(oprot)
+ for iter705 in self.tables:
+ iter705.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15309,10 +15699,10 @@ class Materialization:
if fid == 1:
if ftype == TType.SET:
self.tablesUsed = set()
- (_etype695, _size692) = iprot.readSetBegin()
- for _i696 in xrange(_size692):
- _elem697 = iprot.readString()
- self.tablesUsed.add(_elem697)
+ (_etype709, _size706) = iprot.readSetBegin()
+ for _i710 in xrange(_size706):
+ _elem711 = iprot.readString()
+ self.tablesUsed.add(_elem711)
iprot.readSetEnd()
else:
iprot.skip(ftype)
@@ -15339,8 +15729,8 @@ class Materialization:
if self.tablesUsed is not None:
oprot.writeFieldBegin('tablesUsed', TType.SET, 1)
oprot.writeSetBegin(TType.STRING, len(self.tablesUsed))
- for iter698 in self.tablesUsed:
- oprot.writeString(iter698)
+ for iter712 in self.tablesUsed:
+ oprot.writeString(iter712)
oprot.writeSetEnd()
oprot.writeFieldEnd()
if self.validTxnList is not None:
@@ -16244,44 +16634,44 @@ class WMFullResourcePlan:
elif fid == 2:
if ftype == TType.LIST:
self.pools = []
- (_etype702, _size699) = iprot.readListBegin()
- for _i703 in xrange(_size699):
- _elem704 = WMPool()
- _elem704.read(iprot)
- self.pools.append(_elem704)
+ (_etype716, _size713) = iprot.readListBegin()
+ for _i717 in xrange(_size713):
+ _elem718 = WMPool()
+ _elem718.read(iprot)
+ self.pools.append(_elem718)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.mappings = []
- (_etype708, _size705) = iprot.readListBegin()
- for _i709 in xrange(_size705):
- _elem710 = WMMapping()
- _elem710.read(iprot)
- self.mappings.append(_elem710)
+ (_etype722, _size719) = iprot.readListBegin()
+ for _i723 in xrange(_size719):
+ _elem724 = WMMapping()
+ _elem724.read(iprot)
+ self.mappings.append(_elem724)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.triggers = []
- (_etype714, _size711) = iprot.readListBegin()
- for _i715 in xrange(_size711):
- _elem716 = WMTrigger()
- _elem716.read(iprot)
- self.triggers.append(_elem716)
+ (_etype728, _size725) = iprot.readListBegin()
+ for _i729 in xrange(_size725):
+ _elem730 = WMTrigger()
+ _elem730.read(iprot)
+ self.triggers.append(_elem730)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.poolTriggers = []
- (_etype720, _size717) = iprot.readListBegin()
- for _i721 in xrange(_size717):
- _elem722 = WMPoolTrigger()
- _elem722.read(iprot)
- self.poolTriggers.append(_elem722)
+ (_etype734, _size731) = iprot.readListBegin()
+ for _i735 in xrange(_size731):
+ _elem736 = WMPoolTrigger()
+ _elem736.read(iprot)
+ self.poolTriggers.append(_elem736)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16302,29 +16692,29 @@ class WMFullResourcePlan:
if self.pools is not None:
oprot.writeFieldBegin('pools', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.pools))
- for iter723 in self.pools:
- iter723.write(oprot)
+ for iter737 in self.pools:
+ iter737.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.mappings is not None:
oprot.writeFieldBegin('mappings', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.mappings))
- for iter724 in self.mappings:
- iter724.write(oprot)
+ for iter738 in self.mappings:
+ iter738.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.triggers is not None:
oprot.writeFieldBegin('triggers', TType.LIST, 4)
oprot.writeListBegin(TType.STRUCT, len(self.triggers))
- for iter725 in self.triggers:
- iter725.write(oprot)
+ for iter739 in self.triggers:
+ iter739.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.poolTriggers is not None:
oprot.writeFieldBegin('poolTriggers', TType.LIST, 5)
oprot.writeListBegin(TType.STRUCT, len(self.poolTriggers))
- for iter726 in self.poolTriggers:
- iter726.write(oprot)
+ for iter740 in self.poolTriggers:
+ iter740.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16798,11 +17188,11 @@ class WMGetAllResourcePlanResponse:
if fid == 1:
if ftype == TType.LIST:
self.resourcePlans = []
- (_etype730, _size727) = iprot.readListBegin()
- for _i731 in xrange(_size727):
- _elem732 = WMResourcePlan()
- _elem732.read(iprot)
- self.resourcePlans.append(_elem732)
+ (_etype744, _size741) = iprot.readListBegin()
+ for _i745 in xrange(_size741):
+ _elem746 = WMResourcePlan()
+ _elem746.read(iprot)
+ self.resourcePlans.append(_elem746)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16819,8 +17209,8 @@ class WMGetAllResourcePlanResponse:
if self.resourcePlans is not None:
oprot.writeFieldBegin('resourcePlans', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.resourcePlans))
- for iter733 in self.resourcePlans:
- iter733.write(oprot)
+ for iter747 in self.resourcePlans:
+ iter747.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17124,20 +17514,20 @@ class WMValidateResourcePlanResponse:
if fid == 1:
if ftype == TType.LIST:
self.errors = []
- (_etype737, _size734) = iprot.readListBegin()
- for _i738 in xrange(_size734):
- _elem739 = iprot.readString()
- self.errors.append(_elem739)
+ (_etype751, _size748) = iprot.readListBegin()
+ for _i752 in xrange(_size748):
+ _elem753 = iprot.readString()
+ self.errors.append(_elem753)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.LIST:
self.warnings = []
- (_etype743, _size740) = iprot.readListBegin()
- for _i744 in xrange(_size740):
- _elem745 = iprot.readString()
- self.warnings.append(_elem745)
+ (_etype757, _size754) = iprot.readListBegin()
+ for _i758 in xrange(_size754):
+ _elem759 = iprot.readString()
+ self.warnings.append(_elem759)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17154,15 +17544,15 @@ class WMValidateResourcePlanResponse:
if self.errors is not None:
oprot.writeFieldBegin('errors', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.errors))
- for iter746 in self.errors:
- oprot.writeString(iter746)
+ for iter760 in self.errors:
+ oprot.writeString(iter760)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.warnings is not None:
oprot.writeFieldBegin('warnings', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.warnings))
- for iter747 in self.warnings:
- oprot.writeString(iter747)
+ for iter761 in self.warnings:
+ oprot.writeString(iter761)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17739,11 +18129,11 @@ class WMGetTriggersForResourePlanResponse:
if fid == 1:
if ftype == TType.LIST:
self.triggers = []
- (_etype751, _size748) = iprot.readListBegin()
- for _i752 in xrange(_size748):
- _elem753 = WMTrigger()
- _elem753.read(iprot)
- self.triggers.append(_elem753)
+ (_etype765, _size762) = iprot.readListBegin()
+ for _i766 in xrange(_size762):
+ _elem767 = WMTrigger()
+ _elem767.read(iprot)
+ self.triggers.append(_elem767)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17760,8 +18150,8 @@ class WMGetTriggersForResourePlanResponse:
if self.triggers is not None:
oprot.writeFieldBegin('triggers', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.triggers))
- for iter754 in self.triggers:
- iter754.write(oprot)
+ for iter768 in self.triggers:
+ iter768.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
http://git-wip-us.apache.org/repos/asf/hive/blob/4047befe/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 625baae..8438728 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
@@ -308,6 +308,36 @@ class SQLNotNullConstraint
::Thrift::Struct.generate_accessors self
end
+class SQLDefaultConstraint
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ TABLE_DB = 1
+ TABLE_NAME = 2
+ COLUMN_NAME = 3
+ DEFAULT_VALUE = 4
+ DC_NAME = 5
+ ENABLE_CSTR = 6
+ VALIDATE_CSTR = 7
+ RELY_CSTR = 8
+
+ FIELDS = {
+ TABLE_DB => {:type => ::Thrift::Types::STRING, :name => 'table_db'},
+ TABLE_NAME => {:type => ::Thrift::Types::STRING, :name => 'table_name'},
+ COLUMN_NAME => {:type => ::Thrift::Types::STRING, :name => 'column_name'},
+ DEFAULT_VALUE => {:type => ::Thrift::Types::STRING, :name => 'default_value'},
+ DC_NAME => {:type => ::Thrift::Types::STRING, :name => 'dc_name'},
+ ENABLE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'enable_cstr'},
+ VALIDATE_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'validate_cstr'},
+ RELY_CSTR => {:type => ::Thrift::Types::BOOL, :name => 'rely_cstr'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
class Type
include ::Thrift::Struct, ::Thrift::Struct_Union
NAME = 1
@@ -1557,6 +1587,43 @@ class NotNullConstraintsResponse
::Thrift::Struct.generate_accessors self
end
+class DefaultConstraintsRequest
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ DB_NAME = 1
+ TBL_NAME = 2
+
+ FIELDS = {
+ DB_NAME => {:type => ::Thrift::Types::STRING, :name => 'db_name'},
+ TBL_NAME => {:type => ::Thrift::Types::STRING, :name => 'tbl_name'}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field db_name is unset!') unless @db_name
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tbl_name is unset!') unless @tbl_name
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
+class DefaultConstraintsResponse
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ DEFAULTCONSTRAINTS = 1
+
+ FIELDS = {
+ DEFAULTCONSTRAINTS => {:type => ::Thrift::Types::LIST, :name => 'defaultConstraints', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLDefaultConstraint}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field defaultConstraints is unset!') unless @defaultConstraints
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
class DropConstraintRequest
include ::Thrift::Struct, ::Thrift::Struct_Union
DBNAME = 1
@@ -1648,6 +1715,23 @@ class AddNotNullConstraintRequest
::Thrift::Struct.generate_accessors self
end
+class AddDefaultConstraintRequest
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ DEFAULTCONSTRAINTCOLS = 1
+
+ FIELDS = {
+ DEFAULTCONSTRAINTCOLS => {:type => ::Thrift::Types::LIST, :name => 'defaultConstraintCols', :element => {:type => ::Thrift::Types::STRUCT, :class => ::SQLDefaultConstraint}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field defaultConstraintCols is unset!') unless @defaultConstraintCols
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
class PartitionsByExprResult
include ::Thrift::Struct, ::Thrift::Struct_Union
PARTITIONS = 1