http://git-wip-us.apache.org/repos/asf/hive/blob/926c1e8e/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index a896849..37db81f 100644 --- a/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -1324,6 +1324,57 @@ class Iface(fb303.FacebookService.Iface): """ pass + def find_next_compact(self, workerId): + """ + Parameters: + - workerId + """ + pass + + def update_compactor_state(self, cr, txn_id): + """ + Parameters: + - cr + - txn_id + """ + pass + + def find_columns_with_stats(self, cr): + """ + Parameters: + - cr + """ + pass + + def mark_cleaned(self, cr): + """ + Parameters: + - cr + """ + pass + + def mark_compacted(self, cr): + """ + Parameters: + - cr + """ + pass + + def mark_failed(self, cr): + """ + Parameters: + - cr + """ + pass + + def set_hadoop_jobid(self, jobId, cq_id): + """ + Parameters: + - jobId + - cq_id + """ + pass + def get_next_notification(self, rqst): """ Parameters: @@ -7675,6 +7726,225 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 return + def find_next_compact(self, workerId): + """ + Parameters: + - workerId + """ + self.send_find_next_compact(workerId) + return self.recv_find_next_compact() + + def send_find_next_compact(self, workerId): + self._oprot.writeMessageBegin('find_next_compact', TMessageType.CALL, self._seqid) + args = find_next_compact_args() + args.workerId = workerId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_find_next_compact(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = find_next_compact_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + raise TApplicationException(TApplicationException.MISSING_RESULT, "find_next_compact failed: unknown result") + + def update_compactor_state(self, cr, txn_id): + """ + Parameters: + - cr + - txn_id + """ + self.send_update_compactor_state(cr, txn_id) + self.recv_update_compactor_state() + + def send_update_compactor_state(self, cr, txn_id): + self._oprot.writeMessageBegin('update_compactor_state', TMessageType.CALL, self._seqid) + args = update_compactor_state_args() + args.cr = cr + args.txn_id = txn_id + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_update_compactor_state(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = update_compactor_state_result() + result.read(iprot) + iprot.readMessageEnd() + return + + def find_columns_with_stats(self, cr): + """ + Parameters: + - cr + """ + self.send_find_columns_with_stats(cr) + return self.recv_find_columns_with_stats() + + def send_find_columns_with_stats(self, cr): + self._oprot.writeMessageBegin('find_columns_with_stats', TMessageType.CALL, self._seqid) + args = find_columns_with_stats_args() + args.cr = cr + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_find_columns_with_stats(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = find_columns_with_stats_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "find_columns_with_stats failed: unknown result") + + def mark_cleaned(self, cr): + """ + Parameters: + - cr + """ + self.send_mark_cleaned(cr) + self.recv_mark_cleaned() + + def send_mark_cleaned(self, cr): + self._oprot.writeMessageBegin('mark_cleaned', TMessageType.CALL, self._seqid) + args = mark_cleaned_args() + args.cr = cr + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_mark_cleaned(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = mark_cleaned_result() + result.read(iprot) + iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + return + + def mark_compacted(self, cr): + """ + Parameters: + - cr + """ + self.send_mark_compacted(cr) + self.recv_mark_compacted() + + def send_mark_compacted(self, cr): + self._oprot.writeMessageBegin('mark_compacted', TMessageType.CALL, self._seqid) + args = mark_compacted_args() + args.cr = cr + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_mark_compacted(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = mark_compacted_result() + result.read(iprot) + iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + return + + def mark_failed(self, cr): + """ + Parameters: + - cr + """ + self.send_mark_failed(cr) + self.recv_mark_failed() + + def send_mark_failed(self, cr): + self._oprot.writeMessageBegin('mark_failed', TMessageType.CALL, self._seqid) + args = mark_failed_args() + args.cr = cr + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_mark_failed(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = mark_failed_result() + result.read(iprot) + iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + return + + def set_hadoop_jobid(self, jobId, cq_id): + """ + Parameters: + - jobId + - cq_id + """ + self.send_set_hadoop_jobid(jobId, cq_id) + self.recv_set_hadoop_jobid() + + def send_set_hadoop_jobid(self, jobId, cq_id): + self._oprot.writeMessageBegin('set_hadoop_jobid', TMessageType.CALL, self._seqid) + args = set_hadoop_jobid_args() + args.jobId = jobId + args.cq_id = cq_id + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_set_hadoop_jobid(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = set_hadoop_jobid_result() + result.read(iprot) + iprot.readMessageEnd() + return + def get_next_notification(self, rqst): """ Parameters: @@ -9507,6 +9777,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): self._processMap["compact2"] = Processor.process_compact2 self._processMap["show_compact"] = Processor.process_show_compact self._processMap["add_dynamic_partitions"] = Processor.process_add_dynamic_partitions + self._processMap["find_next_compact"] = Processor.process_find_next_compact + self._processMap["update_compactor_state"] = Processor.process_update_compactor_state + self._processMap["find_columns_with_stats"] = Processor.process_find_columns_with_stats + self._processMap["mark_cleaned"] = Processor.process_mark_cleaned + self._processMap["mark_compacted"] = Processor.process_mark_compacted + self._processMap["mark_failed"] = Processor.process_mark_failed + self._processMap["set_hadoop_jobid"] = Processor.process_set_hadoop_jobid self._processMap["get_next_notification"] = Processor.process_get_next_notification self._processMap["get_current_notificationEventId"] = Processor.process_get_current_notificationEventId self._processMap["get_notification_events_count"] = Processor.process_get_notification_events_count @@ -13695,6 +13972,151 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_find_next_compact(self, seqid, iprot, oprot): + args = find_next_compact_args() + args.read(iprot) + iprot.readMessageEnd() + result = find_next_compact_result() + try: + result.success = self._handler.find_next_compact(args.workerId) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("find_next_compact", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_update_compactor_state(self, seqid, iprot, oprot): + args = update_compactor_state_args() + args.read(iprot) + iprot.readMessageEnd() + result = update_compactor_state_result() + try: + self._handler.update_compactor_state(args.cr, args.txn_id) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("update_compactor_state", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_find_columns_with_stats(self, seqid, iprot, oprot): + args = find_columns_with_stats_args() + args.read(iprot) + iprot.readMessageEnd() + result = find_columns_with_stats_result() + try: + result.success = self._handler.find_columns_with_stats(args.cr) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("find_columns_with_stats", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_mark_cleaned(self, seqid, iprot, oprot): + args = mark_cleaned_args() + args.read(iprot) + iprot.readMessageEnd() + result = mark_cleaned_result() + try: + self._handler.mark_cleaned(args.cr) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("mark_cleaned", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_mark_compacted(self, seqid, iprot, oprot): + args = mark_compacted_args() + args.read(iprot) + iprot.readMessageEnd() + result = mark_compacted_result() + try: + self._handler.mark_compacted(args.cr) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("mark_compacted", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_mark_failed(self, seqid, iprot, oprot): + args = mark_failed_args() + args.read(iprot) + iprot.readMessageEnd() + result = mark_failed_result() + try: + self._handler.mark_failed(args.cr) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("mark_failed", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_set_hadoop_jobid(self, seqid, iprot, oprot): + args = set_hadoop_jobid_args() + args.read(iprot) + iprot.readMessageEnd() + result = set_hadoop_jobid_result() + try: + self._handler.set_hadoop_jobid(args.jobId, args.cq_id) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("set_hadoop_jobid", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_get_next_notification(self, seqid, iprot, oprot): args = get_next_notification_args() args.read(iprot) @@ -16531,10 +16953,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype889, _size886) = iprot.readListBegin() - for _i890 in xrange(_size886): - _elem891 = iprot.readString() - self.success.append(_elem891) + (_etype896, _size893) = iprot.readListBegin() + for _i897 in xrange(_size893): + _elem898 = iprot.readString() + self.success.append(_elem898) iprot.readListEnd() else: iprot.skip(ftype) @@ -16557,8 +16979,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 iter892 in self.success: - oprot.writeString(iter892) + for iter899 in self.success: + oprot.writeString(iter899) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16663,10 +17085,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype896, _size893) = iprot.readListBegin() - for _i897 in xrange(_size893): - _elem898 = iprot.readString() - self.success.append(_elem898) + (_etype903, _size900) = iprot.readListBegin() + for _i904 in xrange(_size900): + _elem905 = iprot.readString() + self.success.append(_elem905) iprot.readListEnd() else: iprot.skip(ftype) @@ -16689,8 +17111,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 iter899 in self.success: - oprot.writeString(iter899) + for iter906 in self.success: + oprot.writeString(iter906) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17460,12 +17882,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype901, _vtype902, _size900 ) = iprot.readMapBegin() - for _i904 in xrange(_size900): - _key905 = iprot.readString() - _val906 = Type() - _val906.read(iprot) - self.success[_key905] = _val906 + (_ktype908, _vtype909, _size907 ) = iprot.readMapBegin() + for _i911 in xrange(_size907): + _key912 = iprot.readString() + _val913 = Type() + _val913.read(iprot) + self.success[_key912] = _val913 iprot.readMapEnd() else: iprot.skip(ftype) @@ -17488,9 +17910,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 kiter907,viter908 in self.success.items(): - oprot.writeString(kiter907) - viter908.write(oprot) + for kiter914,viter915 in self.success.items(): + oprot.writeString(kiter914) + viter915.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -17633,11 +18055,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype912, _size909) = iprot.readListBegin() - for _i913 in xrange(_size909): - _elem914 = FieldSchema() - _elem914.read(iprot) - self.success.append(_elem914) + (_etype919, _size916) = iprot.readListBegin() + for _i920 in xrange(_size916): + _elem921 = FieldSchema() + _elem921.read(iprot) + self.success.append(_elem921) iprot.readListEnd() else: iprot.skip(ftype) @@ -17672,8 +18094,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 iter915 in self.success: - iter915.write(oprot) + for iter922 in self.success: + iter922.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17840,11 +18262,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype919, _size916) = iprot.readListBegin() - for _i920 in xrange(_size916): - _elem921 = FieldSchema() - _elem921.read(iprot) - self.success.append(_elem921) + (_etype926, _size923) = iprot.readListBegin() + for _i927 in xrange(_size923): + _elem928 = FieldSchema() + _elem928.read(iprot) + self.success.append(_elem928) iprot.readListEnd() else: iprot.skip(ftype) @@ -17879,8 +18301,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 iter922 in self.success: - iter922.write(oprot) + for iter929 in self.success: + iter929.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18033,11 +18455,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype926, _size923) = iprot.readListBegin() - for _i927 in xrange(_size923): - _elem928 = FieldSchema() - _elem928.read(iprot) - self.success.append(_elem928) + (_etype933, _size930) = iprot.readListBegin() + for _i934 in xrange(_size930): + _elem935 = FieldSchema() + _elem935.read(iprot) + self.success.append(_elem935) iprot.readListEnd() else: iprot.skip(ftype) @@ -18072,8 +18494,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 iter929 in self.success: - iter929.write(oprot) + for iter936 in self.success: + iter936.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18240,11 +18662,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype933, _size930) = iprot.readListBegin() - for _i934 in xrange(_size930): - _elem935 = FieldSchema() - _elem935.read(iprot) - self.success.append(_elem935) + (_etype940, _size937) = iprot.readListBegin() + for _i941 in xrange(_size937): + _elem942 = FieldSchema() + _elem942.read(iprot) + self.success.append(_elem942) iprot.readListEnd() else: iprot.skip(ftype) @@ -18279,8 +18701,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 iter936 in self.success: - iter936.write(oprot) + for iter943 in self.success: + iter943.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18733,66 +19155,66 @@ class create_table_with_constraints_args: elif fid == 2: if ftype == TType.LIST: self.primaryKeys = [] - (_etype940, _size937) = iprot.readListBegin() - for _i941 in xrange(_size937): - _elem942 = SQLPrimaryKey() - _elem942.read(iprot) - self.primaryKeys.append(_elem942) + (_etype947, _size944) = iprot.readListBegin() + for _i948 in xrange(_size944): + _elem949 = SQLPrimaryKey() + _elem949.read(iprot) + self.primaryKeys.append(_elem949) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.foreignKeys = [] - (_etype946, _size943) = iprot.readListBegin() - for _i947 in xrange(_size943): - _elem948 = SQLForeignKey() - _elem948.read(iprot) - self.foreignKeys.append(_elem948) + (_etype953, _size950) = iprot.readListBegin() + for _i954 in xrange(_size950): + _elem955 = SQLForeignKey() + _elem955.read(iprot) + self.foreignKeys.append(_elem955) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.uniqueConstraints = [] - (_etype952, _size949) = iprot.readListBegin() - for _i953 in xrange(_size949): - _elem954 = SQLUniqueConstraint() - _elem954.read(iprot) - self.uniqueConstraints.append(_elem954) + (_etype959, _size956) = iprot.readListBegin() + for _i960 in xrange(_size956): + _elem961 = SQLUniqueConstraint() + _elem961.read(iprot) + self.uniqueConstraints.append(_elem961) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.LIST: self.notNullConstraints = [] - (_etype958, _size955) = iprot.readListBegin() - for _i959 in xrange(_size955): - _elem960 = SQLNotNullConstraint() - _elem960.read(iprot) - self.notNullConstraints.append(_elem960) + (_etype965, _size962) = iprot.readListBegin() + for _i966 in xrange(_size962): + _elem967 = SQLNotNullConstraint() + _elem967.read(iprot) + self.notNullConstraints.append(_elem967) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.LIST: self.defaultConstraints = [] - (_etype964, _size961) = iprot.readListBegin() - for _i965 in xrange(_size961): - _elem966 = SQLDefaultConstraint() - _elem966.read(iprot) - self.defaultConstraints.append(_elem966) + (_etype971, _size968) = iprot.readListBegin() + for _i972 in xrange(_size968): + _elem973 = SQLDefaultConstraint() + _elem973.read(iprot) + self.defaultConstraints.append(_elem973) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.LIST: self.checkConstraints = [] - (_etype970, _size967) = iprot.readListBegin() - for _i971 in xrange(_size967): - _elem972 = SQLCheckConstraint() - _elem972.read(iprot) - self.checkConstraints.append(_elem972) + (_etype977, _size974) = iprot.readListBegin() + for _i978 in xrange(_size974): + _elem979 = SQLCheckConstraint() + _elem979.read(iprot) + self.checkConstraints.append(_elem979) iprot.readListEnd() else: iprot.skip(ftype) @@ -18813,43 +19235,43 @@ class create_table_with_constraints_args: if self.primaryKeys is not None: oprot.writeFieldBegin('primaryKeys', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys)) - for iter973 in self.primaryKeys: - iter973.write(oprot) + for iter980 in self.primaryKeys: + iter980.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 iter974 in self.foreignKeys: - iter974.write(oprot) + for iter981 in self.foreignKeys: + iter981.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 iter975 in self.uniqueConstraints: - iter975.write(oprot) + for iter982 in self.uniqueConstraints: + iter982.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 iter976 in self.notNullConstraints: - iter976.write(oprot) + for iter983 in self.notNullConstraints: + iter983.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.defaultConstraints is not None: oprot.writeFieldBegin('defaultConstraints', TType.LIST, 6) oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints)) - for iter977 in self.defaultConstraints: - iter977.write(oprot) + for iter984 in self.defaultConstraints: + iter984.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.checkConstraints is not None: oprot.writeFieldBegin('checkConstraints', TType.LIST, 7) oprot.writeListBegin(TType.STRUCT, len(self.checkConstraints)) - for iter978 in self.checkConstraints: - iter978.write(oprot) + for iter985 in self.checkConstraints: + iter985.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20409,10 +20831,10 @@ class truncate_table_args: elif fid == 3: if ftype == TType.LIST: self.partNames = [] - (_etype982, _size979) = iprot.readListBegin() - for _i983 in xrange(_size979): - _elem984 = iprot.readString() - self.partNames.append(_elem984) + (_etype989, _size986) = iprot.readListBegin() + for _i990 in xrange(_size986): + _elem991 = iprot.readString() + self.partNames.append(_elem991) iprot.readListEnd() else: iprot.skip(ftype) @@ -20437,8 +20859,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 iter985 in self.partNames: - oprot.writeString(iter985) + for iter992 in self.partNames: + oprot.writeString(iter992) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20783,10 +21205,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype989, _size986) = iprot.readListBegin() - for _i990 in xrange(_size986): - _elem991 = iprot.readString() - self.success.append(_elem991) + (_etype996, _size993) = iprot.readListBegin() + for _i997 in xrange(_size993): + _elem998 = iprot.readString() + self.success.append(_elem998) iprot.readListEnd() else: iprot.skip(ftype) @@ -20809,8 +21231,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 iter992 in self.success: - oprot.writeString(iter992) + for iter999 in self.success: + oprot.writeString(iter999) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20960,10 +21382,10 @@ class get_tables_by_type_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype996, _size993) = iprot.readListBegin() - for _i997 in xrange(_size993): - _elem998 = iprot.readString() - self.success.append(_elem998) + (_etype1003, _size1000) = iprot.readListBegin() + for _i1004 in xrange(_size1000): + _elem1005 = iprot.readString() + self.success.append(_elem1005) iprot.readListEnd() else: iprot.skip(ftype) @@ -20986,8 +21408,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 iter999 in self.success: - oprot.writeString(iter999) + for iter1006 in self.success: + oprot.writeString(iter1006) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21111,10 +21533,10 @@ class get_materialized_views_for_rewriting_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1003, _size1000) = iprot.readListBegin() - for _i1004 in xrange(_size1000): - _elem1005 = iprot.readString() - self.success.append(_elem1005) + (_etype1010, _size1007) = iprot.readListBegin() + for _i1011 in xrange(_size1007): + _elem1012 = iprot.readString() + self.success.append(_elem1012) iprot.readListEnd() else: iprot.skip(ftype) @@ -21137,8 +21559,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 iter1006 in self.success: - oprot.writeString(iter1006) + for iter1013 in self.success: + oprot.writeString(iter1013) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21211,10 +21633,10 @@ class get_table_meta_args: elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] - (_etype1010, _size1007) = iprot.readListBegin() - for _i1011 in xrange(_size1007): - _elem1012 = iprot.readString() - self.tbl_types.append(_elem1012) + (_etype1017, _size1014) = iprot.readListBegin() + for _i1018 in xrange(_size1014): + _elem1019 = iprot.readString() + self.tbl_types.append(_elem1019) iprot.readListEnd() else: iprot.skip(ftype) @@ -21239,8 +21661,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 iter1013 in self.tbl_types: - oprot.writeString(iter1013) + for iter1020 in self.tbl_types: + oprot.writeString(iter1020) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21296,11 +21718,11 @@ class get_table_meta_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1017, _size1014) = iprot.readListBegin() - for _i1018 in xrange(_size1014): - _elem1019 = TableMeta() - _elem1019.read(iprot) - self.success.append(_elem1019) + (_etype1024, _size1021) = iprot.readListBegin() + for _i1025 in xrange(_size1021): + _elem1026 = TableMeta() + _elem1026.read(iprot) + self.success.append(_elem1026) iprot.readListEnd() else: iprot.skip(ftype) @@ -21323,8 +21745,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 iter1020 in self.success: - iter1020.write(oprot) + for iter1027 in self.success: + iter1027.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21448,10 +21870,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1024, _size1021) = iprot.readListBegin() - for _i1025 in xrange(_size1021): - _elem1026 = iprot.readString() - self.success.append(_elem1026) + (_etype1031, _size1028) = iprot.readListBegin() + for _i1032 in xrange(_size1028): + _elem1033 = iprot.readString() + self.success.append(_elem1033) iprot.readListEnd() else: iprot.skip(ftype) @@ -21474,8 +21896,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 iter1027 in self.success: - oprot.writeString(iter1027) + for iter1034 in self.success: + oprot.writeString(iter1034) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21711,10 +22133,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype1031, _size1028) = iprot.readListBegin() - for _i1032 in xrange(_size1028): - _elem1033 = iprot.readString() - self.tbl_names.append(_elem1033) + (_etype1038, _size1035) = iprot.readListBegin() + for _i1039 in xrange(_size1035): + _elem1040 = iprot.readString() + self.tbl_names.append(_elem1040) iprot.readListEnd() else: iprot.skip(ftype) @@ -21735,8 +22157,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 iter1034 in self.tbl_names: - oprot.writeString(iter1034) + for iter1041 in self.tbl_names: + oprot.writeString(iter1041) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21788,11 +22210,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1038, _size1035) = iprot.readListBegin() - for _i1039 in xrange(_size1035): - _elem1040 = Table() - _elem1040.read(iprot) - self.success.append(_elem1040) + (_etype1045, _size1042) = iprot.readListBegin() + for _i1046 in xrange(_size1042): + _elem1047 = Table() + _elem1047.read(iprot) + self.success.append(_elem1047) iprot.readListEnd() else: iprot.skip(ftype) @@ -21809,8 +22231,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 iter1041 in self.success: - iter1041.write(oprot) + for iter1048 in self.success: + iter1048.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22678,10 +23100,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1045, _size1042) = iprot.readListBegin() - for _i1046 in xrange(_size1042): - _elem1047 = iprot.readString() - self.success.append(_elem1047) + (_etype1052, _size1049) = iprot.readListBegin() + for _i1053 in xrange(_size1049): + _elem1054 = iprot.readString() + self.success.append(_elem1054) iprot.readListEnd() else: iprot.skip(ftype) @@ -22716,8 +23138,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 iter1048 in self.success: - oprot.writeString(iter1048) + for iter1055 in self.success: + oprot.writeString(iter1055) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23846,11 +24268,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype1052, _size1049) = iprot.readListBegin() - for _i1053 in xrange(_size1049): - _elem1054 = Partition() - _elem1054.read(iprot) - self.new_parts.append(_elem1054) + (_etype1059, _size1056) = iprot.readListBegin() + for _i1060 in xrange(_size1056): + _elem1061 = Partition() + _elem1061.read(iprot) + self.new_parts.append(_elem1061) iprot.readListEnd() else: iprot.skip(ftype) @@ -23867,8 +24289,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 iter1055 in self.new_parts: - iter1055.write(oprot) + for iter1062 in self.new_parts: + iter1062.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24026,11 +24448,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype1059, _size1056) = iprot.readListBegin() - for _i1060 in xrange(_size1056): - _elem1061 = PartitionSpec() - _elem1061.read(iprot) - self.new_parts.append(_elem1061) + (_etype1066, _size1063) = iprot.readListBegin() + for _i1067 in xrange(_size1063): + _elem1068 = PartitionSpec() + _elem1068.read(iprot) + self.new_parts.append(_elem1068) iprot.readListEnd() else: iprot.skip(ftype) @@ -24047,8 +24469,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 iter1062 in self.new_parts: - iter1062.write(oprot) + for iter1069 in self.new_parts: + iter1069.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24222,10 +24644,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1066, _size1063) = iprot.readListBegin() - for _i1067 in xrange(_size1063): - _elem1068 = iprot.readString() - self.part_vals.append(_elem1068) + (_etype1073, _size1070) = iprot.readListBegin() + for _i1074 in xrange(_size1070): + _elem1075 = iprot.readString() + self.part_vals.append(_elem1075) iprot.readListEnd() else: iprot.skip(ftype) @@ -24250,8 +24672,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 iter1069 in self.part_vals: - oprot.writeString(iter1069) + for iter1076 in self.part_vals: + oprot.writeString(iter1076) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24604,10 +25026,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1073, _size1070) = iprot.readListBegin() - for _i1074 in xrange(_size1070): - _elem1075 = iprot.readString() - self.part_vals.append(_elem1075) + (_etype1080, _size1077) = iprot.readListBegin() + for _i1081 in xrange(_size1077): + _elem1082 = iprot.readString() + self.part_vals.append(_elem1082) iprot.readListEnd() else: iprot.skip(ftype) @@ -24638,8 +25060,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 iter1076 in self.part_vals: - oprot.writeString(iter1076) + for iter1083 in self.part_vals: + oprot.writeString(iter1083) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -25234,10 +25656,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1080, _size1077) = iprot.readListBegin() - for _i1081 in xrange(_size1077): - _elem1082 = iprot.readString() - self.part_vals.append(_elem1082) + (_etype1087, _size1084) = iprot.readListBegin() + for _i1088 in xrange(_size1084): + _elem1089 = iprot.readString() + self.part_vals.append(_elem1089) iprot.readListEnd() else: iprot.skip(ftype) @@ -25267,8 +25689,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 iter1083 in self.part_vals: - oprot.writeString(iter1083) + for iter1090 in self.part_vals: + oprot.writeString(iter1090) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -25441,10 +25863,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1087, _size1084) = iprot.readListBegin() - for _i1088 in xrange(_size1084): - _elem1089 = iprot.readString() - self.part_vals.append(_elem1089) + (_etype1094, _size1091) = iprot.readListBegin() + for _i1095 in xrange(_size1091): + _elem1096 = iprot.readString() + self.part_vals.append(_elem1096) iprot.readListEnd() else: iprot.skip(ftype) @@ -25480,8 +25902,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 iter1090 in self.part_vals: - oprot.writeString(iter1090) + for iter1097 in self.part_vals: + oprot.writeString(iter1097) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -26218,10 +26640,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1094, _size1091) = iprot.readListBegin() - for _i1095 in xrange(_size1091): - _elem1096 = iprot.readString() - self.part_vals.append(_elem1096) + (_etype1101, _size1098) = iprot.readListBegin() + for _i1102 in xrange(_size1098): + _elem1103 = iprot.readString() + self.part_vals.append(_elem1103) iprot.readListEnd() else: iprot.skip(ftype) @@ -26246,8 +26668,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 iter1097 in self.part_vals: - oprot.writeString(iter1097) + for iter1104 in self.part_vals: + oprot.writeString(iter1104) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -26406,11 +26828,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype1099, _vtype1100, _size1098 ) = iprot.readMapBegin() - for _i1102 in xrange(_size1098): - _key1103 = iprot.readString() - _val1104 = iprot.readString() - self.partitionSpecs[_key1103] = _val1104 + (_ktype1106, _vtype1107, _size1105 ) = iprot.readMapBegin() + for _i1109 in xrange(_size1105): + _key1110 = iprot.readString() + _val1111 = iprot.readString() + self.partitionSpecs[_key1110] = _val1111 iprot.readMapEnd() else: iprot.skip(ftype) @@ -26447,9 +26869,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 kiter1105,viter1106 in self.partitionSpecs.items(): - oprot.writeString(kiter1105) - oprot.writeString(viter1106) + for kiter1112,viter1113 in self.partitionSpecs.items(): + oprot.writeString(kiter1112) + oprot.writeString(viter1113) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -26654,11 +27076,11 @@ class exchange_partitions_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype1108, _vtype1109, _size1107 ) = iprot.readMapBegin() - for _i1111 in xrange(_size1107): - _key1112 = iprot.readString() - _val1113 = iprot.readString() - self.partitionSpecs[_key1112] = _val1113 + (_ktype1115, _vtype1116, _size1114 ) = iprot.readMapBegin() + for _i1118 in xrange(_size1114): + _key1119 = iprot.readString() + _val1120 = iprot.readString() + self.partitionSpecs[_key1119] = _val1120 iprot.readMapEnd() else: iprot.skip(ftype) @@ -26695,9 +27117,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 kiter1114,viter1115 in self.partitionSpecs.items(): - oprot.writeString(kiter1114) - oprot.writeString(viter1115) + for kiter1121,viter1122 in self.partitionSpecs.items(): + oprot.writeString(kiter1121) + oprot.writeString(viter1122) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -26780,11 +27202,11 @@ class exchange_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1119, _size1116) = iprot.readListBegin() - for _i1120 in xrange(_size1116): - _elem1121 = Partition() - _elem1121.read(iprot) - self.success.append(_elem1121) + (_etype1126, _size1123) = iprot.readListBegin() + for _i1127 in xrange(_size1123): + _elem1128 = Partition() + _elem1128.read(iprot) + self.success.append(_elem1128) iprot.readListEnd() else: iprot.skip(ftype) @@ -26825,8 +27247,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 iter1122 in self.success: - iter1122.write(oprot) + for iter1129 in self.success: + iter1129.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26920,10 +27342,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1126, _size1123) = iprot.readListBegin() - for _i1127 in xrange(_size1123): - _elem1128 = iprot.readString() - self.part_vals.append(_elem1128) + (_etype1133, _size1130) = iprot.readListBegin() + for _i1134 in xrange(_size1130): + _elem1135 = iprot.readString() + self.part_vals.append(_elem1135) iprot.readListEnd() else: iprot.skip(ftype) @@ -26935,10 +27357,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype1132, _size1129) = iprot.readListBegin() - for _i1133 in xrange(_size1129): - _elem1134 = iprot.readString() - self.group_names.append(_elem1134) + (_etype1139, _size1136) = iprot.readListBegin() + for _i1140 in xrange(_size1136): + _elem1141 = iprot.readString() + self.group_names.append(_elem1141) iprot.readListEnd() else: iprot.skip(ftype) @@ -26963,8 +27385,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 iter1135 in self.part_vals: - oprot.writeString(iter1135) + for iter1142 in self.part_vals: + oprot.writeString(iter1142) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -26974,8 +27396,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 iter1136 in self.group_names: - oprot.writeString(iter1136) + for iter1143 in self.group_names: + oprot.writeString(iter1143) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -27404,11 +27826,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1140, _size1137) = iprot.readListBegin() - for _i1141 in xrange(_size1137): - _elem1142 = Partition() - _elem1142.read(iprot) - self.success.append(_elem1142) + (_etype1147, _size1144) = iprot.readListBegin() + for _i1148 in xrange(_size1144): + _elem1149 = Partition() + _elem1149.read(iprot) + self.success.append(_elem1149) iprot.readListEnd() else: iprot.skip(ftype) @@ -27437,8 +27859,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 iter1143 in self.success: - iter1143.write(oprot) + for iter1150 in self.success: + iter1150.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27532,10 +27954,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype1147, _size1144) = iprot.readListBegin() - for _i1148 in xrange(_size1144): - _elem1149 = iprot.readString() - self.group_names.append(_elem1149) + (_etype1154, _size1151) = iprot.readListBegin() + for _i1155 in xrange(_size1151): + _elem1156 = iprot.readString() + self.group_names.append(_elem1156) iprot.readListEnd() else: iprot.skip(ftype) @@ -27568,8 +27990,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 iter1150 in self.group_names: - oprot.writeString(iter1150) + for iter1157 in self.group_names: + oprot.writeString(iter1157) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -27630,11 +28052,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1154, _size1151) = iprot.readListBegin() - for _i1155 in xrange(_size1151): - _elem1156 = Partition() - _elem1156.read(iprot) - self.success.append(_elem1156) + (_etype1161, _size1158) = iprot.readListBegin() + for _i1162 in xrange(_size1158): + _elem1163 = Partition() + _elem1163.read(iprot) + self.success.append(_elem1163) iprot.readListEnd() else: iprot.skip(ftype) @@ -27663,8 +28085,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 iter1157 in self.success: - iter1157.write(oprot) + for iter1164 in self.success: + iter1164.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27822,11 +28244,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1161, _size1158) = iprot.readListBegin() - for _i1162 in xrange(_size1158): - _elem1163 = PartitionSpec() - _elem1163.read(iprot) - self.success.append(_elem1163) + (_etype1168, _size1165) = iprot.readListBegin() + for _i1169 in xrange(_size1165): + _elem1170 = PartitionSpec() + _elem1170.read(iprot) + self.success.append(_elem1170) iprot.readListEnd() else: iprot.skip(ftype) @@ -27855,8 +28277,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 iter1164 in self.success: - iter1164.write(oprot) + for iter1171 in self.success: + iter1171.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28014,10 +28436,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1168, _size1165) = iprot.readListBegin() - for _i1169 in xrange(_size1165): - _elem1170 = iprot.readString() - self.success.append(_elem1170) + (_etype1175, _size1172) = iprot.readListBegin() + for _i1176 in xrange(_size1172): + _elem1177 = iprot.readString() + self.success.append(_elem1177) iprot.readListEnd() else: iprot.skip(ftype) @@ -28046,8 +28468,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 iter1171 in self.success: - oprot.writeString(iter1171) + for iter1178 in self.success: + oprot.writeString(iter1178) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28287,10 +28709,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1175, _size1172) = iprot.readListBegin() - for _i1176 in xrange(_size1172): - _elem1177 = iprot.readString() - self.part_vals.append(_elem1177) + (_etype1182, _size1179) = iprot.readListBegin() + for _i1183 in xrange(_size1179): + _elem1184 = iprot.readString() + self.part_vals.append(_elem1184) iprot.readListEnd() else: iprot.skip(ftype) @@ -28320,8 +28742,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 iter1178 in self.part_vals: - oprot.writeString(iter1178) + for iter1185 in self.part_vals: + oprot.writeString(iter1185) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -28385,11 +28807,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1182, _size1179) = iprot.readListBegin() - for _i1183 in xrange(_size1179): - _elem1184 = Partition() - _elem1184.read(iprot) - self.success.append(_elem1184) + (_etype1189, _size1186) = iprot.readListBegin() + for _i1190 in xrange(_size1186): + _elem1191 = Partition() + _elem1191.read(iprot) + self.success.append(_elem1191) iprot.readListEnd() else: iprot.skip(ftype) @@ -28418,8 +28840,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 iter1185 in self.success: - iter1185.write(oprot) + for iter1192 in self.success: + iter1192.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28506,10 +28928,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1189, _size1186) = iprot.readListBegin() - for _i1190 in xrange(_size1186): - _elem1191 = iprot.readString() - self.part_vals.append(_elem1191) + (_etype1196, _size1193) = iprot.readListBegin() + for _i1197 in xrange(_size1193): + _elem1198 = iprot.readString() + self.part_vals.append(_elem1198) iprot.readListEnd() else: iprot.skip(ftype) @@ -28526,10 +28948,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype1195, _size1192) = iprot.readListBegin() - for _i1196 in xrange(_size1192): - _elem1197 = iprot.readString() - self.group_names.append(_elem1197) + (_etype1202, _size1199) = iprot.readListBegin() + for _i1203 in xrange(_size1199): + _elem1204 = iprot.readString() + self.group_names.append(_elem1204) iprot.readListEnd() else: iprot.skip(ftype) @@ -28554,8 +28976,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 iter1198 in self.part_vals: - oprot.writeString(iter1198) + for iter1205 in self.part_vals: + oprot.writeString(iter1205) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -28569,8 +28991,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 iter1199 in self.group_names: - oprot.writeString(iter1199) + for iter1206 in self.group_names: + oprot.writeString(iter1206) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -28632,11 +29054,11 @@ class get_partitions_ps_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1203, _size1200) = iprot.readListBegin() - for _i1204 in xrange(_size1200): - _elem1205 = Partition() - _elem1205.read(iprot) - self.success.append(_elem1205) + (_etype1210, _size1207) = iprot.readListBegin() + for _i1211 in xrange(_size1207): + _elem1212 = Partition() + _elem1212.read(iprot) + self.success.append(_elem1212) iprot.readListEnd() else: iprot.skip(ftype) @@ -28665,8 +29087,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 iter1206 in self.success: - iter1206.write(oprot) + for iter1213 in self.success: + iter1213.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28747,10 +29169,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1210, _size1207) = iprot.readListBegin() - for _i1211 in xrange(_size1207): - _elem1212 = iprot.readString() - self.part_vals.append(_elem1212) + (_etype1217, _size1214) = iprot.readListBegin() + for _i1218 in xrange(_size1214): + _elem1219 = iprot.readString() + self.part_vals.append(_elem1219) iprot.readListEnd() else: iprot.skip(ftype) @@ -28780,8 +29202,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 iter1213 in self.part_vals: - oprot.writeString(iter1213) + for iter1220 in self.part_vals: + oprot.writeString(iter1220) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -28845,10 +29267,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1217, _size1214) = iprot.readListBegin() - for _i1218 in xrange(_size1214): - _elem1219 = iprot.readString() - self.success.append(_elem1219) + (_etype1224, _size1221) = iprot.readListBegin() + for _i1225 in xrange(_size1221): + _elem1226 = iprot.readString() + self.success.append(_elem1226) iprot.readListEnd() else: iprot.skip(ftype) @@ -28877,8 +29299,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 iter1220 in self.success: - oprot.writeString(iter1220) + for iter1227 in self.success: + oprot.writeString(iter1227) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -29049,11 +29471,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1224, _size1221) = iprot.readListBegin() - for _i1225 in xrange(_size1221): - _elem1226 = Partition() - _elem1226.read(iprot) - self.success.append(_elem1226) + (_etype1231, _size1228) = iprot.readListBegin() + for _i1232 in xrange(_size1228): + _elem1233 = Partition() + _elem1233.read(iprot) + self.success.append(_elem1233) iprot.readListEnd() else: iprot.skip(ftype) @@ -29082,8 +29504,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 iter1227 in self.success: - iter1227.write(oprot) + for iter1234 in self.success: + iter1234.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -29254,11 +29676,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1231, _size1228) = iprot.readListBegin() - for _i1232 in xrange(_size1228): - _elem1233 = PartitionSpec() - _elem1233.read(iprot) - self.success.append(_elem1233) + (_etype1238, _size1235) = iprot.readListBegin() + for _i1239 in xrange(_size1235): + _elem1240 = PartitionSpec() + _elem1240.read(iprot) + self.success.append(_elem1240) iprot.readListEnd() else: iprot.skip(ftype) @@ -29287,8 +29709,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 iter1234 in self.success: - iter1234.write(oprot) + for iter1241 in self.success: + iter1241.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -29708,10 +30130,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype1238, _size1235) = iprot.readListBegin() - for _i1239 in xrange(_size1235): - _elem1240 = iprot.readString() - self.names.append(_elem1240) + (_etype1245, _size1242) = iprot.readListBegin() + for _i1246 in xrange(_size1242): + _elem1247 = iprot.readString() + self.names.append(_elem1247) iprot.readListEnd() else: iprot.skip(ftype) @@ -29736,8 +30158,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 iter1241 in self.names: - oprot.writeString(iter1241) + for iter1248 in self.names: + oprot.writeString(iter1248) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -29796,11 +30218,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1245, _size1242) = iprot.readListBegin() - for _i1246 in xrange(_size1242): - _elem1247 = Partition() - _elem1247.read(iprot) - self.success.append(_elem1247) + (_etype1252, _size1249) = iprot.readListBegin() + for _i1253 in xrange(_size1249): + _elem1254 = Partition() + _elem1254.read(iprot) + self.success.append(_elem1254) iprot.readListEnd() else: iprot.skip(ftype) @@ -29829,8 +30251,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 iter1248 in self.success: - iter1248.write(oprot) + for iter1255 in self.success: + iter1255.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -30080,11 +30502,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1252, _size1249) = iprot.readListBegin() - for _i1253 in xrange(_size1249): - _elem1254 = Partition() - _elem1254.read(iprot) - self.new_parts.append(_elem1254) + (_etype1259, _size1256) = iprot.readListBegin() + for _i1260 in xrange(_size1256): + _elem1261 = Partition() + _elem1261.read(iprot) + self.new_parts.append(_elem1261) iprot.readListEnd() else: iprot.skip(ftype) @@ -30109,8 +30531,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 iter1255 in self.new_parts: - iter1255.write(oprot) + for iter1262 in self.new_parts: + iter1262.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -30263,11 +30685,11 @@ class alter_partitions_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1259, _size1256) = iprot.readListBegin() - for _i1260 in xrange(_size1256): - _elem1261 = Partition() - _elem1261.read(iprot) - self.new_parts.append(_elem1261) + (_etype1266, _size1263) = iprot.readListBegin() + for _i1267 in xrange(_size1263): + _elem1268 = Partition() + _elem1268.read(iprot) + self.new_parts.append(_elem1268) iprot.readListEnd() else: iprot.skip(ftype) @@ -30298,8 +30720,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 iter1262 in self.new_parts: - iter1262.write(oprot) + for iter1269 in self.new_parts: + iter1269.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -30802,10 +31224,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1266, _size1263) = iprot.readListBegin() - for _i1267 in xrange(_size1263): - _elem1268 = iprot.readString() - self.part_vals.append(_elem1268) + (_etype1273, _size1270) = iprot.readListBegin() + for _i1274 in xrange(_size1270): + _elem1275 = iprot.readString() + self.part_vals.append(_elem1275) iprot.readListEnd() else: iprot.skip(ftype) @@ -30836,8 +31258,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 iter1269 in self.part_vals: - oprot.writeString(iter1269) + for iter1276 in self.part_vals: + oprot.writeString(iter1276) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -31138,10 +31560,10 @@ class partition_name_has_valid_characters_args: if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype1273, _size1270) = iprot.readListBegin() - for _i1274 in xrange(_size1270): - _elem1275 = iprot.readString() - self.part_vals.append(_elem1275) + (_etype1280, _size1277) = iprot.readListBegin() + for _i1281 in xrange(_size1277): + _elem1282 = iprot.readString() + self.part_vals.append(_elem1282) iprot.readListEnd() else: iprot.skip(ftype) @@ -31163,8 +31585,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 iter1276 in self.part_vals: - oprot.writeString(iter1276) + for iter1283 in self.part_vals: + oprot.writeString(iter1283) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -31522,10 +31944,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1280, _size1277) = iprot.readListBegin() - for _i1281 in xrange(_size1277): - _elem1282 = iprot.readString() - self.success.append(_elem1282) + (_etype1287, _size1284) = iprot.readListBegin() + for _i1288 in xrange(_size1284): + _elem1289 = iprot.readString() + self.success.append(_elem1289) iprot.readListEnd() else: iprot.skip(ftype) @@ -31548,8 +31970,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 iter1283 in self.success: - oprot.writeString(iter1283) + for iter1290 in self.success: + oprot.writeString(iter1290) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -31673,11 +32095,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype1285, _vtype1286, _size1284 ) = iprot.readMapBegin() - for _i1288 in xrange(_size1284): - _key1289 = iprot.readString() - _val1290 = iprot.readString() - self.success[_key1289] = _val1290 + (_ktype1292, _vtype1293, _size1291 ) = iprot.readMapBegin() + for _i1295 in xrange(_size1291): + _key1296 = iprot.readString() + _val1297 = iprot.readString() + self.success[_key1296] = _val1297 iprot.readMapEnd() else: iprot.skip(ftype) @@ -31700,9 +32122,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 kiter1291,viter1292 in self.success.items(): - oprot.writeString(kiter1291) - oprot.writeString(viter1292) + for kiter1298,viter1299 in self.success.items(): + oprot.writeString(kiter1298) + oprot.writeString(viter1299) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -31778,11 +32200,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype1294, _vtype1295, _size1293 ) = iprot.readMapBegin() - for _i1297 in xrange(_size1293): - _key1298 = iprot.readString() - _val1299 = iprot.readString() - self.part_vals[_key1298] = _val1299 + (_ktype1301, _vtype1302, _size1300 ) = iprot.readMapBegin() + for _i1304 in xrange(_size1300): + _key1305 = iprot.readString() + _val1306 = iprot.readString() + self.part_vals[_key1305] = _val1306 iprot.readMapEnd() else: iprot.skip(ftype) @@ -31812,9 +32234,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 kiter1300,viter1301 in self.part_vals.items(): - oprot.writeString(kiter1300) - oprot.writeString(viter1301) + for kiter1307,viter1308 in self.part_vals.items(): + oprot.writeString(kiter1307) + oprot.writeString(viter1308) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -32028,11 +32450,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype1303, _vtype1304, _size1302 ) = iprot.readMapBegin() - for _i1306 in xrange(_size1302): - _key1307 = iprot.readString() - _val1308 = iprot.readString() - self.part_vals[_key1307] = _val1308 + (_ktype1310, _vtype1311, _size1309 ) = iprot.readMapBegin() + for _i1313 in xrange(_size1309): + _key1314 = iprot.readString() + _val1315 = iprot.readString() + self.part_vals[_key1314] = _val1315 iprot.readMapEnd() else: iprot.skip(ftype) @@ -32062,9 +32484,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 kiter1309,viter1310 in self.part_vals.items(): - oprot.writeString(kiter1309) - oprot.writeString(viter1310) + for kiter1316,viter1317 in self.part_vals.items(): + oprot.writeString(kiter1316) + oprot.writeString(viter1317) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -36090,10 +36512,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1314, _size1311) = iprot.readListBegin() - for _i1315 in xrange(_size1311): - _elem1316 = iprot.readString() - self.success.append(_elem1316) + (_etype1321, _size1318) = iprot.readListBegin() + for _i1322 in xrange(_size1318): + _elem1323 = iprot.readString() + self.success.append(_elem1323) iprot.readListEnd() else: iprot.skip(ftype) @@ -36116,8 +36538,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 iter1317 in self.success: - oprot.writeString(iter1317) + for iter1324 in self.success: + oprot.writeString(iter1324) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -36805,10 +37227,10 @@ class get_role_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1321, _size1318) = iprot.readListBegin() - for _i1322 in xrange(_size1318): - _elem1323 = iprot.readString() - self.success.append(_elem1323) + (_etype1328, _size1325) = iprot.readListBegin() + for _i1329 in xrange(_size1325): + _elem1330 = iprot.readString() + self.success.append(_elem1330) iprot.readListEnd() else: iprot.skip(ftype) @@ -36831,8 +37253,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 iter1324 in self.success: - oprot.writeString(iter1324) + for iter1331 in self.success: + oprot.writeString(iter1331) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -37346,11 +37768,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1328, _size1325) = iprot.readListBegin() - for _i1329 in xrange(_size1325): - _elem1330 = Role() - _elem1330.read(iprot) - self.success.append(_elem1330) + (_etype1335, _size1332) = iprot.readListBegin() + for _i1336 in xrange(_size1332): + _elem1337 = Role() + _elem1337.read(iprot) + self.success.append(_elem1337) iprot.readListEnd() else: iprot.skip(ftype) @@ -37373,8 +37795,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 iter1331 in self.success: - iter1331.write(oprot) + for iter1338 in self.success: + iter1338.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -37883,10 +38305,10 @@ class get_privilege_set_args: elif fid == 3: if ftype == TType.LIST: self.group_names = [] - (_etype1335, _size1332) = iprot.readListBegin() - for _i1336 in xrange(_size1332): - _elem1337 = iprot.readString() - self.group_names.append(_elem1337) + (_etype1342, _size1339) = iprot.readListBegin() + for _i1343 in xrange(_size1339): + _elem1344 = iprot.readString() + self.group_names.append(_elem1344) iprot.readListEnd() else: iprot.skip(ftype) @@ -37911,8 +38333,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 iter1338 in self.group_names: - oprot.writeString(iter1338) + for iter1345 in self.group_names: + oprot.writeString(iter1345) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -38139,11 +38561,11 @@ class list_privileges_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1342, _size1339) = iprot.readListBegin() - for _i1343 in xrange(_size1339): - _elem1344 = HiveObjectPrivilege() - _elem1344.read(iprot) - self.success.append(_elem1344) + (_etype1349, _size1346) = iprot.readListBegin() + for _i1350 in xrange(_size1346): + _elem1351 = HiveObjectPrivilege() + _elem1351.read(iprot) + self.success.append(_elem1351) iprot.readListEnd() else: iprot.skip(ftype) @@ -38166,8 +38588,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 iter1345 in self.success: - iter1345.write(oprot) + for iter1352 in self.success: + iter1352.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -38837,10 +39259,10 @@ class set_ugi_args: elif fid == 2: if ftype == TType.LIST: self.group_names = [] - (_etype1349, _size1346) = iprot.readListBegin() - for _i1350 in xrange(_size1346): - _elem1351 = iprot.readString() - self.group_names.append(_elem1351) + (_etype1356, _size1353) = iprot.readListBegin() + for _i1357 in xrange(_size1353): + _elem1358 = iprot.readString() + self.group_names.append(_elem1358) iprot.readListEnd() else: iprot.skip(ftype) @@ -38861,8 +39283,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 iter1352 in self.group_names: - oprot.writeString(iter1352) + for iter1359 in self.group_names: + oprot.writeString(iter1359) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -38917,10 +39339,10 @@ class set_ugi_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1356, _size1353) = iprot.readListBegin() - for _i1357 in xrange(_size1353): - _elem1358 = iprot.readString() - self.success.append(_elem1358) + (_etype1363, _size1360) = iprot.readListBegin() + for _i1364 in xrange(_size1360): + _elem1365 = iprot.readString() + self.success.append(_elem1365) iprot.readListEnd() else: iprot.skip(ftype) @@ -38943,8 +39365,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 iter1359 in self.success: - oprot.writeString(iter1359) + for iter1366 in self.success: + oprot.writeString(iter1366) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -39876,10 +40298,10 @@ class get_all_token_identifiers_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1363, _size1360) = iprot.readListBegin() - for _i1364 in xrange(_size1360): - _elem1365 = iprot.readString() - self.success.append(_elem1365) + (_etype1370, _size1367) = iprot.readListBegin() + for _i1371 in xrange(_size1367): + _elem1372 = iprot.readString() + self.success.append(_elem1372) iprot.readListEnd() else: iprot.skip(ftype) @@ -39896,8 +40318,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 iter1366 in self.success: - oprot.writeString(iter1366) + for iter1373 in self.success: + oprot.writeString(iter1373) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -40424,10 +40846,10 @@ class get_master_keys_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1370, _size1367) = iprot.readListBegin() - for _i1371 in xrange(_size1367): - _elem1372 = iprot.readString() - self.success.append(_elem1372) + (_etype1377, _size1374) = iprot.readListBegin() + for _i1378 in xrange(_size1374): + _elem1379 = iprot.readString() + self.success.append(_elem1379) iprot.readListEnd() else: iprot.skip(ftype) @@ -40444,8 +40866,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 iter1373 in self.success: - oprot.writeString(iter1373) + for iter1380 in self.success: + oprot.writeString(iter1380) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -40890,19 +41312,1350 @@ class abort_txn_args: def __ne__(self, other): return not (self == other) -class abort_txn_result: +class abort_txn_result: + """ + Attributes: + - o1 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'o1', (NoSuchTxnException, NoSuchTxnException.thrift_spec), None, ), # 1 + ) + + def __init__(self, o1=None,): + self.o1 = o1 + + 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, ft
<TRUNCATED>
