You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2018/05/02 06:45:27 UTC
[03/14] hive git commit: HIVE-18988: Support bootstrap replication of
ACID tables (Sankar Hariappan, reviewed by Mahesh Kumar Behera, Thejas M Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index d94951b..49d966f 100644
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -1175,6 +1175,13 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def repl_tbl_writeid_state(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ pass
+
def get_valid_write_ids(self, rqst):
"""
Parameters:
@@ -6881,6 +6888,35 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
return
+ def repl_tbl_writeid_state(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ self.send_repl_tbl_writeid_state(rqst)
+ self.recv_repl_tbl_writeid_state()
+
+ def send_repl_tbl_writeid_state(self, rqst):
+ self._oprot.writeMessageBegin('repl_tbl_writeid_state', TMessageType.CALL, self._seqid)
+ args = repl_tbl_writeid_state_args()
+ args.rqst = rqst
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_repl_tbl_writeid_state(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = repl_tbl_writeid_state_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ return
+
def get_valid_write_ids(self, rqst):
"""
Parameters:
@@ -9026,6 +9062,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["abort_txn"] = Processor.process_abort_txn
self._processMap["abort_txns"] = Processor.process_abort_txns
self._processMap["commit_txn"] = Processor.process_commit_txn
+ self._processMap["repl_tbl_writeid_state"] = Processor.process_repl_tbl_writeid_state
self._processMap["get_valid_write_ids"] = Processor.process_get_valid_write_ids
self._processMap["allocate_table_write_ids"] = Processor.process_allocate_table_write_ids
self._processMap["lock"] = Processor.process_lock
@@ -12717,6 +12754,25 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_repl_tbl_writeid_state(self, seqid, iprot, oprot):
+ args = repl_tbl_writeid_state_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = repl_tbl_writeid_state_result()
+ try:
+ self._handler.repl_tbl_writeid_state(args.rqst)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("repl_tbl_writeid_state", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_get_valid_write_ids(self, seqid, iprot, oprot):
args = get_valid_write_ids_args()
args.read(iprot)
@@ -15631,10 +15687,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype812, _size809) = iprot.readListBegin()
- for _i813 in xrange(_size809):
- _elem814 = iprot.readString()
- self.success.append(_elem814)
+ (_etype819, _size816) = iprot.readListBegin()
+ for _i820 in xrange(_size816):
+ _elem821 = iprot.readString()
+ self.success.append(_elem821)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15657,8 +15713,8 @@ class get_databases_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter815 in self.success:
- oprot.writeString(iter815)
+ for iter822 in self.success:
+ oprot.writeString(iter822)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15763,10 +15819,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype819, _size816) = iprot.readListBegin()
- for _i820 in xrange(_size816):
- _elem821 = iprot.readString()
- self.success.append(_elem821)
+ (_etype826, _size823) = iprot.readListBegin()
+ for _i827 in xrange(_size823):
+ _elem828 = iprot.readString()
+ self.success.append(_elem828)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15789,8 +15845,8 @@ class get_all_databases_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter822 in self.success:
- oprot.writeString(iter822)
+ for iter829 in self.success:
+ oprot.writeString(iter829)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16560,12 +16616,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype824, _vtype825, _size823 ) = iprot.readMapBegin()
- for _i827 in xrange(_size823):
- _key828 = iprot.readString()
- _val829 = Type()
- _val829.read(iprot)
- self.success[_key828] = _val829
+ (_ktype831, _vtype832, _size830 ) = iprot.readMapBegin()
+ for _i834 in xrange(_size830):
+ _key835 = iprot.readString()
+ _val836 = Type()
+ _val836.read(iprot)
+ self.success[_key835] = _val836
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16588,9 +16644,9 @@ class get_type_all_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter830,viter831 in self.success.items():
- oprot.writeString(kiter830)
- viter831.write(oprot)
+ for kiter837,viter838 in self.success.items():
+ oprot.writeString(kiter837)
+ viter838.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -16733,11 +16789,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype835, _size832) = iprot.readListBegin()
- for _i836 in xrange(_size832):
- _elem837 = FieldSchema()
- _elem837.read(iprot)
- self.success.append(_elem837)
+ (_etype842, _size839) = iprot.readListBegin()
+ for _i843 in xrange(_size839):
+ _elem844 = FieldSchema()
+ _elem844.read(iprot)
+ self.success.append(_elem844)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16772,8 +16828,8 @@ class get_fields_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter838 in self.success:
- iter838.write(oprot)
+ for iter845 in self.success:
+ iter845.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16940,199 +16996,6 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype842, _size839) = iprot.readListBegin()
- for _i843 in xrange(_size839):
- _elem844 = FieldSchema()
- _elem844.read(iprot)
- self.success.append(_elem844)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.o1 = MetaException()
- self.o1.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
- self.o2 = UnknownTableException()
- self.o2.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRUCT:
- self.o3 = UnknownDBException()
- self.o3.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_fields_with_environment_context_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter845 in self.success:
- iter845.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.o1 is not None:
- oprot.writeFieldBegin('o1', TType.STRUCT, 1)
- self.o1.write(oprot)
- oprot.writeFieldEnd()
- if self.o2 is not None:
- oprot.writeFieldBegin('o2', TType.STRUCT, 2)
- self.o2.write(oprot)
- oprot.writeFieldEnd()
- if self.o3 is not None:
- oprot.writeFieldBegin('o3', TType.STRUCT, 3)
- self.o3.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.o1)
- value = (value * 31) ^ hash(self.o2)
- value = (value * 31) ^ hash(self.o3)
- 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 get_schema_args:
- """
- Attributes:
- - db_name
- - table_name
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'db_name', None, None, ), # 1
- (2, TType.STRING, 'table_name', None, None, ), # 2
- )
-
- def __init__(self, db_name=None, table_name=None,):
- self.db_name = db_name
- self.table_name = table_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.table_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('get_schema_args')
- if self.db_name is not None:
- oprot.writeFieldBegin('db_name', TType.STRING, 1)
- oprot.writeString(self.db_name)
- oprot.writeFieldEnd()
- if self.table_name is not None:
- oprot.writeFieldBegin('table_name', TType.STRING, 2)
- oprot.writeString(self.table_name)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.db_name)
- value = (value * 31) ^ hash(self.table_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 get_schema_result:
- """
- Attributes:
- - success
- - o1
- - o2
- - o3
- """
-
- thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 0
- (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'o2', (UnknownTableException, UnknownTableException.thrift_spec), None, ), # 2
- (3, TType.STRUCT, 'o3', (UnknownDBException, UnknownDBException.thrift_spec), None, ), # 3
- )
-
- def __init__(self, success=None, o1=None, o2=None, o3=None,):
- self.success = success
- self.o1 = o1
- self.o2 = o2
- self.o3 = o3
-
- 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 == 0:
- if ftype == TType.LIST:
- self.success = []
(_etype849, _size846) = iprot.readListBegin()
for _i850 in xrange(_size846):
_elem851 = FieldSchema()
@@ -17168,7 +17031,7 @@ class get_schema_result:
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('get_schema_result')
+ oprot.writeStructBegin('get_fields_with_environment_context_result')
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
@@ -17214,6 +17077,199 @@ class get_schema_result:
def __ne__(self, other):
return not (self == other)
+class get_schema_args:
+ """
+ Attributes:
+ - db_name
+ - table_name
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'table_name', None, None, ), # 2
+ )
+
+ def __init__(self, db_name=None, table_name=None,):
+ self.db_name = db_name
+ self.table_name = table_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.table_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('get_schema_args')
+ if self.db_name is not None:
+ oprot.writeFieldBegin('db_name', TType.STRING, 1)
+ oprot.writeString(self.db_name)
+ oprot.writeFieldEnd()
+ if self.table_name is not None:
+ oprot.writeFieldBegin('table_name', TType.STRING, 2)
+ oprot.writeString(self.table_name)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.db_name)
+ value = (value * 31) ^ hash(self.table_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 get_schema_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ - o3
+ """
+
+ thrift_spec = (
+ (0, TType.LIST, 'success', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (UnknownTableException, UnknownTableException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'o3', (UnknownDBException, UnknownDBException.thrift_spec), None, ), # 3
+ )
+
+ def __init__(self, success=None, o1=None, o2=None, o3=None,):
+ self.success = success
+ self.o1 = o1
+ self.o2 = o2
+ self.o3 = o3
+
+ 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 == 0:
+ if ftype == TType.LIST:
+ self.success = []
+ (_etype856, _size853) = iprot.readListBegin()
+ for _i857 in xrange(_size853):
+ _elem858 = FieldSchema()
+ _elem858.read(iprot)
+ self.success.append(_elem858)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = MetaException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.o2 = UnknownTableException()
+ self.o2.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.o3 = UnknownDBException()
+ self.o3.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_schema_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRUCT, len(self.success))
+ for iter859 in self.success:
+ iter859.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.o1 is not None:
+ oprot.writeFieldBegin('o1', TType.STRUCT, 1)
+ self.o1.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o2 is not None:
+ oprot.writeFieldBegin('o2', TType.STRUCT, 2)
+ self.o2.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o3 is not None:
+ oprot.writeFieldBegin('o3', TType.STRUCT, 3)
+ self.o3.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.o1)
+ value = (value * 31) ^ hash(self.o2)
+ value = (value * 31) ^ hash(self.o3)
+ 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 get_schema_with_environment_context_args:
"""
Attributes:
@@ -17340,11 +17396,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype856, _size853) = iprot.readListBegin()
- for _i857 in xrange(_size853):
- _elem858 = FieldSchema()
- _elem858.read(iprot)
- self.success.append(_elem858)
+ (_etype863, _size860) = iprot.readListBegin()
+ for _i864 in xrange(_size860):
+ _elem865 = FieldSchema()
+ _elem865.read(iprot)
+ self.success.append(_elem865)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17379,8 +17435,8 @@ class get_schema_with_environment_context_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter859 in self.success:
- iter859.write(oprot)
+ for iter866 in self.success:
+ iter866.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17833,66 +17889,66 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype863, _size860) = iprot.readListBegin()
- for _i864 in xrange(_size860):
- _elem865 = SQLPrimaryKey()
- _elem865.read(iprot)
- self.primaryKeys.append(_elem865)
+ (_etype870, _size867) = iprot.readListBegin()
+ for _i871 in xrange(_size867):
+ _elem872 = SQLPrimaryKey()
+ _elem872.read(iprot)
+ self.primaryKeys.append(_elem872)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype869, _size866) = iprot.readListBegin()
- for _i870 in xrange(_size866):
- _elem871 = SQLForeignKey()
- _elem871.read(iprot)
- self.foreignKeys.append(_elem871)
+ (_etype876, _size873) = iprot.readListBegin()
+ for _i877 in xrange(_size873):
+ _elem878 = SQLForeignKey()
+ _elem878.read(iprot)
+ self.foreignKeys.append(_elem878)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype875, _size872) = iprot.readListBegin()
- for _i876 in xrange(_size872):
- _elem877 = SQLUniqueConstraint()
- _elem877.read(iprot)
- self.uniqueConstraints.append(_elem877)
+ (_etype882, _size879) = iprot.readListBegin()
+ for _i883 in xrange(_size879):
+ _elem884 = SQLUniqueConstraint()
+ _elem884.read(iprot)
+ self.uniqueConstraints.append(_elem884)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype881, _size878) = iprot.readListBegin()
- for _i882 in xrange(_size878):
- _elem883 = SQLNotNullConstraint()
- _elem883.read(iprot)
- self.notNullConstraints.append(_elem883)
+ (_etype888, _size885) = iprot.readListBegin()
+ for _i889 in xrange(_size885):
+ _elem890 = SQLNotNullConstraint()
+ _elem890.read(iprot)
+ self.notNullConstraints.append(_elem890)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.LIST:
self.defaultConstraints = []
- (_etype887, _size884) = iprot.readListBegin()
- for _i888 in xrange(_size884):
- _elem889 = SQLDefaultConstraint()
- _elem889.read(iprot)
- self.defaultConstraints.append(_elem889)
+ (_etype894, _size891) = iprot.readListBegin()
+ for _i895 in xrange(_size891):
+ _elem896 = SQLDefaultConstraint()
+ _elem896.read(iprot)
+ self.defaultConstraints.append(_elem896)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 7:
if ftype == TType.LIST:
self.checkConstraints = []
- (_etype893, _size890) = iprot.readListBegin()
- for _i894 in xrange(_size890):
- _elem895 = SQLCheckConstraint()
- _elem895.read(iprot)
- self.checkConstraints.append(_elem895)
+ (_etype900, _size897) = iprot.readListBegin()
+ for _i901 in xrange(_size897):
+ _elem902 = SQLCheckConstraint()
+ _elem902.read(iprot)
+ self.checkConstraints.append(_elem902)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17913,43 +17969,43 @@ class create_table_with_constraints_args:
if self.primaryKeys is not None:
oprot.writeFieldBegin('primaryKeys', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys))
- for iter896 in self.primaryKeys:
- iter896.write(oprot)
+ for iter903 in self.primaryKeys:
+ iter903.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.foreignKeys is not None:
oprot.writeFieldBegin('foreignKeys', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.foreignKeys))
- for iter897 in self.foreignKeys:
- iter897.write(oprot)
+ for iter904 in self.foreignKeys:
+ iter904.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.uniqueConstraints is not None:
oprot.writeFieldBegin('uniqueConstraints', TType.LIST, 4)
oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraints))
- for iter898 in self.uniqueConstraints:
- iter898.write(oprot)
+ for iter905 in self.uniqueConstraints:
+ iter905.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.notNullConstraints is not None:
oprot.writeFieldBegin('notNullConstraints', TType.LIST, 5)
oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraints))
- for iter899 in self.notNullConstraints:
- iter899.write(oprot)
+ for iter906 in self.notNullConstraints:
+ iter906.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.defaultConstraints is not None:
oprot.writeFieldBegin('defaultConstraints', TType.LIST, 6)
oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints))
- for iter900 in self.defaultConstraints:
- iter900.write(oprot)
+ for iter907 in self.defaultConstraints:
+ iter907.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.checkConstraints is not None:
oprot.writeFieldBegin('checkConstraints', TType.LIST, 7)
oprot.writeListBegin(TType.STRUCT, len(self.checkConstraints))
- for iter901 in self.checkConstraints:
- iter901.write(oprot)
+ for iter908 in self.checkConstraints:
+ iter908.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19509,10 +19565,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype905, _size902) = iprot.readListBegin()
- for _i906 in xrange(_size902):
- _elem907 = iprot.readString()
- self.partNames.append(_elem907)
+ (_etype912, _size909) = iprot.readListBegin()
+ for _i913 in xrange(_size909):
+ _elem914 = iprot.readString()
+ self.partNames.append(_elem914)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19537,8 +19593,8 @@ class truncate_table_args:
if self.partNames is not None:
oprot.writeFieldBegin('partNames', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.partNames))
- for iter908 in self.partNames:
- oprot.writeString(iter908)
+ for iter915 in self.partNames:
+ oprot.writeString(iter915)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19738,10 +19794,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype912, _size909) = iprot.readListBegin()
- for _i913 in xrange(_size909):
- _elem914 = iprot.readString()
- self.success.append(_elem914)
+ (_etype919, _size916) = iprot.readListBegin()
+ for _i920 in xrange(_size916):
+ _elem921 = iprot.readString()
+ self.success.append(_elem921)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19764,8 +19820,8 @@ class get_tables_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter915 in self.success:
- oprot.writeString(iter915)
+ for iter922 in self.success:
+ oprot.writeString(iter922)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19915,10 +19971,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype919, _size916) = iprot.readListBegin()
- for _i920 in xrange(_size916):
- _elem921 = iprot.readString()
- self.success.append(_elem921)
+ (_etype926, _size923) = iprot.readListBegin()
+ for _i927 in xrange(_size923):
+ _elem928 = iprot.readString()
+ self.success.append(_elem928)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19941,8 +19997,8 @@ class get_tables_by_type_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter922 in self.success:
- oprot.writeString(iter922)
+ for iter929 in self.success:
+ oprot.writeString(iter929)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20066,10 +20122,10 @@ class get_materialized_views_for_rewriting_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype926, _size923) = iprot.readListBegin()
- for _i927 in xrange(_size923):
- _elem928 = iprot.readString()
- self.success.append(_elem928)
+ (_etype933, _size930) = iprot.readListBegin()
+ for _i934 in xrange(_size930):
+ _elem935 = iprot.readString()
+ self.success.append(_elem935)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20092,8 +20148,8 @@ class get_materialized_views_for_rewriting_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter929 in self.success:
- oprot.writeString(iter929)
+ for iter936 in self.success:
+ oprot.writeString(iter936)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20166,10 +20222,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype933, _size930) = iprot.readListBegin()
- for _i934 in xrange(_size930):
- _elem935 = iprot.readString()
- self.tbl_types.append(_elem935)
+ (_etype940, _size937) = iprot.readListBegin()
+ for _i941 in xrange(_size937):
+ _elem942 = iprot.readString()
+ self.tbl_types.append(_elem942)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20194,8 +20250,8 @@ class get_table_meta_args:
if self.tbl_types is not None:
oprot.writeFieldBegin('tbl_types', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.tbl_types))
- for iter936 in self.tbl_types:
- oprot.writeString(iter936)
+ for iter943 in self.tbl_types:
+ oprot.writeString(iter943)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20251,11 +20307,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype940, _size937) = iprot.readListBegin()
- for _i941 in xrange(_size937):
- _elem942 = TableMeta()
- _elem942.read(iprot)
- self.success.append(_elem942)
+ (_etype947, _size944) = iprot.readListBegin()
+ for _i948 in xrange(_size944):
+ _elem949 = TableMeta()
+ _elem949.read(iprot)
+ self.success.append(_elem949)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20278,8 +20334,8 @@ class get_table_meta_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter943 in self.success:
- iter943.write(oprot)
+ for iter950 in self.success:
+ iter950.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20403,10 +20459,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype947, _size944) = iprot.readListBegin()
- for _i948 in xrange(_size944):
- _elem949 = iprot.readString()
- self.success.append(_elem949)
+ (_etype954, _size951) = iprot.readListBegin()
+ for _i955 in xrange(_size951):
+ _elem956 = iprot.readString()
+ self.success.append(_elem956)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20429,8 +20485,8 @@ class get_all_tables_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter950 in self.success:
- oprot.writeString(iter950)
+ for iter957 in self.success:
+ oprot.writeString(iter957)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20666,10 +20722,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype954, _size951) = iprot.readListBegin()
- for _i955 in xrange(_size951):
- _elem956 = iprot.readString()
- self.tbl_names.append(_elem956)
+ (_etype961, _size958) = iprot.readListBegin()
+ for _i962 in xrange(_size958):
+ _elem963 = iprot.readString()
+ self.tbl_names.append(_elem963)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20690,8 +20746,8 @@ class get_table_objects_by_name_args:
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter957 in self.tbl_names:
- oprot.writeString(iter957)
+ for iter964 in self.tbl_names:
+ oprot.writeString(iter964)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20743,11 +20799,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype961, _size958) = iprot.readListBegin()
- for _i962 in xrange(_size958):
- _elem963 = Table()
- _elem963.read(iprot)
- self.success.append(_elem963)
+ (_etype968, _size965) = iprot.readListBegin()
+ for _i969 in xrange(_size965):
+ _elem970 = Table()
+ _elem970.read(iprot)
+ self.success.append(_elem970)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20764,8 +20820,8 @@ class get_table_objects_by_name_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter964 in self.success:
- iter964.write(oprot)
+ for iter971 in self.success:
+ iter971.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21157,10 +21213,10 @@ class get_materialization_invalidation_info_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype968, _size965) = iprot.readListBegin()
- for _i969 in xrange(_size965):
- _elem970 = iprot.readString()
- self.tbl_names.append(_elem970)
+ (_etype975, _size972) = iprot.readListBegin()
+ for _i976 in xrange(_size972):
+ _elem977 = iprot.readString()
+ self.tbl_names.append(_elem977)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21181,8 +21237,8 @@ class get_materialization_invalidation_info_args:
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter971 in self.tbl_names:
- oprot.writeString(iter971)
+ for iter978 in self.tbl_names:
+ oprot.writeString(iter978)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21243,12 +21299,12 @@ class get_materialization_invalidation_info_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype973, _vtype974, _size972 ) = iprot.readMapBegin()
- for _i976 in xrange(_size972):
- _key977 = iprot.readString()
- _val978 = Materialization()
- _val978.read(iprot)
- self.success[_key977] = _val978
+ (_ktype980, _vtype981, _size979 ) = iprot.readMapBegin()
+ for _i983 in xrange(_size979):
+ _key984 = iprot.readString()
+ _val985 = Materialization()
+ _val985.read(iprot)
+ self.success[_key984] = _val985
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21283,9 +21339,9 @@ class get_materialization_invalidation_info_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter979,viter980 in self.success.items():
- oprot.writeString(kiter979)
- viter980.write(oprot)
+ for kiter986,viter987 in self.success.items():
+ oprot.writeString(kiter986)
+ viter987.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21650,10 +21706,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype984, _size981) = iprot.readListBegin()
- for _i985 in xrange(_size981):
- _elem986 = iprot.readString()
- self.success.append(_elem986)
+ (_etype991, _size988) = iprot.readListBegin()
+ for _i992 in xrange(_size988):
+ _elem993 = iprot.readString()
+ self.success.append(_elem993)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21688,8 +21744,8 @@ class get_table_names_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter987 in self.success:
- oprot.writeString(iter987)
+ for iter994 in self.success:
+ oprot.writeString(iter994)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22659,11 +22715,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype991, _size988) = iprot.readListBegin()
- for _i992 in xrange(_size988):
- _elem993 = Partition()
- _elem993.read(iprot)
- self.new_parts.append(_elem993)
+ (_etype998, _size995) = iprot.readListBegin()
+ for _i999 in xrange(_size995):
+ _elem1000 = Partition()
+ _elem1000.read(iprot)
+ self.new_parts.append(_elem1000)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22680,8 +22736,8 @@ class add_partitions_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter994 in self.new_parts:
- iter994.write(oprot)
+ for iter1001 in self.new_parts:
+ iter1001.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22839,11 +22895,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype998, _size995) = iprot.readListBegin()
- for _i999 in xrange(_size995):
- _elem1000 = PartitionSpec()
- _elem1000.read(iprot)
- self.new_parts.append(_elem1000)
+ (_etype1005, _size1002) = iprot.readListBegin()
+ for _i1006 in xrange(_size1002):
+ _elem1007 = PartitionSpec()
+ _elem1007.read(iprot)
+ self.new_parts.append(_elem1007)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22860,8 +22916,8 @@ class add_partitions_pspec_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter1001 in self.new_parts:
- iter1001.write(oprot)
+ for iter1008 in self.new_parts:
+ iter1008.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23035,10 +23091,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1005, _size1002) = iprot.readListBegin()
- for _i1006 in xrange(_size1002):
- _elem1007 = iprot.readString()
- self.part_vals.append(_elem1007)
+ (_etype1012, _size1009) = iprot.readListBegin()
+ for _i1013 in xrange(_size1009):
+ _elem1014 = iprot.readString()
+ self.part_vals.append(_elem1014)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23063,8 +23119,8 @@ class append_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1008 in self.part_vals:
- oprot.writeString(iter1008)
+ for iter1015 in self.part_vals:
+ oprot.writeString(iter1015)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23417,10 +23473,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1012, _size1009) = iprot.readListBegin()
- for _i1013 in xrange(_size1009):
- _elem1014 = iprot.readString()
- self.part_vals.append(_elem1014)
+ (_etype1019, _size1016) = iprot.readListBegin()
+ for _i1020 in xrange(_size1016):
+ _elem1021 = iprot.readString()
+ self.part_vals.append(_elem1021)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23451,8 +23507,8 @@ class append_partition_with_environment_context_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1015 in self.part_vals:
- oprot.writeString(iter1015)
+ for iter1022 in self.part_vals:
+ oprot.writeString(iter1022)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -24047,10 +24103,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1019, _size1016) = iprot.readListBegin()
- for _i1020 in xrange(_size1016):
- _elem1021 = iprot.readString()
- self.part_vals.append(_elem1021)
+ (_etype1026, _size1023) = iprot.readListBegin()
+ for _i1027 in xrange(_size1023):
+ _elem1028 = iprot.readString()
+ self.part_vals.append(_elem1028)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24080,8 +24136,8 @@ class drop_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1022 in self.part_vals:
- oprot.writeString(iter1022)
+ for iter1029 in self.part_vals:
+ oprot.writeString(iter1029)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -24254,10 +24310,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1026, _size1023) = iprot.readListBegin()
- for _i1027 in xrange(_size1023):
- _elem1028 = iprot.readString()
- self.part_vals.append(_elem1028)
+ (_etype1033, _size1030) = iprot.readListBegin()
+ for _i1034 in xrange(_size1030):
+ _elem1035 = iprot.readString()
+ self.part_vals.append(_elem1035)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24293,8 +24349,8 @@ class drop_partition_with_environment_context_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1029 in self.part_vals:
- oprot.writeString(iter1029)
+ for iter1036 in self.part_vals:
+ oprot.writeString(iter1036)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -25031,10 +25087,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1033, _size1030) = iprot.readListBegin()
- for _i1034 in xrange(_size1030):
- _elem1035 = iprot.readString()
- self.part_vals.append(_elem1035)
+ (_etype1040, _size1037) = iprot.readListBegin()
+ for _i1041 in xrange(_size1037):
+ _elem1042 = iprot.readString()
+ self.part_vals.append(_elem1042)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25059,8 +25115,8 @@ class get_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1036 in self.part_vals:
- oprot.writeString(iter1036)
+ for iter1043 in self.part_vals:
+ oprot.writeString(iter1043)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25219,11 +25275,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1038, _vtype1039, _size1037 ) = iprot.readMapBegin()
- for _i1041 in xrange(_size1037):
- _key1042 = iprot.readString()
- _val1043 = iprot.readString()
- self.partitionSpecs[_key1042] = _val1043
+ (_ktype1045, _vtype1046, _size1044 ) = iprot.readMapBegin()
+ for _i1048 in xrange(_size1044):
+ _key1049 = iprot.readString()
+ _val1050 = iprot.readString()
+ self.partitionSpecs[_key1049] = _val1050
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25260,9 +25316,9 @@ class exchange_partition_args:
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
- for kiter1044,viter1045 in self.partitionSpecs.items():
- oprot.writeString(kiter1044)
- oprot.writeString(viter1045)
+ for kiter1051,viter1052 in self.partitionSpecs.items():
+ oprot.writeString(kiter1051)
+ oprot.writeString(viter1052)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -25467,11 +25523,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1047, _vtype1048, _size1046 ) = iprot.readMapBegin()
- for _i1050 in xrange(_size1046):
- _key1051 = iprot.readString()
- _val1052 = iprot.readString()
- self.partitionSpecs[_key1051] = _val1052
+ (_ktype1054, _vtype1055, _size1053 ) = iprot.readMapBegin()
+ for _i1057 in xrange(_size1053):
+ _key1058 = iprot.readString()
+ _val1059 = iprot.readString()
+ self.partitionSpecs[_key1058] = _val1059
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25508,9 +25564,9 @@ class exchange_partitions_args:
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
- for kiter1053,viter1054 in self.partitionSpecs.items():
- oprot.writeString(kiter1053)
- oprot.writeString(viter1054)
+ for kiter1060,viter1061 in self.partitionSpecs.items():
+ oprot.writeString(kiter1060)
+ oprot.writeString(viter1061)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -25593,11 +25649,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1058, _size1055) = iprot.readListBegin()
- for _i1059 in xrange(_size1055):
- _elem1060 = Partition()
- _elem1060.read(iprot)
- self.success.append(_elem1060)
+ (_etype1065, _size1062) = iprot.readListBegin()
+ for _i1066 in xrange(_size1062):
+ _elem1067 = Partition()
+ _elem1067.read(iprot)
+ self.success.append(_elem1067)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25638,8 +25694,8 @@ class exchange_partitions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1061 in self.success:
- iter1061.write(oprot)
+ for iter1068 in self.success:
+ iter1068.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25733,10 +25789,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1065, _size1062) = iprot.readListBegin()
- for _i1066 in xrange(_size1062):
- _elem1067 = iprot.readString()
- self.part_vals.append(_elem1067)
+ (_etype1072, _size1069) = iprot.readListBegin()
+ for _i1073 in xrange(_size1069):
+ _elem1074 = iprot.readString()
+ self.part_vals.append(_elem1074)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25748,10 +25804,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1071, _size1068) = iprot.readListBegin()
- for _i1072 in xrange(_size1068):
- _elem1073 = iprot.readString()
- self.group_names.append(_elem1073)
+ (_etype1078, _size1075) = iprot.readListBegin()
+ for _i1079 in xrange(_size1075):
+ _elem1080 = iprot.readString()
+ self.group_names.append(_elem1080)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25776,8 +25832,8 @@ class get_partition_with_auth_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1074 in self.part_vals:
- oprot.writeString(iter1074)
+ for iter1081 in self.part_vals:
+ oprot.writeString(iter1081)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -25787,8 +25843,8 @@ class get_partition_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1075 in self.group_names:
- oprot.writeString(iter1075)
+ for iter1082 in self.group_names:
+ oprot.writeString(iter1082)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26217,11 +26273,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1079, _size1076) = iprot.readListBegin()
- for _i1080 in xrange(_size1076):
- _elem1081 = Partition()
- _elem1081.read(iprot)
- self.success.append(_elem1081)
+ (_etype1086, _size1083) = iprot.readListBegin()
+ for _i1087 in xrange(_size1083):
+ _elem1088 = Partition()
+ _elem1088.read(iprot)
+ self.success.append(_elem1088)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26250,8 +26306,8 @@ class get_partitions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1082 in self.success:
- iter1082.write(oprot)
+ for iter1089 in self.success:
+ iter1089.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26345,10 +26401,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1086, _size1083) = iprot.readListBegin()
- for _i1087 in xrange(_size1083):
- _elem1088 = iprot.readString()
- self.group_names.append(_elem1088)
+ (_etype1093, _size1090) = iprot.readListBegin()
+ for _i1094 in xrange(_size1090):
+ _elem1095 = iprot.readString()
+ self.group_names.append(_elem1095)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26381,8 +26437,8 @@ class get_partitions_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1089 in self.group_names:
- oprot.writeString(iter1089)
+ for iter1096 in self.group_names:
+ oprot.writeString(iter1096)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26443,11 +26499,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1093, _size1090) = iprot.readListBegin()
- for _i1094 in xrange(_size1090):
- _elem1095 = Partition()
- _elem1095.read(iprot)
- self.success.append(_elem1095)
+ (_etype1100, _size1097) = iprot.readListBegin()
+ for _i1101 in xrange(_size1097):
+ _elem1102 = Partition()
+ _elem1102.read(iprot)
+ self.success.append(_elem1102)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26476,8 +26532,8 @@ class get_partitions_with_auth_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1096 in self.success:
- iter1096.write(oprot)
+ for iter1103 in self.success:
+ iter1103.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26635,11 +26691,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1100, _size1097) = iprot.readListBegin()
- for _i1101 in xrange(_size1097):
- _elem1102 = PartitionSpec()
- _elem1102.read(iprot)
- self.success.append(_elem1102)
+ (_etype1107, _size1104) = iprot.readListBegin()
+ for _i1108 in xrange(_size1104):
+ _elem1109 = PartitionSpec()
+ _elem1109.read(iprot)
+ self.success.append(_elem1109)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26668,8 +26724,8 @@ class get_partitions_pspec_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1103 in self.success:
- iter1103.write(oprot)
+ for iter1110 in self.success:
+ iter1110.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26827,10 +26883,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1107, _size1104) = iprot.readListBegin()
- for _i1108 in xrange(_size1104):
- _elem1109 = iprot.readString()
- self.success.append(_elem1109)
+ (_etype1114, _size1111) = iprot.readListBegin()
+ for _i1115 in xrange(_size1111):
+ _elem1116 = iprot.readString()
+ self.success.append(_elem1116)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26859,8 +26915,8 @@ class get_partition_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1110 in self.success:
- oprot.writeString(iter1110)
+ for iter1117 in self.success:
+ oprot.writeString(iter1117)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27100,10 +27156,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1114, _size1111) = iprot.readListBegin()
- for _i1115 in xrange(_size1111):
- _elem1116 = iprot.readString()
- self.part_vals.append(_elem1116)
+ (_etype1121, _size1118) = iprot.readListBegin()
+ for _i1122 in xrange(_size1118):
+ _elem1123 = iprot.readString()
+ self.part_vals.append(_elem1123)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27133,8 +27189,8 @@ class get_partitions_ps_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1117 in self.part_vals:
- oprot.writeString(iter1117)
+ for iter1124 in self.part_vals:
+ oprot.writeString(iter1124)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27198,11 +27254,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1121, _size1118) = iprot.readListBegin()
- for _i1122 in xrange(_size1118):
- _elem1123 = Partition()
- _elem1123.read(iprot)
- self.success.append(_elem1123)
+ (_etype1128, _size1125) = iprot.readListBegin()
+ for _i1129 in xrange(_size1125):
+ _elem1130 = Partition()
+ _elem1130.read(iprot)
+ self.success.append(_elem1130)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27231,8 +27287,8 @@ class get_partitions_ps_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1124 in self.success:
- iter1124.write(oprot)
+ for iter1131 in self.success:
+ iter1131.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27319,10 +27375,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1128, _size1125) = iprot.readListBegin()
- for _i1129 in xrange(_size1125):
- _elem1130 = iprot.readString()
- self.part_vals.append(_elem1130)
+ (_etype1135, _size1132) = iprot.readListBegin()
+ for _i1136 in xrange(_size1132):
+ _elem1137 = iprot.readString()
+ self.part_vals.append(_elem1137)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27339,10 +27395,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype1134, _size1131) = iprot.readListBegin()
- for _i1135 in xrange(_size1131):
- _elem1136 = iprot.readString()
- self.group_names.append(_elem1136)
+ (_etype1141, _size1138) = iprot.readListBegin()
+ for _i1142 in xrange(_size1138):
+ _elem1143 = iprot.readString()
+ self.group_names.append(_elem1143)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27367,8 +27423,8 @@ class get_partitions_ps_with_auth_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1137 in self.part_vals:
- oprot.writeString(iter1137)
+ for iter1144 in self.part_vals:
+ oprot.writeString(iter1144)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27382,8 +27438,8 @@ class get_partitions_ps_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 6)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1138 in self.group_names:
- oprot.writeString(iter1138)
+ for iter1145 in self.group_names:
+ oprot.writeString(iter1145)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -27445,11 +27501,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1142, _size1139) = iprot.readListBegin()
- for _i1143 in xrange(_size1139):
- _elem1144 = Partition()
- _elem1144.read(iprot)
- self.success.append(_elem1144)
+ (_etype1149, _size1146) = iprot.readListBegin()
+ for _i1150 in xrange(_size1146):
+ _elem1151 = Partition()
+ _elem1151.read(iprot)
+ self.success.append(_elem1151)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27478,8 +27534,8 @@ class get_partitions_ps_with_auth_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1145 in self.success:
- iter1145.write(oprot)
+ for iter1152 in self.success:
+ iter1152.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27560,10 +27616,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1149, _size1146) = iprot.readListBegin()
- for _i1150 in xrange(_size1146):
- _elem1151 = iprot.readString()
- self.part_vals.append(_elem1151)
+ (_etype1156, _size1153) = iprot.readListBegin()
+ for _i1157 in xrange(_size1153):
+ _elem1158 = iprot.readString()
+ self.part_vals.append(_elem1158)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27593,8 +27649,8 @@ class get_partition_names_ps_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1152 in self.part_vals:
- oprot.writeString(iter1152)
+ for iter1159 in self.part_vals:
+ oprot.writeString(iter1159)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27658,10 +27714,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1156, _size1153) = iprot.readListBegin()
- for _i1157 in xrange(_size1153):
- _elem1158 = iprot.readString()
- self.success.append(_elem1158)
+ (_etype1163, _size1160) = iprot.readListBegin()
+ for _i1164 in xrange(_size1160):
+ _elem1165 = iprot.readString()
+ self.success.append(_elem1165)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27690,8 +27746,8 @@ class get_partition_names_ps_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1159 in self.success:
- oprot.writeString(iter1159)
+ for iter1166 in self.success:
+ oprot.writeString(iter1166)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27862,11 +27918,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1163, _size1160) = iprot.readListBegin()
- for _i1164 in xrange(_size1160):
- _elem1165 = Partition()
- _elem1165.read(iprot)
- self.success.append(_elem1165)
+ (_etype1170, _size1167) = iprot.readListBegin()
+ for _i1171 in xrange(_size1167):
+ _elem1172 = Partition()
+ _elem1172.read(iprot)
+ self.success.append(_elem1172)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27895,8 +27951,8 @@ class get_partitions_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1166 in self.success:
- iter1166.write(oprot)
+ for iter1173 in self.success:
+ iter1173.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28067,11 +28123,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1170, _size1167) = iprot.readListBegin()
- for _i1171 in xrange(_size1167):
- _elem1172 = PartitionSpec()
- _elem1172.read(iprot)
- self.success.append(_elem1172)
+ (_etype1177, _size1174) = iprot.readListBegin()
+ for _i1178 in xrange(_size1174):
+ _elem1179 = PartitionSpec()
+ _elem1179.read(iprot)
+ self.success.append(_elem1179)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28100,8 +28156,8 @@ class get_part_specs_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1173 in self.success:
- iter1173.write(oprot)
+ for iter1180 in self.success:
+ iter1180.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28521,10 +28577,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype1177, _size1174) = iprot.readListBegin()
- for _i1178 in xrange(_size1174):
- _elem1179 = iprot.readString()
- self.names.append(_elem1179)
+ (_etype1184, _size1181) = iprot.readListBegin()
+ for _i1185 in xrange(_size1181):
+ _elem1186 = iprot.readString()
+ self.names.append(_elem1186)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28549,8 +28605,8 @@ class get_partitions_by_names_args:
if self.names is not None:
oprot.writeFieldBegin('names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.names))
- for iter1180 in self.names:
- oprot.writeString(iter1180)
+ for iter1187 in self.names:
+ oprot.writeString(iter1187)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -28609,11 +28665,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1184, _size1181) = iprot.readListBegin()
- for _i1185 in xrange(_size1181):
- _elem1186 = Partition()
- _elem1186.read(iprot)
- self.success.append(_elem1186)
+ (_etype1191, _size1188) = iprot.readListBegin()
+ for _i1192 in xrange(_size1188):
+ _elem1193 = Partition()
+ _elem1193.read(iprot)
+ self.success.append(_elem1193)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28642,8 +28698,8 @@ class get_partitions_by_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1187 in self.success:
- iter1187.write(oprot)
+ for iter1194 in self.success:
+ iter1194.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28893,11 +28949,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1191, _size1188) = iprot.readListBegin()
- for _i1192 in xrange(_size1188):
- _elem1193 = Partition()
- _elem1193.read(iprot)
- self.new_parts.append(_elem1193)
+ (_etype1198, _size1195) = iprot.readListBegin()
+ for _i1199 in xrange(_size1195):
+ _elem1200 = Partition()
+ _elem1200.read(iprot)
+ self.new_parts.append(_elem1200)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28922,8 +28978,8 @@ class alter_partitions_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter1194 in self.new_parts:
- iter1194.write(oprot)
+ for iter1201 in self.new_parts:
+ iter1201.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -29076,11 +29132,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1198, _size1195) = iprot.readListBegin()
- for _i1199 in xrange(_size1195):
- _elem1200 = Partition()
- _elem1200.read(iprot)
- self.new_parts.append(_elem1200)
+ (_etype1205, _size1202) = iprot.readListBegin()
+ for _i1206 in xrange(_size1202):
+ _elem1207 = Partition()
+ _elem1207.read(iprot)
+ self.new_parts.append(_elem1207)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29111,8 +29167,8 @@ class alter_partitions_with_environment_context_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter1201 in self.new_parts:
- iter1201.write(oprot)
+ for iter1208 in self.new_parts:
+ iter1208.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -29456,10 +29512,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1205, _size1202) = iprot.readListBegin()
- for _i1206 in xrange(_size1202):
- _elem1207 = iprot.readString()
- self.part_vals.append(_elem1207)
+ (_etype1212, _size1209) = iprot.readListBegin()
+ for _i1213 in xrange(_size1209):
+ _elem1214 = iprot.readString()
+ self.part_vals.append(_elem1214)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29490,8 +29546,8 @@ class rename_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1208 in self.part_vals:
- oprot.writeString(iter1208)
+ for iter1215 in self.part_vals:
+ oprot.writeString(iter1215)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -29633,10 +29689,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1212, _size1209) = iprot.readListBegin()
- for _i1213 in xrange(_size1209):
- _elem1214 = iprot.readString()
- self.part_vals.append(_elem1214)
+ (_etype1219, _size1216) = iprot.readListBegin()
+ for _i1220 in xrange(_size1216):
+ _elem1221 = iprot.readString()
+ self.part_vals.append(_elem1221)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29658,8 +29714,8 @@ class partition_name_has_valid_characters_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1215 in self.part_vals:
- oprot.writeString(iter1215)
+ for iter1222 in self.part_vals:
+ oprot.writeString(iter1222)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -30017,10 +30073,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1219, _size1216) = iprot.readListBegin()
- for _i1220 in xrange(_size1216):
- _elem1221 = iprot.readString()
- self.success.append(_elem1221)
+ (_etype1226, _size1223) = iprot.readListBegin()
+ for _i1227 in xrange(_size1223):
+ _elem1228 = iprot.readString()
+ self.success.append(_elem1228)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30043,8 +30099,8 @@ class partition_name_to_vals_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1222 in self.success:
- oprot.writeString(iter1222)
+ for iter1229 in self.success:
+ oprot.writeString(iter1229)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30168,11 +30224,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1224, _vtype1225, _size1223 ) = iprot.readMapBegin()
- for _i1227 in xrange(_size1223):
- _key1228 = iprot.readString()
- _val1229 = iprot.readString()
- self.success[_key1228] = _val1229
+ (_ktype1231, _vtype1232, _size1230 ) = iprot.readMapBegin()
+ for _i1234 in xrange(_size1230):
+ _key1235 = iprot.readString()
+ _val1236 = iprot.readString()
+ self.success[_key1235] = _val1236
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30195,9 +30251,9 @@ class partition_name_to_spec_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter1230,viter1231 in self.success.items():
- oprot.writeString(kiter1230)
- oprot.writeString(viter1231)
+ for kiter1237,viter1238 in self.success.items():
+ oprot.writeString(kiter1237)
+ oprot.writeString(viter1238)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30273,11 +30329,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1233, _vtype1234, _size1232 ) = iprot.readMapBegin()
- for _i1236 in xrange(_size1232):
- _key1237 = iprot.readString()
- _val1238 = iprot.readString()
- self.part_vals[_key1237] = _val1238
+ (_ktype1240, _vtype1241, _size1239 ) = iprot.readMapBegin()
+ for _i1243 in xrange(_size1239):
+ _key1244 = iprot.readString()
+ _val1245 = iprot.readString()
+ self.part_vals[_key1244] = _val1245
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30307,9 +30363,9 @@ class markPartitionForEvent_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals))
- for kiter1239,viter1240 in self.part_vals.items():
- oprot.writeString(kiter1239)
- oprot.writeString(viter1240)
+ for kiter1246,viter1247 in self.part_vals.items():
+ oprot.writeString(kiter1246)
+ oprot.writeString(viter1247)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -30523,11 +30579,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1242, _vtype1243, _size1241 ) = iprot.readMapBegin()
- for _i1245 in xrange(_size1241):
- _key1246 = iprot.readString()
- _val1247 = iprot.readString()
- self.part_vals[_key1246] = _val1247
+ (_ktype1249, _vtype1250, _size1248 ) = iprot.readMapBegin()
+ for _i1252 in xrange(_size1248):
+ _key1253 = iprot.readString()
+ _val1254 = iprot.readString()
+ self.part_vals[_key1253] = _val1254
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30557,9 +30613,9 @@ class isPartitionMarkedForEvent_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals))
- for kiter1248,viter1249 in self.part_vals.items():
- oprot.writeString(kiter1248)
- oprot.writeString(viter1249)
+ for kiter1255,viter1256 in self.part_vals.items():
+ oprot.writeString(kiter1255)
+ oprot.writeString(viter1256)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -34211,10 +34267,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1253, _size1250) = iprot.readListBegin()
- for _i1254 in xrange(_size1250):
- _elem1255 = iprot.readString()
- self.success.append(_elem1255)
+ (_etype1260, _size1257) = iprot.readListBegin()
+ for _i1261 in xrange(_size1257):
+ _elem1262 = iprot.readString()
+ self.success.append(_elem1262)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34237,8 +34293,8 @@ class get_functions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1256 in self.success:
- oprot.writeString(iter1256)
+ for iter1263 in self.success:
+ oprot.writeString(iter1263)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -34926,10 +34982,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1260, _size1257) = iprot.readListBegin()
- for _i1261 in xrange(_size1257):
- _elem1262 = iprot.readString()
- self.success.append(_elem1262)
+ (_etype1267, _size1264) = iprot.readListBegin()
+ for _i1268 in xrange(_size1264):
+ _elem1269 = iprot.readString()
+ self.success.append(_elem1269)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34952,8 +35008,8 @@ class get_role_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1263 in self.success:
- oprot.writeString(iter1263)
+ for iter1270 in self.success:
+ oprot.writeString(iter1270)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35467,11 +35523,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1267, _size1264) = iprot.readListBegin()
- for _i1268 in xrange(_size1264):
- _elem1269 = Role()
- _elem1269.read(iprot)
- self.success.append(_elem1269)
+ (_etype1274, _size1271) = iprot.readListBegin()
+ for _i1275 in xrange(_size1271):
+ _elem1276 = Role()
+ _elem1276.read(iprot)
+ self.success.append(_elem1276)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35494,8 +35550,8 @@ class list_roles_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1270 in self.success:
- iter1270.write(oprot)
+ for iter1277 in self.success:
+ iter1277.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -36004,10 +36060,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1274, _size1271) = iprot.readListBegin()
- for _i1275 in xrange(_size1271):
- _elem1276 = iprot.readString()
- self.group_names.append(_elem1276)
+ (_etype1281, _size1278) = iprot.readListBegin()
+ for _i1282 in xrange(_size1278):
+ _elem1283 = iprot.readString()
+ self.group_names.append(_elem1283)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36032,8 +36088,8 @@ class get_privilege_set_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1277 in self.group_names:
- oprot.writeString(iter1277)
+ for iter1284 in self.group_names:
+ oprot.writeString(iter1284)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -36260,11 +36316,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1281, _size1278) = iprot.readListBegin()
- for _i1282 in xrange(_size1278):
- _elem1283 = HiveObjectPrivilege()
- _elem1283.read(iprot)
- self.success.append(_elem1283)
+ (_etype1288, _size1285) = iprot.readListBegin()
+ for _i1289 in xrange(_size1285):
+ _elem1290 = HiveObjectPrivilege()
+ _elem1290.read(iprot)
+ self.success.append(_elem1290)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36287,8 +36343,8 @@ class list_privileges_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1284 in self.success:
- iter1284.write(oprot)
+ for iter1291 in self.success:
+ iter1291.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -36786,10 +36842,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1288, _size1285) = iprot.readListBegin()
- for _i1289 in xrange(_size1285):
- _elem1290 = iprot.readString()
- self.group_names.append(_elem1290)
+ (_etype1295, _size1292) = iprot.readListBegin()
+ for _i1296 in xrange(_size1292):
+ _elem1297 = iprot.readString()
+ self.group_names.append(_elem1297)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36810,8 +36866,8 @@ class set_ugi_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1291 in self.group_names:
- oprot.writeString(iter1291)
+ for iter1298 in self.group_names:
+ oprot.writeString(iter1298)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -36866,10 +36922,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1295, _size1292) = iprot.readListBegin()
- for _i1296 in xrange(_size1292):
- _elem1297 = iprot.readString()
- self.success.append(_elem1297)
+ (_etype1302, _size1299) = iprot.readListBegin()
+ for _i1303 in xrange(_size1299):
+ _elem1304 = iprot.readString()
+ self.success.append(_elem1304)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36892,8 +36948,8 @@ class set_ugi_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1298 in self.success:
- oprot.writeString(iter1298)
+ for iter1305 in self.success:
+ oprot.writeString(iter1305)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -37825,10 +37881,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1302, _size1299) = iprot.readListBegin()
- for _i1303 in xrange(_size1299):
- _elem1304 = iprot.readString()
- self.success.append(_elem1304)
+ (_etype1309, _size1306) = iprot.readListBegin()
+ for _i1310 in xrange(_size1306):
+ _elem1311 = iprot.readString()
+ self.success.append(_elem1311)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37845,8 +37901,8 @@ class get_all_token_id
<TRUNCATED>