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>