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/02/23 16:31:02 UTC
[04/21] hive git commit: HIVE-18192: Introduce WriteID per table
rather than using global transaction ID (Sankar Hariappan,
reviewed by Eugene Koifman)
http://git-wip-us.apache.org/repos/asf/hive/blob/cbb9233a/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 330e75f..dfddd4a 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,20 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def get_valid_write_ids(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ pass
+
+ def allocate_table_write_ids(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ pass
+
def lock(self, rqst):
"""
Parameters:
@@ -6696,6 +6710,78 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
return
+ def get_valid_write_ids(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ self.send_get_valid_write_ids(rqst)
+ return self.recv_get_valid_write_ids()
+
+ def send_get_valid_write_ids(self, rqst):
+ self._oprot.writeMessageBegin('get_valid_write_ids', TMessageType.CALL, self._seqid)
+ args = get_valid_write_ids_args()
+ args.rqst = rqst
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_valid_write_ids(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_valid_write_ids_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.o1 is not None:
+ raise result.o1
+ if result.o2 is not None:
+ raise result.o2
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_valid_write_ids failed: unknown result")
+
+ def allocate_table_write_ids(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ self.send_allocate_table_write_ids(rqst)
+ return self.recv_allocate_table_write_ids()
+
+ def send_allocate_table_write_ids(self, rqst):
+ self._oprot.writeMessageBegin('allocate_table_write_ids', TMessageType.CALL, self._seqid)
+ args = allocate_table_write_ids_args()
+ args.rqst = rqst
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_allocate_table_write_ids(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = allocate_table_write_ids_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.o1 is not None:
+ raise result.o1
+ if result.o2 is not None:
+ raise result.o2
+ if result.o3 is not None:
+ raise result.o3
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "allocate_table_write_ids failed: unknown result")
+
def lock(self, rqst):
"""
Parameters:
@@ -8153,6 +8239,8 @@ 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["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
self._processMap["check_lock"] = Processor.process_check_lock
self._processMap["unlock"] = Processor.process_unlock
@@ -11771,6 +11859,59 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_valid_write_ids(self, seqid, iprot, oprot):
+ args = get_valid_write_ids_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_valid_write_ids_result()
+ try:
+ result.success = self._handler.get_valid_write_ids(args.rqst)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NoSuchTxnException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except MetaException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("get_valid_write_ids", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_allocate_table_write_ids(self, seqid, iprot, oprot):
+ args = allocate_table_write_ids_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = allocate_table_write_ids_result()
+ try:
+ result.success = self._handler.allocate_table_write_ids(args.rqst)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except NoSuchTxnException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except TxnAbortedException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except MetaException as o3:
+ msg_type = TMessageType.REPLY
+ result.o3 = o3
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("allocate_table_write_ids", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_lock(self, seqid, iprot, oprot):
args = lock_args()
args.read(iprot)
@@ -13587,10 +13728,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype723, _size720) = iprot.readListBegin()
- for _i724 in xrange(_size720):
- _elem725 = iprot.readString()
- self.success.append(_elem725)
+ (_etype758, _size755) = iprot.readListBegin()
+ for _i759 in xrange(_size755):
+ _elem760 = iprot.readString()
+ self.success.append(_elem760)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13613,8 +13754,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 iter726 in self.success:
- oprot.writeString(iter726)
+ for iter761 in self.success:
+ oprot.writeString(iter761)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13719,10 +13860,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype730, _size727) = iprot.readListBegin()
- for _i731 in xrange(_size727):
- _elem732 = iprot.readString()
- self.success.append(_elem732)
+ (_etype765, _size762) = iprot.readListBegin()
+ for _i766 in xrange(_size762):
+ _elem767 = iprot.readString()
+ self.success.append(_elem767)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13745,8 +13886,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 iter733 in self.success:
- oprot.writeString(iter733)
+ for iter768 in self.success:
+ oprot.writeString(iter768)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14516,12 +14657,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype735, _vtype736, _size734 ) = iprot.readMapBegin()
- for _i738 in xrange(_size734):
- _key739 = iprot.readString()
- _val740 = Type()
- _val740.read(iprot)
- self.success[_key739] = _val740
+ (_ktype770, _vtype771, _size769 ) = iprot.readMapBegin()
+ for _i773 in xrange(_size769):
+ _key774 = iprot.readString()
+ _val775 = Type()
+ _val775.read(iprot)
+ self.success[_key774] = _val775
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -14544,9 +14685,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 kiter741,viter742 in self.success.items():
- oprot.writeString(kiter741)
- viter742.write(oprot)
+ for kiter776,viter777 in self.success.items():
+ oprot.writeString(kiter776)
+ viter777.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -14689,11 +14830,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype746, _size743) = iprot.readListBegin()
- for _i747 in xrange(_size743):
- _elem748 = FieldSchema()
- _elem748.read(iprot)
- self.success.append(_elem748)
+ (_etype781, _size778) = iprot.readListBegin()
+ for _i782 in xrange(_size778):
+ _elem783 = FieldSchema()
+ _elem783.read(iprot)
+ self.success.append(_elem783)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14728,8 +14869,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 iter749 in self.success:
- iter749.write(oprot)
+ for iter784 in self.success:
+ iter784.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14896,11 +15037,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype753, _size750) = iprot.readListBegin()
- for _i754 in xrange(_size750):
- _elem755 = FieldSchema()
- _elem755.read(iprot)
- self.success.append(_elem755)
+ (_etype788, _size785) = iprot.readListBegin()
+ for _i789 in xrange(_size785):
+ _elem790 = FieldSchema()
+ _elem790.read(iprot)
+ self.success.append(_elem790)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14935,8 +15076,8 @@ class 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 iter756 in self.success:
- iter756.write(oprot)
+ for iter791 in self.success:
+ iter791.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15089,11 +15230,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype760, _size757) = iprot.readListBegin()
- for _i761 in xrange(_size757):
- _elem762 = FieldSchema()
- _elem762.read(iprot)
- self.success.append(_elem762)
+ (_etype795, _size792) = iprot.readListBegin()
+ for _i796 in xrange(_size792):
+ _elem797 = FieldSchema()
+ _elem797.read(iprot)
+ self.success.append(_elem797)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15128,8 +15269,8 @@ class get_schema_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter763 in self.success:
- iter763.write(oprot)
+ for iter798 in self.success:
+ iter798.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15296,11 +15437,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype767, _size764) = iprot.readListBegin()
- for _i768 in xrange(_size764):
- _elem769 = FieldSchema()
- _elem769.read(iprot)
- self.success.append(_elem769)
+ (_etype802, _size799) = iprot.readListBegin()
+ for _i803 in xrange(_size799):
+ _elem804 = FieldSchema()
+ _elem804.read(iprot)
+ self.success.append(_elem804)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15335,8 +15476,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 iter770 in self.success:
- iter770.write(oprot)
+ for iter805 in self.success:
+ iter805.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15783,44 +15924,44 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype774, _size771) = iprot.readListBegin()
- for _i775 in xrange(_size771):
- _elem776 = SQLPrimaryKey()
- _elem776.read(iprot)
- self.primaryKeys.append(_elem776)
+ (_etype809, _size806) = iprot.readListBegin()
+ for _i810 in xrange(_size806):
+ _elem811 = SQLPrimaryKey()
+ _elem811.read(iprot)
+ self.primaryKeys.append(_elem811)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype780, _size777) = iprot.readListBegin()
- for _i781 in xrange(_size777):
- _elem782 = SQLForeignKey()
- _elem782.read(iprot)
- self.foreignKeys.append(_elem782)
+ (_etype815, _size812) = iprot.readListBegin()
+ for _i816 in xrange(_size812):
+ _elem817 = SQLForeignKey()
+ _elem817.read(iprot)
+ self.foreignKeys.append(_elem817)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype786, _size783) = iprot.readListBegin()
- for _i787 in xrange(_size783):
- _elem788 = SQLUniqueConstraint()
- _elem788.read(iprot)
- self.uniqueConstraints.append(_elem788)
+ (_etype821, _size818) = iprot.readListBegin()
+ for _i822 in xrange(_size818):
+ _elem823 = SQLUniqueConstraint()
+ _elem823.read(iprot)
+ self.uniqueConstraints.append(_elem823)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype792, _size789) = iprot.readListBegin()
- for _i793 in xrange(_size789):
- _elem794 = SQLNotNullConstraint()
- _elem794.read(iprot)
- self.notNullConstraints.append(_elem794)
+ (_etype827, _size824) = iprot.readListBegin()
+ for _i828 in xrange(_size824):
+ _elem829 = SQLNotNullConstraint()
+ _elem829.read(iprot)
+ self.notNullConstraints.append(_elem829)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15841,29 +15982,29 @@ 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 iter795 in self.primaryKeys:
- iter795.write(oprot)
+ for iter830 in self.primaryKeys:
+ iter830.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 iter796 in self.foreignKeys:
- iter796.write(oprot)
+ for iter831 in self.foreignKeys:
+ iter831.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 iter797 in self.uniqueConstraints:
- iter797.write(oprot)
+ for iter832 in self.uniqueConstraints:
+ iter832.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 iter798 in self.notNullConstraints:
- iter798.write(oprot)
+ for iter833 in self.notNullConstraints:
+ iter833.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17129,10 +17270,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype802, _size799) = iprot.readListBegin()
- for _i803 in xrange(_size799):
- _elem804 = iprot.readString()
- self.partNames.append(_elem804)
+ (_etype837, _size834) = iprot.readListBegin()
+ for _i838 in xrange(_size834):
+ _elem839 = iprot.readString()
+ self.partNames.append(_elem839)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17157,8 +17298,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 iter805 in self.partNames:
- oprot.writeString(iter805)
+ for iter840 in self.partNames:
+ oprot.writeString(iter840)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17358,10 +17499,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype809, _size806) = iprot.readListBegin()
- for _i810 in xrange(_size806):
- _elem811 = iprot.readString()
- self.success.append(_elem811)
+ (_etype844, _size841) = iprot.readListBegin()
+ for _i845 in xrange(_size841):
+ _elem846 = iprot.readString()
+ self.success.append(_elem846)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17384,8 +17525,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 iter812 in self.success:
- oprot.writeString(iter812)
+ for iter847 in self.success:
+ oprot.writeString(iter847)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17535,10 +17676,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype816, _size813) = iprot.readListBegin()
- for _i817 in xrange(_size813):
- _elem818 = iprot.readString()
- self.success.append(_elem818)
+ (_etype851, _size848) = iprot.readListBegin()
+ for _i852 in xrange(_size848):
+ _elem853 = iprot.readString()
+ self.success.append(_elem853)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17561,8 +17702,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 iter819 in self.success:
- oprot.writeString(iter819)
+ for iter854 in self.success:
+ oprot.writeString(iter854)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17686,10 +17827,10 @@ class get_materialized_views_for_rewriting_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype823, _size820) = iprot.readListBegin()
- for _i824 in xrange(_size820):
- _elem825 = iprot.readString()
- self.success.append(_elem825)
+ (_etype858, _size855) = iprot.readListBegin()
+ for _i859 in xrange(_size855):
+ _elem860 = iprot.readString()
+ self.success.append(_elem860)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17712,8 +17853,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 iter826 in self.success:
- oprot.writeString(iter826)
+ for iter861 in self.success:
+ oprot.writeString(iter861)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17786,10 +17927,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype830, _size827) = iprot.readListBegin()
- for _i831 in xrange(_size827):
- _elem832 = iprot.readString()
- self.tbl_types.append(_elem832)
+ (_etype865, _size862) = iprot.readListBegin()
+ for _i866 in xrange(_size862):
+ _elem867 = iprot.readString()
+ self.tbl_types.append(_elem867)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17814,8 +17955,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 iter833 in self.tbl_types:
- oprot.writeString(iter833)
+ for iter868 in self.tbl_types:
+ oprot.writeString(iter868)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17871,11 +18012,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype837, _size834) = iprot.readListBegin()
- for _i838 in xrange(_size834):
- _elem839 = TableMeta()
- _elem839.read(iprot)
- self.success.append(_elem839)
+ (_etype872, _size869) = iprot.readListBegin()
+ for _i873 in xrange(_size869):
+ _elem874 = TableMeta()
+ _elem874.read(iprot)
+ self.success.append(_elem874)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17898,8 +18039,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 iter840 in self.success:
- iter840.write(oprot)
+ for iter875 in self.success:
+ iter875.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18023,10 +18164,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype844, _size841) = iprot.readListBegin()
- for _i845 in xrange(_size841):
- _elem846 = iprot.readString()
- self.success.append(_elem846)
+ (_etype879, _size876) = iprot.readListBegin()
+ for _i880 in xrange(_size876):
+ _elem881 = iprot.readString()
+ self.success.append(_elem881)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18049,8 +18190,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 iter847 in self.success:
- oprot.writeString(iter847)
+ for iter882 in self.success:
+ oprot.writeString(iter882)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18286,10 +18427,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype851, _size848) = iprot.readListBegin()
- for _i852 in xrange(_size848):
- _elem853 = iprot.readString()
- self.tbl_names.append(_elem853)
+ (_etype886, _size883) = iprot.readListBegin()
+ for _i887 in xrange(_size883):
+ _elem888 = iprot.readString()
+ self.tbl_names.append(_elem888)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18310,8 +18451,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 iter854 in self.tbl_names:
- oprot.writeString(iter854)
+ for iter889 in self.tbl_names:
+ oprot.writeString(iter889)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18363,11 +18504,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype858, _size855) = iprot.readListBegin()
- for _i859 in xrange(_size855):
- _elem860 = Table()
- _elem860.read(iprot)
- self.success.append(_elem860)
+ (_etype893, _size890) = iprot.readListBegin()
+ for _i894 in xrange(_size890):
+ _elem895 = Table()
+ _elem895.read(iprot)
+ self.success.append(_elem895)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18384,8 +18525,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 iter861 in self.success:
- iter861.write(oprot)
+ for iter896 in self.success:
+ iter896.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18777,10 +18918,10 @@ class get_materialization_invalidation_info_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype865, _size862) = iprot.readListBegin()
- for _i866 in xrange(_size862):
- _elem867 = iprot.readString()
- self.tbl_names.append(_elem867)
+ (_etype900, _size897) = iprot.readListBegin()
+ for _i901 in xrange(_size897):
+ _elem902 = iprot.readString()
+ self.tbl_names.append(_elem902)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18801,8 +18942,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 iter868 in self.tbl_names:
- oprot.writeString(iter868)
+ for iter903 in self.tbl_names:
+ oprot.writeString(iter903)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18863,12 +19004,12 @@ class get_materialization_invalidation_info_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype870, _vtype871, _size869 ) = iprot.readMapBegin()
- for _i873 in xrange(_size869):
- _key874 = iprot.readString()
- _val875 = Materialization()
- _val875.read(iprot)
- self.success[_key874] = _val875
+ (_ktype905, _vtype906, _size904 ) = iprot.readMapBegin()
+ for _i908 in xrange(_size904):
+ _key909 = iprot.readString()
+ _val910 = Materialization()
+ _val910.read(iprot)
+ self.success[_key909] = _val910
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -18903,9 +19044,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 kiter876,viter877 in self.success.items():
- oprot.writeString(kiter876)
- viter877.write(oprot)
+ for kiter911,viter912 in self.success.items():
+ oprot.writeString(kiter911)
+ viter912.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19257,10 +19398,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype881, _size878) = iprot.readListBegin()
- for _i882 in xrange(_size878):
- _elem883 = iprot.readString()
- self.success.append(_elem883)
+ (_etype916, _size913) = iprot.readListBegin()
+ for _i917 in xrange(_size913):
+ _elem918 = iprot.readString()
+ self.success.append(_elem918)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19295,8 +19436,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 iter884 in self.success:
- oprot.writeString(iter884)
+ for iter919 in self.success:
+ oprot.writeString(iter919)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20266,11 +20407,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype888, _size885) = iprot.readListBegin()
- for _i889 in xrange(_size885):
- _elem890 = Partition()
- _elem890.read(iprot)
- self.new_parts.append(_elem890)
+ (_etype923, _size920) = iprot.readListBegin()
+ for _i924 in xrange(_size920):
+ _elem925 = Partition()
+ _elem925.read(iprot)
+ self.new_parts.append(_elem925)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20287,8 +20428,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 iter891 in self.new_parts:
- iter891.write(oprot)
+ for iter926 in self.new_parts:
+ iter926.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20446,11 +20587,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype895, _size892) = iprot.readListBegin()
- for _i896 in xrange(_size892):
- _elem897 = PartitionSpec()
- _elem897.read(iprot)
- self.new_parts.append(_elem897)
+ (_etype930, _size927) = iprot.readListBegin()
+ for _i931 in xrange(_size927):
+ _elem932 = PartitionSpec()
+ _elem932.read(iprot)
+ self.new_parts.append(_elem932)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20467,8 +20608,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 iter898 in self.new_parts:
- iter898.write(oprot)
+ for iter933 in self.new_parts:
+ iter933.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20642,10 +20783,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype902, _size899) = iprot.readListBegin()
- for _i903 in xrange(_size899):
- _elem904 = iprot.readString()
- self.part_vals.append(_elem904)
+ (_etype937, _size934) = iprot.readListBegin()
+ for _i938 in xrange(_size934):
+ _elem939 = iprot.readString()
+ self.part_vals.append(_elem939)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20670,8 +20811,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 iter905 in self.part_vals:
- oprot.writeString(iter905)
+ for iter940 in self.part_vals:
+ oprot.writeString(iter940)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21024,10 +21165,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype909, _size906) = iprot.readListBegin()
- for _i910 in xrange(_size906):
- _elem911 = iprot.readString()
- self.part_vals.append(_elem911)
+ (_etype944, _size941) = iprot.readListBegin()
+ for _i945 in xrange(_size941):
+ _elem946 = iprot.readString()
+ self.part_vals.append(_elem946)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21058,8 +21199,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 iter912 in self.part_vals:
- oprot.writeString(iter912)
+ for iter947 in self.part_vals:
+ oprot.writeString(iter947)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -21654,10 +21795,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype916, _size913) = iprot.readListBegin()
- for _i917 in xrange(_size913):
- _elem918 = iprot.readString()
- self.part_vals.append(_elem918)
+ (_etype951, _size948) = iprot.readListBegin()
+ for _i952 in xrange(_size948):
+ _elem953 = iprot.readString()
+ self.part_vals.append(_elem953)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21687,8 +21828,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 iter919 in self.part_vals:
- oprot.writeString(iter919)
+ for iter954 in self.part_vals:
+ oprot.writeString(iter954)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -21861,10 +22002,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype923, _size920) = iprot.readListBegin()
- for _i924 in xrange(_size920):
- _elem925 = iprot.readString()
- self.part_vals.append(_elem925)
+ (_etype958, _size955) = iprot.readListBegin()
+ for _i959 in xrange(_size955):
+ _elem960 = iprot.readString()
+ self.part_vals.append(_elem960)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21900,8 +22041,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 iter926 in self.part_vals:
- oprot.writeString(iter926)
+ for iter961 in self.part_vals:
+ oprot.writeString(iter961)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -22638,10 +22779,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype930, _size927) = iprot.readListBegin()
- for _i931 in xrange(_size927):
- _elem932 = iprot.readString()
- self.part_vals.append(_elem932)
+ (_etype965, _size962) = iprot.readListBegin()
+ for _i966 in xrange(_size962):
+ _elem967 = iprot.readString()
+ self.part_vals.append(_elem967)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22666,8 +22807,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 iter933 in self.part_vals:
- oprot.writeString(iter933)
+ for iter968 in self.part_vals:
+ oprot.writeString(iter968)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22826,11 +22967,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype935, _vtype936, _size934 ) = iprot.readMapBegin()
- for _i938 in xrange(_size934):
- _key939 = iprot.readString()
- _val940 = iprot.readString()
- self.partitionSpecs[_key939] = _val940
+ (_ktype970, _vtype971, _size969 ) = iprot.readMapBegin()
+ for _i973 in xrange(_size969):
+ _key974 = iprot.readString()
+ _val975 = iprot.readString()
+ self.partitionSpecs[_key974] = _val975
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -22867,9 +23008,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 kiter941,viter942 in self.partitionSpecs.items():
- oprot.writeString(kiter941)
- oprot.writeString(viter942)
+ for kiter976,viter977 in self.partitionSpecs.items():
+ oprot.writeString(kiter976)
+ oprot.writeString(viter977)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -23074,11 +23215,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype944, _vtype945, _size943 ) = iprot.readMapBegin()
- for _i947 in xrange(_size943):
- _key948 = iprot.readString()
- _val949 = iprot.readString()
- self.partitionSpecs[_key948] = _val949
+ (_ktype979, _vtype980, _size978 ) = iprot.readMapBegin()
+ for _i982 in xrange(_size978):
+ _key983 = iprot.readString()
+ _val984 = iprot.readString()
+ self.partitionSpecs[_key983] = _val984
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -23115,9 +23256,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 kiter950,viter951 in self.partitionSpecs.items():
- oprot.writeString(kiter950)
- oprot.writeString(viter951)
+ for kiter985,viter986 in self.partitionSpecs.items():
+ oprot.writeString(kiter985)
+ oprot.writeString(viter986)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -23200,11 +23341,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype955, _size952) = iprot.readListBegin()
- for _i956 in xrange(_size952):
- _elem957 = Partition()
- _elem957.read(iprot)
- self.success.append(_elem957)
+ (_etype990, _size987) = iprot.readListBegin()
+ for _i991 in xrange(_size987):
+ _elem992 = Partition()
+ _elem992.read(iprot)
+ self.success.append(_elem992)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23245,8 +23386,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 iter958 in self.success:
- iter958.write(oprot)
+ for iter993 in self.success:
+ iter993.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23340,10 +23481,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype962, _size959) = iprot.readListBegin()
- for _i963 in xrange(_size959):
- _elem964 = iprot.readString()
- self.part_vals.append(_elem964)
+ (_etype997, _size994) = iprot.readListBegin()
+ for _i998 in xrange(_size994):
+ _elem999 = iprot.readString()
+ self.part_vals.append(_elem999)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23355,10 +23496,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype968, _size965) = iprot.readListBegin()
- for _i969 in xrange(_size965):
- _elem970 = iprot.readString()
- self.group_names.append(_elem970)
+ (_etype1003, _size1000) = iprot.readListBegin()
+ for _i1004 in xrange(_size1000):
+ _elem1005 = iprot.readString()
+ self.group_names.append(_elem1005)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23383,8 +23524,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 iter971 in self.part_vals:
- oprot.writeString(iter971)
+ for iter1006 in self.part_vals:
+ oprot.writeString(iter1006)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -23394,8 +23535,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 iter972 in self.group_names:
- oprot.writeString(iter972)
+ for iter1007 in self.group_names:
+ oprot.writeString(iter1007)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23824,11 +23965,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype976, _size973) = iprot.readListBegin()
- for _i977 in xrange(_size973):
- _elem978 = Partition()
- _elem978.read(iprot)
- self.success.append(_elem978)
+ (_etype1011, _size1008) = iprot.readListBegin()
+ for _i1012 in xrange(_size1008):
+ _elem1013 = Partition()
+ _elem1013.read(iprot)
+ self.success.append(_elem1013)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23857,8 +23998,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 iter979 in self.success:
- iter979.write(oprot)
+ for iter1014 in self.success:
+ iter1014.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23952,10 +24093,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype983, _size980) = iprot.readListBegin()
- for _i984 in xrange(_size980):
- _elem985 = iprot.readString()
- self.group_names.append(_elem985)
+ (_etype1018, _size1015) = iprot.readListBegin()
+ for _i1019 in xrange(_size1015):
+ _elem1020 = iprot.readString()
+ self.group_names.append(_elem1020)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23988,8 +24129,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 iter986 in self.group_names:
- oprot.writeString(iter986)
+ for iter1021 in self.group_names:
+ oprot.writeString(iter1021)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24050,11 +24191,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype990, _size987) = iprot.readListBegin()
- for _i991 in xrange(_size987):
- _elem992 = Partition()
- _elem992.read(iprot)
- self.success.append(_elem992)
+ (_etype1025, _size1022) = iprot.readListBegin()
+ for _i1026 in xrange(_size1022):
+ _elem1027 = Partition()
+ _elem1027.read(iprot)
+ self.success.append(_elem1027)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24083,8 +24224,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 iter993 in self.success:
- iter993.write(oprot)
+ for iter1028 in self.success:
+ iter1028.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24242,11 +24383,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype997, _size994) = iprot.readListBegin()
- for _i998 in xrange(_size994):
- _elem999 = PartitionSpec()
- _elem999.read(iprot)
- self.success.append(_elem999)
+ (_etype1032, _size1029) = iprot.readListBegin()
+ for _i1033 in xrange(_size1029):
+ _elem1034 = PartitionSpec()
+ _elem1034.read(iprot)
+ self.success.append(_elem1034)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24275,8 +24416,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 iter1000 in self.success:
- iter1000.write(oprot)
+ for iter1035 in self.success:
+ iter1035.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24434,10 +24575,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1004, _size1001) = iprot.readListBegin()
- for _i1005 in xrange(_size1001):
- _elem1006 = iprot.readString()
- self.success.append(_elem1006)
+ (_etype1039, _size1036) = iprot.readListBegin()
+ for _i1040 in xrange(_size1036):
+ _elem1041 = iprot.readString()
+ self.success.append(_elem1041)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24466,8 +24607,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 iter1007 in self.success:
- oprot.writeString(iter1007)
+ for iter1042 in self.success:
+ oprot.writeString(iter1042)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24707,10 +24848,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1011, _size1008) = iprot.readListBegin()
- for _i1012 in xrange(_size1008):
- _elem1013 = iprot.readString()
- self.part_vals.append(_elem1013)
+ (_etype1046, _size1043) = iprot.readListBegin()
+ for _i1047 in xrange(_size1043):
+ _elem1048 = iprot.readString()
+ self.part_vals.append(_elem1048)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24740,8 +24881,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 iter1014 in self.part_vals:
- oprot.writeString(iter1014)
+ for iter1049 in self.part_vals:
+ oprot.writeString(iter1049)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -24805,11 +24946,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1018, _size1015) = iprot.readListBegin()
- for _i1019 in xrange(_size1015):
- _elem1020 = Partition()
- _elem1020.read(iprot)
- self.success.append(_elem1020)
+ (_etype1053, _size1050) = iprot.readListBegin()
+ for _i1054 in xrange(_size1050):
+ _elem1055 = Partition()
+ _elem1055.read(iprot)
+ self.success.append(_elem1055)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24838,8 +24979,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 iter1021 in self.success:
- iter1021.write(oprot)
+ for iter1056 in self.success:
+ iter1056.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24926,10 +25067,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1025, _size1022) = iprot.readListBegin()
- for _i1026 in xrange(_size1022):
- _elem1027 = iprot.readString()
- self.part_vals.append(_elem1027)
+ (_etype1060, _size1057) = iprot.readListBegin()
+ for _i1061 in xrange(_size1057):
+ _elem1062 = iprot.readString()
+ self.part_vals.append(_elem1062)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24946,10 +25087,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype1031, _size1028) = iprot.readListBegin()
- for _i1032 in xrange(_size1028):
- _elem1033 = iprot.readString()
- self.group_names.append(_elem1033)
+ (_etype1066, _size1063) = iprot.readListBegin()
+ for _i1067 in xrange(_size1063):
+ _elem1068 = iprot.readString()
+ self.group_names.append(_elem1068)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24974,8 +25115,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 iter1034 in self.part_vals:
- oprot.writeString(iter1034)
+ for iter1069 in self.part_vals:
+ oprot.writeString(iter1069)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -24989,8 +25130,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 iter1035 in self.group_names:
- oprot.writeString(iter1035)
+ for iter1070 in self.group_names:
+ oprot.writeString(iter1070)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25052,11 +25193,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1039, _size1036) = iprot.readListBegin()
- for _i1040 in xrange(_size1036):
- _elem1041 = Partition()
- _elem1041.read(iprot)
- self.success.append(_elem1041)
+ (_etype1074, _size1071) = iprot.readListBegin()
+ for _i1075 in xrange(_size1071):
+ _elem1076 = Partition()
+ _elem1076.read(iprot)
+ self.success.append(_elem1076)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25085,8 +25226,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 iter1042 in self.success:
- iter1042.write(oprot)
+ for iter1077 in self.success:
+ iter1077.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25167,10 +25308,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1046, _size1043) = iprot.readListBegin()
- for _i1047 in xrange(_size1043):
- _elem1048 = iprot.readString()
- self.part_vals.append(_elem1048)
+ (_etype1081, _size1078) = iprot.readListBegin()
+ for _i1082 in xrange(_size1078):
+ _elem1083 = iprot.readString()
+ self.part_vals.append(_elem1083)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25200,8 +25341,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 iter1049 in self.part_vals:
- oprot.writeString(iter1049)
+ for iter1084 in self.part_vals:
+ oprot.writeString(iter1084)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -25265,10 +25406,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1053, _size1050) = iprot.readListBegin()
- for _i1054 in xrange(_size1050):
- _elem1055 = iprot.readString()
- self.success.append(_elem1055)
+ (_etype1088, _size1085) = iprot.readListBegin()
+ for _i1089 in xrange(_size1085):
+ _elem1090 = iprot.readString()
+ self.success.append(_elem1090)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25297,8 +25438,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 iter1056 in self.success:
- oprot.writeString(iter1056)
+ for iter1091 in self.success:
+ oprot.writeString(iter1091)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25469,11 +25610,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1060, _size1057) = iprot.readListBegin()
- for _i1061 in xrange(_size1057):
- _elem1062 = Partition()
- _elem1062.read(iprot)
- self.success.append(_elem1062)
+ (_etype1095, _size1092) = iprot.readListBegin()
+ for _i1096 in xrange(_size1092):
+ _elem1097 = Partition()
+ _elem1097.read(iprot)
+ self.success.append(_elem1097)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25502,8 +25643,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 iter1063 in self.success:
- iter1063.write(oprot)
+ for iter1098 in self.success:
+ iter1098.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25674,11 +25815,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1067, _size1064) = iprot.readListBegin()
- for _i1068 in xrange(_size1064):
- _elem1069 = PartitionSpec()
- _elem1069.read(iprot)
- self.success.append(_elem1069)
+ (_etype1102, _size1099) = iprot.readListBegin()
+ for _i1103 in xrange(_size1099):
+ _elem1104 = PartitionSpec()
+ _elem1104.read(iprot)
+ self.success.append(_elem1104)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25707,8 +25848,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 iter1070 in self.success:
- iter1070.write(oprot)
+ for iter1105 in self.success:
+ iter1105.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26128,10 +26269,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype1074, _size1071) = iprot.readListBegin()
- for _i1075 in xrange(_size1071):
- _elem1076 = iprot.readString()
- self.names.append(_elem1076)
+ (_etype1109, _size1106) = iprot.readListBegin()
+ for _i1110 in xrange(_size1106):
+ _elem1111 = iprot.readString()
+ self.names.append(_elem1111)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26156,8 +26297,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 iter1077 in self.names:
- oprot.writeString(iter1077)
+ for iter1112 in self.names:
+ oprot.writeString(iter1112)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26216,11 +26357,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1081, _size1078) = iprot.readListBegin()
- for _i1082 in xrange(_size1078):
- _elem1083 = Partition()
- _elem1083.read(iprot)
- self.success.append(_elem1083)
+ (_etype1116, _size1113) = iprot.readListBegin()
+ for _i1117 in xrange(_size1113):
+ _elem1118 = Partition()
+ _elem1118.read(iprot)
+ self.success.append(_elem1118)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26249,8 +26390,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 iter1084 in self.success:
- iter1084.write(oprot)
+ for iter1119 in self.success:
+ iter1119.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26500,11 +26641,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1088, _size1085) = iprot.readListBegin()
- for _i1089 in xrange(_size1085):
- _elem1090 = Partition()
- _elem1090.read(iprot)
- self.new_parts.append(_elem1090)
+ (_etype1123, _size1120) = iprot.readListBegin()
+ for _i1124 in xrange(_size1120):
+ _elem1125 = Partition()
+ _elem1125.read(iprot)
+ self.new_parts.append(_elem1125)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26529,8 +26670,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 iter1091 in self.new_parts:
- iter1091.write(oprot)
+ for iter1126 in self.new_parts:
+ iter1126.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26683,11 +26824,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1095, _size1092) = iprot.readListBegin()
- for _i1096 in xrange(_size1092):
- _elem1097 = Partition()
- _elem1097.read(iprot)
- self.new_parts.append(_elem1097)
+ (_etype1130, _size1127) = iprot.readListBegin()
+ for _i1131 in xrange(_size1127):
+ _elem1132 = Partition()
+ _elem1132.read(iprot)
+ self.new_parts.append(_elem1132)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26718,8 +26859,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 iter1098 in self.new_parts:
- iter1098.write(oprot)
+ for iter1133 in self.new_parts:
+ iter1133.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -27063,10 +27204,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1102, _size1099) = iprot.readListBegin()
- for _i1103 in xrange(_size1099):
- _elem1104 = iprot.readString()
- self.part_vals.append(_elem1104)
+ (_etype1137, _size1134) = iprot.readListBegin()
+ for _i1138 in xrange(_size1134):
+ _elem1139 = iprot.readString()
+ self.part_vals.append(_elem1139)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27097,8 +27238,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 iter1105 in self.part_vals:
- oprot.writeString(iter1105)
+ for iter1140 in self.part_vals:
+ oprot.writeString(iter1140)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -27240,10 +27381,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1109, _size1106) = iprot.readListBegin()
- for _i1110 in xrange(_size1106):
- _elem1111 = iprot.readString()
- self.part_vals.append(_elem1111)
+ (_etype1144, _size1141) = iprot.readListBegin()
+ for _i1145 in xrange(_size1141):
+ _elem1146 = iprot.readString()
+ self.part_vals.append(_elem1146)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27265,8 +27406,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 iter1112 in self.part_vals:
- oprot.writeString(iter1112)
+ for iter1147 in self.part_vals:
+ oprot.writeString(iter1147)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -27624,10 +27765,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1116, _size1113) = iprot.readListBegin()
- for _i1117 in xrange(_size1113):
- _elem1118 = iprot.readString()
- self.success.append(_elem1118)
+ (_etype1151, _size1148) = iprot.readListBegin()
+ for _i1152 in xrange(_size1148):
+ _elem1153 = iprot.readString()
+ self.success.append(_elem1153)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27650,8 +27791,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 iter1119 in self.success:
- oprot.writeString(iter1119)
+ for iter1154 in self.success:
+ oprot.writeString(iter1154)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27775,11 +27916,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1121, _vtype1122, _size1120 ) = iprot.readMapBegin()
- for _i1124 in xrange(_size1120):
- _key1125 = iprot.readString()
- _val1126 = iprot.readString()
- self.success[_key1125] = _val1126
+ (_ktype1156, _vtype1157, _size1155 ) = iprot.readMapBegin()
+ for _i1159 in xrange(_size1155):
+ _key1160 = iprot.readString()
+ _val1161 = iprot.readString()
+ self.success[_key1160] = _val1161
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -27802,9 +27943,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 kiter1127,viter1128 in self.success.items():
- oprot.writeString(kiter1127)
- oprot.writeString(viter1128)
+ for kiter1162,viter1163 in self.success.items():
+ oprot.writeString(kiter1162)
+ oprot.writeString(viter1163)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27880,11 +28021,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1130, _vtype1131, _size1129 ) = iprot.readMapBegin()
- for _i1133 in xrange(_size1129):
- _key1134 = iprot.readString()
- _val1135 = iprot.readString()
- self.part_vals[_key1134] = _val1135
+ (_ktype1165, _vtype1166, _size1164 ) = iprot.readMapBegin()
+ for _i1168 in xrange(_size1164):
+ _key1169 = iprot.readString()
+ _val1170 = iprot.readString()
+ self.part_vals[_key1169] = _val1170
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -27914,9 +28055,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 kiter1136,viter1137 in self.part_vals.items():
- oprot.writeString(kiter1136)
- oprot.writeString(viter1137)
+ for kiter1171,viter1172 in self.part_vals.items():
+ oprot.writeString(kiter1171)
+ oprot.writeString(viter1172)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -28130,11 +28271,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1139, _vtype1140, _size1138 ) = iprot.readMapBegin()
- for _i1142 in xrange(_size1138):
- _key1143 = iprot.readString()
- _val1144 = iprot.readString()
- self.part_vals[_key1143] = _val1144
+ (_ktype1174, _vtype1175, _size1173 ) = iprot.readMapBegin()
+ for _i1177 in xrange(_size1173):
+ _key1178 = iprot.readString()
+ _val1179 = iprot.readString()
+ self.part_vals[_key1178] = _val1179
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -28164,9 +28305,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 kiter1145,viter1146 in self.part_vals.items():
- oprot.writeString(kiter1145)
- oprot.writeString(viter1146)
+ for kiter1180,viter1181 in self.part_vals.items():
+ oprot.writeString(kiter1180)
+ oprot.writeString(viter1181)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -29221,11 +29362,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1150, _size1147) = iprot.readListBegin()
- for _i1151 in xrange(_size1147):
- _elem1152 = Index()
- _elem1152.read(iprot)
- self.success.append(_elem1152)
+ (_etype1185, _size1182) = iprot.readListBegin()
+ for _i1186 in xrange(_size1182):
+ _elem1187 = Index()
+ _elem1187.read(iprot)
+ self.success.append(_elem1187)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29254,8 +29395,8 @@ class get_indexes_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1153 in self.success:
- iter1153.write(oprot)
+ for iter1188 in self.success:
+ iter1188.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29410,10 +29551,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1157, _size1154) = iprot.readListBegin()
- for _i1158 in xrange(_size1154):
- _elem1159 = iprot.readString()
- self.success.append(_elem1159)
+ (_etype1192, _size1189) = iprot.readListBegin()
+ for _i1193 in xrange(_size1189):
+ _elem1194 = iprot.readString()
+ self.success.append(_elem1194)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29436,8 +29577,8 @@ class get_index_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1160 in self.success:
- oprot.writeString(iter1160)
+ for iter1195 in self.success:
+ oprot.writeString(iter1195)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -32621,10 +32762,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1164, _size1161) = iprot.readListBegin()
- for _i1165 in xrange(_size1161):
- _elem1166 = iprot.readString()
- self.success.append(_elem1166)
+ (_etype1199, _size1196) = iprot.readListBegin()
+ for _i1200 in xrange(_size1196):
+ _elem1201 = iprot.readString()
+ self.success.append(_elem1201)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32647,8 +32788,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 iter1167 in self.success:
- oprot.writeString(iter1167)
+ for iter1202 in self.success:
+ oprot.writeString(iter1202)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -33336,10 +33477,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1171, _size1168) = iprot.readListBegin()
- for _i1172 in xrange(_size1168):
- _elem1173 = iprot.readString()
- self.success.append(_elem1173)
+ (_etype1206, _size1203) = iprot.readListBegin()
+ for _i1207 in xrange(_size1203):
+ _elem1208 = iprot.readString()
+ self.success.append(_elem1208)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33362,8 +33503,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 iter1174 in self.success:
- oprot.writeString(iter1174)
+ for iter1209 in self.success:
+ oprot.writeString(iter1209)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -33877,11 +34018,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1178, _size1175) = iprot.readListBegin()
- for _i1179 in xrange(_size1175):
- _elem1180 = Role()
- _elem1180.read(iprot)
- self.success.append(_elem1180)
+ (_etype1213, _size1210) = iprot.readListBegin()
+ for _i1214 in xrange(_size1210):
+ _elem1215 = Role()
+ _elem1215.read(iprot)
+ self.success.append(_elem1215)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33904,8 +34045,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 iter1181 in self.success:
- iter1181.write(oprot)
+ for iter1216 in self.success:
+ iter1216.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -34414,10 +34555,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1185, _size1182) = iprot.readListBegin()
- for _i1186 in xrange(_size1182):
- _elem1187 = iprot.readString()
- self.group_names.append(_elem1187)
+ (_etype1220, _size1217) = iprot.readListBegin()
+ for _i1221 in xrange(_size1217):
+ _elem1222 = iprot.readString()
+ self.group_names.append(_elem1222)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34442,8 +34583,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 iter1188 in self.group_names:
- oprot.writeString(iter1188)
+ for iter1223 in self.group_names:
+ oprot.writeString(iter1223)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -34670,11 +34811,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1192, _size1189) = iprot.readListBegin()
- for _i1193 in xrange(_size1189):
- _elem1194 = HiveObjectPrivilege()
- _elem1194.read(iprot)
- self.success.append(_elem1194)
+ (_etype1227, _size1224) = iprot.readListBegin()
+ for _i1228 in xrange(_size1224):
+ _elem1229 = HiveObjectPrivilege()
+ _elem1229.read(iprot)
+ self.success.append(_elem1229)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34697,8 +34838,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 iter1195 in self.success:
- iter1195.write(oprot)
+ for iter1230 in self.success:
+ iter1230.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35196,10 +35337,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1199, _size1196) = iprot.readListBegin()
- for _i1200 in xrange(_size1196):
- _elem1201 = iprot.readString()
- self.group_names.append(_elem1201)
+ (_etype1234, _size1231) = iprot.readListBegin()
+ for _i1235 in xrange(_size1231):
+ _elem1236 = iprot.readString()
+ self.group_names.append(_elem1236)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35220,8 +35361,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 iter1202 in self.group_names:
- oprot.writeString(iter1202)
+ for iter1237 in self.group_names:
+ oprot.writeString(iter1237)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -35276,10 +35417,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1206, _size1203) = iprot.readListBegin()
- for _i1207 in xrange(_size1203):
- _elem1208 = iprot.readString()
- self.success.append(_elem1208)
+ (_etype1241, _size1238) = iprot.readListBegin()
+ for _i1242 in xrange(_size1238):
+ _elem1243 = iprot.readString()
+ self.success.append(_elem1243)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35302,8 +35443,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 iter1209 in self.success:
- oprot.writeString(iter1209)
+ for iter1244 in self.success:
+ oprot.writeString(iter1244)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -36235,10 +36376,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1213, _size1210) = iprot.readListBegin()
- for _i1214 in xrange(_size1210):
- _elem1215 = iprot.readString()
- self.success.append(_elem1215)
+ (_etype1248, _size1245) = iprot.readListBegin()
+ for _i1249 in xrange(_size1245):
+ _elem1250 = iprot.readString()
+ self.success.append(_elem1250)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36255,8 +36396,8 @@ class get_all_token_identifiers_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1216 in self.success:
- oprot.writeString(iter1216)
+ for iter1251 in self.success:
+ oprot.writeString(iter1251)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -36783,10 +36924,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1220, _size1217) = iprot.readListBegin()
- for _i1221 in xrange(_size1217):
- _elem1222 = iprot.readString()
- self.success.append(_elem1222)
+ (_etype1255, _size1252) = iprot.readListBegin()
+ for _i1256 in xrange(_size1252):
+ _elem1257 = iprot.readString()
+ self.success.append(_elem1257)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36803,8 +36944,8 @@ class get_master_keys_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1223 in self.success:
- oprot.writeString(iter1223)
+ for iter1258 in self.success:
+ oprot.writeString(iter1258)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -37593,6 +37734,338 @@ class commit_txn_result:
def __ne__(self, other):
return not (self == other)
+class get_valid_write_ids_args:
+ """
+ Attributes:
+ - rqst
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'rqst', (GetValidWriteIdsRequest, GetValidWriteIdsRequest.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, rqst=None,):
+ self.rqst = rqst
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.rqst = GetValidWriteIdsRequest()
+ self.rqst.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_valid_write_ids_args')
+ if self.rqst is not None:
+ oprot.writeFieldBegin('rqst', TType.STRUCT, 1)
+ self.rqst.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.rqst)
+ 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_valid_write_ids_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (GetValidWriteIdsResponse, GetValidWriteIdsResponse.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (NoSuchTxnException, NoSuchTxnException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, success=None, o1=None, o2=None,):
+ self.success = success
+ self.o1 = o1
+ self.o2 = o2
+
+ 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.STRUCT:
+ self.success = GetValidWriteIdsResponse()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = NoSuchTxnException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.o2 = MetaException()
+ self.o2.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_valid_write_ids_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ 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()
+ 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)
+ 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 allocate_table_write_ids_args:
+ """
+ Attributes:
+ - rqst
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'rqst', (AllocateTableWriteIdsRequest, AllocateTableWriteIdsRequest.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, rqst=None,):
+ self.rqst = rqst
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.rqst = AllocateTableWriteIdsRequest()
+ self.rqst.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('allocate_table_write_ids_args')
+ if self.rqst is not None:
+ oprot.writeFieldBegin('rqst', TType.STRUCT, 1)
+ self.rqst.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.rqst)
+ 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 allocate_table_write_ids_result:
+ """
+ Attributes:
+ - success
+ - o
<TRUNCATED>