http://git-wip-us.apache.org/repos/asf/hive/blob/7c22d74c/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 392e8ca..516be77 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 @@ -757,61 +757,6 @@ class Iface(fb303.FacebookService.Iface): """ pass - def add_index(self, new_index, index_table): - """ - Parameters: - - new_index - - index_table - """ - pass - - def alter_index(self, dbname, base_tbl_name, idx_name, new_idx): - """ - Parameters: - - dbname - - base_tbl_name - - idx_name - - new_idx - """ - pass - - def drop_index_by_name(self, db_name, tbl_name, index_name, deleteData): - """ - Parameters: - - db_name - - tbl_name - - index_name - - deleteData - """ - pass - - def get_index_by_name(self, db_name, tbl_name, index_name): - """ - Parameters: - - db_name - - tbl_name - - index_name - """ - pass - - def get_indexes(self, db_name, tbl_name, max_indexes): - """ - Parameters: - - db_name - - tbl_name - - max_indexes - """ - pass - - def get_index_names(self, db_name, tbl_name, max_indexes): - """ - Parameters: - - db_name - - tbl_name - - max_indexes - """ - pass - def get_primary_keys(self, request): """ Parameters: @@ -4740,240 +4685,6 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o6 raise TApplicationException(TApplicationException.MISSING_RESULT, "isPartitionMarkedForEvent failed: unknown result") - def add_index(self, new_index, index_table): - """ - Parameters: - - new_index - - index_table - """ - self.send_add_index(new_index, index_table) - return self.recv_add_index() - - def send_add_index(self, new_index, index_table): - self._oprot.writeMessageBegin('add_index', TMessageType.CALL, self._seqid) - args = add_index_args() - args.new_index = new_index - args.index_table = index_table - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_add_index(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = add_index_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, "add_index failed: unknown result") - - def alter_index(self, dbname, base_tbl_name, idx_name, new_idx): - """ - Parameters: - - dbname - - base_tbl_name - - idx_name - - new_idx - """ - self.send_alter_index(dbname, base_tbl_name, idx_name, new_idx) - self.recv_alter_index() - - def send_alter_index(self, dbname, base_tbl_name, idx_name, new_idx): - self._oprot.writeMessageBegin('alter_index', TMessageType.CALL, self._seqid) - args = alter_index_args() - args.dbname = dbname - args.base_tbl_name = base_tbl_name - args.idx_name = idx_name - args.new_idx = new_idx - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_alter_index(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = alter_index_result() - result.read(iprot) - iprot.readMessageEnd() - if result.o1 is not None: - raise result.o1 - if result.o2 is not None: - raise result.o2 - return - - def drop_index_by_name(self, db_name, tbl_name, index_name, deleteData): - """ - Parameters: - - db_name - - tbl_name - - index_name - - deleteData - """ - self.send_drop_index_by_name(db_name, tbl_name, index_name, deleteData) - return self.recv_drop_index_by_name() - - def send_drop_index_by_name(self, db_name, tbl_name, index_name, deleteData): - self._oprot.writeMessageBegin('drop_index_by_name', TMessageType.CALL, self._seqid) - args = drop_index_by_name_args() - args.db_name = db_name - args.tbl_name = tbl_name - args.index_name = index_name - args.deleteData = deleteData - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_drop_index_by_name(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = drop_index_by_name_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, "drop_index_by_name failed: unknown result") - - def get_index_by_name(self, db_name, tbl_name, index_name): - """ - Parameters: - - db_name - - tbl_name - - index_name - """ - self.send_get_index_by_name(db_name, tbl_name, index_name) - return self.recv_get_index_by_name() - - def send_get_index_by_name(self, db_name, tbl_name, index_name): - self._oprot.writeMessageBegin('get_index_by_name', TMessageType.CALL, self._seqid) - args = get_index_by_name_args() - args.db_name = db_name - args.tbl_name = tbl_name - args.index_name = index_name - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_index_by_name(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = get_index_by_name_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_index_by_name failed: unknown result") - - def get_indexes(self, db_name, tbl_name, max_indexes): - """ - Parameters: - - db_name - - tbl_name - - max_indexes - """ - self.send_get_indexes(db_name, tbl_name, max_indexes) - return self.recv_get_indexes() - - def send_get_indexes(self, db_name, tbl_name, max_indexes): - self._oprot.writeMessageBegin('get_indexes', TMessageType.CALL, self._seqid) - args = get_indexes_args() - args.db_name = db_name - args.tbl_name = tbl_name - args.max_indexes = max_indexes - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_indexes(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = get_indexes_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_indexes failed: unknown result") - - def get_index_names(self, db_name, tbl_name, max_indexes): - """ - Parameters: - - db_name - - tbl_name - - max_indexes - """ - self.send_get_index_names(db_name, tbl_name, max_indexes) - return self.recv_get_index_names() - - def send_get_index_names(self, db_name, tbl_name, max_indexes): - self._oprot.writeMessageBegin('get_index_names', TMessageType.CALL, self._seqid) - args = get_index_names_args() - args.db_name = db_name - args.tbl_name = tbl_name - args.max_indexes = max_indexes - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_get_index_names(self): - iprot = self._iprot - (fname, mtype, rseqid) = iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(iprot) - iprot.readMessageEnd() - raise x - result = get_index_names_result() - result.read(iprot) - iprot.readMessageEnd() - if result.success is not None: - return result.success - if result.o2 is not None: - raise result.o2 - raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result") - def get_primary_keys(self, request): """ Parameters: @@ -8267,12 +7978,6 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): self._processMap["partition_name_to_spec"] = Processor.process_partition_name_to_spec self._processMap["markPartitionForEvent"] = Processor.process_markPartitionForEvent self._processMap["isPartitionMarkedForEvent"] = Processor.process_isPartitionMarkedForEvent - self._processMap["add_index"] = Processor.process_add_index - self._processMap["alter_index"] = Processor.process_alter_index - self._processMap["drop_index_by_name"] = Processor.process_drop_index_by_name - self._processMap["get_index_by_name"] = Processor.process_get_index_by_name - self._processMap["get_indexes"] = Processor.process_get_indexes - self._processMap["get_index_names"] = Processor.process_get_index_names self._processMap["get_primary_keys"] = Processor.process_get_primary_keys self._processMap["get_foreign_keys"] = Processor.process_get_foreign_keys self._processMap["get_unique_constraints"] = Processor.process_get_unique_constraints @@ -10596,156 +10301,6 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_add_index(self, seqid, iprot, oprot): - args = add_index_args() - args.read(iprot) - iprot.readMessageEnd() - result = add_index_result() - try: - result.success = self._handler.add_index(args.new_index, args.index_table) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except InvalidObjectException as o1: - msg_type = TMessageType.REPLY - result.o1 = o1 - except AlreadyExistsException 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("add_index", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_alter_index(self, seqid, iprot, oprot): - args = alter_index_args() - args.read(iprot) - iprot.readMessageEnd() - result = alter_index_result() - try: - self._handler.alter_index(args.dbname, args.base_tbl_name, args.idx_name, args.new_idx) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except InvalidOperationException 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("alter_index", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_drop_index_by_name(self, seqid, iprot, oprot): - args = drop_index_by_name_args() - args.read(iprot) - iprot.readMessageEnd() - result = drop_index_by_name_result() - try: - result.success = self._handler.drop_index_by_name(args.db_name, args.tbl_name, args.index_name, args.deleteData) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except NoSuchObjectException 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("drop_index_by_name", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get_index_by_name(self, seqid, iprot, oprot): - args = get_index_by_name_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_index_by_name_result() - try: - result.success = self._handler.get_index_by_name(args.db_name, args.tbl_name, args.index_name) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except MetaException as o1: - msg_type = TMessageType.REPLY - result.o1 = o1 - except NoSuchObjectException 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_index_by_name", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get_indexes(self, seqid, iprot, oprot): - args = get_indexes_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_indexes_result() - try: - result.success = self._handler.get_indexes(args.db_name, args.tbl_name, args.max_indexes) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - except NoSuchObjectException 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_indexes", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_get_index_names(self, seqid, iprot, oprot): - args = get_index_names_args() - args.read(iprot) - iprot.readMessageEnd() - result = get_index_names_result() - try: - result.success = self._handler.get_index_names(args.db_name, args.tbl_name, args.max_indexes) - msg_type = TMessageType.REPLY - except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): - raise - 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_index_names", msg_type, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - def process_get_primary_keys(self, seqid, iprot, oprot): args = get_primary_keys_args() args.read(iprot) @@ -13865,10 +13420,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype772, _size769) = iprot.readListBegin() - for _i773 in xrange(_size769): - _elem774 = iprot.readString() - self.success.append(_elem774) + (_etype763, _size760) = iprot.readListBegin() + for _i764 in xrange(_size760): + _elem765 = iprot.readString() + self.success.append(_elem765) iprot.readListEnd() else: iprot.skip(ftype) @@ -13891,8 +13446,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 iter775 in self.success: - oprot.writeString(iter775) + for iter766 in self.success: + oprot.writeString(iter766) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13997,10 +13552,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype779, _size776) = iprot.readListBegin() - for _i780 in xrange(_size776): - _elem781 = iprot.readString() - self.success.append(_elem781) + (_etype770, _size767) = iprot.readListBegin() + for _i771 in xrange(_size767): + _elem772 = iprot.readString() + self.success.append(_elem772) iprot.readListEnd() else: iprot.skip(ftype) @@ -14023,8 +13578,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 iter782 in self.success: - oprot.writeString(iter782) + for iter773 in self.success: + oprot.writeString(iter773) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14794,12 +14349,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype784, _vtype785, _size783 ) = iprot.readMapBegin() - for _i787 in xrange(_size783): - _key788 = iprot.readString() - _val789 = Type() - _val789.read(iprot) - self.success[_key788] = _val789 + (_ktype775, _vtype776, _size774 ) = iprot.readMapBegin() + for _i778 in xrange(_size774): + _key779 = iprot.readString() + _val780 = Type() + _val780.read(iprot) + self.success[_key779] = _val780 iprot.readMapEnd() else: iprot.skip(ftype) @@ -14822,9 +14377,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 kiter790,viter791 in self.success.items(): - oprot.writeString(kiter790) - viter791.write(oprot) + for kiter781,viter782 in self.success.items(): + oprot.writeString(kiter781) + viter782.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -14967,11 +14522,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype795, _size792) = iprot.readListBegin() - for _i796 in xrange(_size792): - _elem797 = FieldSchema() - _elem797.read(iprot) - self.success.append(_elem797) + (_etype786, _size783) = iprot.readListBegin() + for _i787 in xrange(_size783): + _elem788 = FieldSchema() + _elem788.read(iprot) + self.success.append(_elem788) iprot.readListEnd() else: iprot.skip(ftype) @@ -15006,8 +14561,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 iter798 in self.success: - iter798.write(oprot) + for iter789 in self.success: + iter789.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15174,11 +14729,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype802, _size799) = iprot.readListBegin() - for _i803 in xrange(_size799): - _elem804 = FieldSchema() - _elem804.read(iprot) - self.success.append(_elem804) + (_etype793, _size790) = iprot.readListBegin() + for _i794 in xrange(_size790): + _elem795 = FieldSchema() + _elem795.read(iprot) + self.success.append(_elem795) iprot.readListEnd() else: iprot.skip(ftype) @@ -15213,8 +14768,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 iter805 in self.success: - iter805.write(oprot) + for iter796 in self.success: + iter796.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15367,11 +14922,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype809, _size806) = iprot.readListBegin() - for _i810 in xrange(_size806): - _elem811 = FieldSchema() - _elem811.read(iprot) - self.success.append(_elem811) + (_etype800, _size797) = iprot.readListBegin() + for _i801 in xrange(_size797): + _elem802 = FieldSchema() + _elem802.read(iprot) + self.success.append(_elem802) iprot.readListEnd() else: iprot.skip(ftype) @@ -15406,8 +14961,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 iter812 in self.success: - iter812.write(oprot) + for iter803 in self.success: + iter803.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15574,11 +15129,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype816, _size813) = iprot.readListBegin() - for _i817 in xrange(_size813): - _elem818 = FieldSchema() - _elem818.read(iprot) - self.success.append(_elem818) + (_etype807, _size804) = iprot.readListBegin() + for _i808 in xrange(_size804): + _elem809 = FieldSchema() + _elem809.read(iprot) + self.success.append(_elem809) iprot.readListEnd() else: iprot.skip(ftype) @@ -15613,8 +15168,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 iter819 in self.success: - iter819.write(oprot) + for iter810 in self.success: + iter810.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16064,55 +15619,55 @@ class create_table_with_constraints_args: elif fid == 2: if ftype == TType.LIST: self.primaryKeys = [] - (_etype823, _size820) = iprot.readListBegin() - for _i824 in xrange(_size820): - _elem825 = SQLPrimaryKey() - _elem825.read(iprot) - self.primaryKeys.append(_elem825) + (_etype814, _size811) = iprot.readListBegin() + for _i815 in xrange(_size811): + _elem816 = SQLPrimaryKey() + _elem816.read(iprot) + self.primaryKeys.append(_elem816) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.foreignKeys = [] - (_etype829, _size826) = iprot.readListBegin() - for _i830 in xrange(_size826): - _elem831 = SQLForeignKey() - _elem831.read(iprot) - self.foreignKeys.append(_elem831) + (_etype820, _size817) = iprot.readListBegin() + for _i821 in xrange(_size817): + _elem822 = SQLForeignKey() + _elem822.read(iprot) + self.foreignKeys.append(_elem822) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.uniqueConstraints = [] - (_etype835, _size832) = iprot.readListBegin() - for _i836 in xrange(_size832): - _elem837 = SQLUniqueConstraint() - _elem837.read(iprot) - self.uniqueConstraints.append(_elem837) + (_etype826, _size823) = iprot.readListBegin() + for _i827 in xrange(_size823): + _elem828 = SQLUniqueConstraint() + _elem828.read(iprot) + self.uniqueConstraints.append(_elem828) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.LIST: self.notNullConstraints = [] - (_etype841, _size838) = iprot.readListBegin() - for _i842 in xrange(_size838): - _elem843 = SQLNotNullConstraint() - _elem843.read(iprot) - self.notNullConstraints.append(_elem843) + (_etype832, _size829) = iprot.readListBegin() + for _i833 in xrange(_size829): + _elem834 = SQLNotNullConstraint() + _elem834.read(iprot) + self.notNullConstraints.append(_elem834) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.LIST: self.defaultConstraints = [] - (_etype847, _size844) = iprot.readListBegin() - for _i848 in xrange(_size844): - _elem849 = SQLDefaultConstraint() - _elem849.read(iprot) - self.defaultConstraints.append(_elem849) + (_etype838, _size835) = iprot.readListBegin() + for _i839 in xrange(_size835): + _elem840 = SQLDefaultConstraint() + _elem840.read(iprot) + self.defaultConstraints.append(_elem840) iprot.readListEnd() else: iprot.skip(ftype) @@ -16133,36 +15688,36 @@ 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 iter850 in self.primaryKeys: - iter850.write(oprot) + for iter841 in self.primaryKeys: + iter841.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 iter851 in self.foreignKeys: - iter851.write(oprot) + for iter842 in self.foreignKeys: + iter842.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 iter852 in self.uniqueConstraints: - iter852.write(oprot) + for iter843 in self.uniqueConstraints: + iter843.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 iter853 in self.notNullConstraints: - iter853.write(oprot) + for iter844 in self.notNullConstraints: + iter844.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 iter854 in self.defaultConstraints: - iter854.write(oprot) + for iter845 in self.defaultConstraints: + iter845.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17575,10 +17130,10 @@ class truncate_table_args: elif fid == 3: if ftype == TType.LIST: self.partNames = [] - (_etype858, _size855) = iprot.readListBegin() - for _i859 in xrange(_size855): - _elem860 = iprot.readString() - self.partNames.append(_elem860) + (_etype849, _size846) = iprot.readListBegin() + for _i850 in xrange(_size846): + _elem851 = iprot.readString() + self.partNames.append(_elem851) iprot.readListEnd() else: iprot.skip(ftype) @@ -17603,8 +17158,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 iter861 in self.partNames: - oprot.writeString(iter861) + for iter852 in self.partNames: + oprot.writeString(iter852) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17804,10 +17359,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype865, _size862) = iprot.readListBegin() - for _i866 in xrange(_size862): - _elem867 = iprot.readString() - self.success.append(_elem867) + (_etype856, _size853) = iprot.readListBegin() + for _i857 in xrange(_size853): + _elem858 = iprot.readString() + self.success.append(_elem858) iprot.readListEnd() else: iprot.skip(ftype) @@ -17830,8 +17385,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 iter868 in self.success: - oprot.writeString(iter868) + for iter859 in self.success: + oprot.writeString(iter859) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17981,10 +17536,10 @@ class get_tables_by_type_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype872, _size869) = iprot.readListBegin() - for _i873 in xrange(_size869): - _elem874 = iprot.readString() - self.success.append(_elem874) + (_etype863, _size860) = iprot.readListBegin() + for _i864 in xrange(_size860): + _elem865 = iprot.readString() + self.success.append(_elem865) iprot.readListEnd() else: iprot.skip(ftype) @@ -18007,8 +17562,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 iter875 in self.success: - oprot.writeString(iter875) + for iter866 in self.success: + oprot.writeString(iter866) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18132,10 +17687,10 @@ class get_materialized_views_for_rewriting_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype879, _size876) = iprot.readListBegin() - for _i880 in xrange(_size876): - _elem881 = iprot.readString() - self.success.append(_elem881) + (_etype870, _size867) = iprot.readListBegin() + for _i871 in xrange(_size867): + _elem872 = iprot.readString() + self.success.append(_elem872) iprot.readListEnd() else: iprot.skip(ftype) @@ -18158,8 +17713,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 iter882 in self.success: - oprot.writeString(iter882) + for iter873 in self.success: + oprot.writeString(iter873) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18232,10 +17787,10 @@ class get_table_meta_args: elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] - (_etype886, _size883) = iprot.readListBegin() - for _i887 in xrange(_size883): - _elem888 = iprot.readString() - self.tbl_types.append(_elem888) + (_etype877, _size874) = iprot.readListBegin() + for _i878 in xrange(_size874): + _elem879 = iprot.readString() + self.tbl_types.append(_elem879) iprot.readListEnd() else: iprot.skip(ftype) @@ -18260,8 +17815,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 iter889 in self.tbl_types: - oprot.writeString(iter889) + for iter880 in self.tbl_types: + oprot.writeString(iter880) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18317,11 +17872,11 @@ class get_table_meta_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype893, _size890) = iprot.readListBegin() - for _i894 in xrange(_size890): - _elem895 = TableMeta() - _elem895.read(iprot) - self.success.append(_elem895) + (_etype884, _size881) = iprot.readListBegin() + for _i885 in xrange(_size881): + _elem886 = TableMeta() + _elem886.read(iprot) + self.success.append(_elem886) iprot.readListEnd() else: iprot.skip(ftype) @@ -18344,8 +17899,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 iter896 in self.success: - iter896.write(oprot) + for iter887 in self.success: + iter887.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18469,10 +18024,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype900, _size897) = iprot.readListBegin() - for _i901 in xrange(_size897): - _elem902 = iprot.readString() - self.success.append(_elem902) + (_etype891, _size888) = iprot.readListBegin() + for _i892 in xrange(_size888): + _elem893 = iprot.readString() + self.success.append(_elem893) iprot.readListEnd() else: iprot.skip(ftype) @@ -18495,8 +18050,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 iter903 in self.success: - oprot.writeString(iter903) + for iter894 in self.success: + oprot.writeString(iter894) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18732,10 +18287,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype907, _size904) = iprot.readListBegin() - for _i908 in xrange(_size904): - _elem909 = iprot.readString() - self.tbl_names.append(_elem909) + (_etype898, _size895) = iprot.readListBegin() + for _i899 in xrange(_size895): + _elem900 = iprot.readString() + self.tbl_names.append(_elem900) iprot.readListEnd() else: iprot.skip(ftype) @@ -18756,8 +18311,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 iter910 in self.tbl_names: - oprot.writeString(iter910) + for iter901 in self.tbl_names: + oprot.writeString(iter901) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18809,11 +18364,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype914, _size911) = iprot.readListBegin() - for _i915 in xrange(_size911): - _elem916 = Table() - _elem916.read(iprot) - self.success.append(_elem916) + (_etype905, _size902) = iprot.readListBegin() + for _i906 in xrange(_size902): + _elem907 = Table() + _elem907.read(iprot) + self.success.append(_elem907) iprot.readListEnd() else: iprot.skip(ftype) @@ -18830,8 +18385,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 iter917 in self.success: - iter917.write(oprot) + for iter908 in self.success: + iter908.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19223,10 +18778,10 @@ class get_materialization_invalidation_info_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype921, _size918) = iprot.readListBegin() - for _i922 in xrange(_size918): - _elem923 = iprot.readString() - self.tbl_names.append(_elem923) + (_etype912, _size909) = iprot.readListBegin() + for _i913 in xrange(_size909): + _elem914 = iprot.readString() + self.tbl_names.append(_elem914) iprot.readListEnd() else: iprot.skip(ftype) @@ -19247,8 +18802,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 iter924 in self.tbl_names: - oprot.writeString(iter924) + for iter915 in self.tbl_names: + oprot.writeString(iter915) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19309,12 +18864,12 @@ class get_materialization_invalidation_info_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype926, _vtype927, _size925 ) = iprot.readMapBegin() - for _i929 in xrange(_size925): - _key930 = iprot.readString() - _val931 = Materialization() - _val931.read(iprot) - self.success[_key930] = _val931 + (_ktype917, _vtype918, _size916 ) = iprot.readMapBegin() + for _i920 in xrange(_size916): + _key921 = iprot.readString() + _val922 = Materialization() + _val922.read(iprot) + self.success[_key921] = _val922 iprot.readMapEnd() else: iprot.skip(ftype) @@ -19349,9 +18904,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 kiter932,viter933 in self.success.items(): - oprot.writeString(kiter932) - viter933.write(oprot) + for kiter923,viter924 in self.success.items(): + oprot.writeString(kiter923) + viter924.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19703,10 +19258,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype937, _size934) = iprot.readListBegin() - for _i938 in xrange(_size934): - _elem939 = iprot.readString() - self.success.append(_elem939) + (_etype928, _size925) = iprot.readListBegin() + for _i929 in xrange(_size925): + _elem930 = iprot.readString() + self.success.append(_elem930) iprot.readListEnd() else: iprot.skip(ftype) @@ -19741,8 +19296,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 iter940 in self.success: - oprot.writeString(iter940) + for iter931 in self.success: + oprot.writeString(iter931) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20712,11 +20267,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype944, _size941) = iprot.readListBegin() - for _i945 in xrange(_size941): - _elem946 = Partition() - _elem946.read(iprot) - self.new_parts.append(_elem946) + (_etype935, _size932) = iprot.readListBegin() + for _i936 in xrange(_size932): + _elem937 = Partition() + _elem937.read(iprot) + self.new_parts.append(_elem937) iprot.readListEnd() else: iprot.skip(ftype) @@ -20733,8 +20288,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 iter947 in self.new_parts: - iter947.write(oprot) + for iter938 in self.new_parts: + iter938.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20892,11 +20447,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype951, _size948) = iprot.readListBegin() - for _i952 in xrange(_size948): - _elem953 = PartitionSpec() - _elem953.read(iprot) - self.new_parts.append(_elem953) + (_etype942, _size939) = iprot.readListBegin() + for _i943 in xrange(_size939): + _elem944 = PartitionSpec() + _elem944.read(iprot) + self.new_parts.append(_elem944) iprot.readListEnd() else: iprot.skip(ftype) @@ -20913,8 +20468,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 iter954 in self.new_parts: - iter954.write(oprot) + for iter945 in self.new_parts: + iter945.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21088,10 +20643,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype958, _size955) = iprot.readListBegin() - for _i959 in xrange(_size955): - _elem960 = iprot.readString() - self.part_vals.append(_elem960) + (_etype949, _size946) = iprot.readListBegin() + for _i950 in xrange(_size946): + _elem951 = iprot.readString() + self.part_vals.append(_elem951) iprot.readListEnd() else: iprot.skip(ftype) @@ -21116,8 +20671,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 iter961 in self.part_vals: - oprot.writeString(iter961) + for iter952 in self.part_vals: + oprot.writeString(iter952) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21470,10 +21025,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype965, _size962) = iprot.readListBegin() - for _i966 in xrange(_size962): - _elem967 = iprot.readString() - self.part_vals.append(_elem967) + (_etype956, _size953) = iprot.readListBegin() + for _i957 in xrange(_size953): + _elem958 = iprot.readString() + self.part_vals.append(_elem958) iprot.readListEnd() else: iprot.skip(ftype) @@ -21504,8 +21059,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 iter968 in self.part_vals: - oprot.writeString(iter968) + for iter959 in self.part_vals: + oprot.writeString(iter959) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -22100,10 +21655,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype972, _size969) = iprot.readListBegin() - for _i973 in xrange(_size969): - _elem974 = iprot.readString() - self.part_vals.append(_elem974) + (_etype963, _size960) = iprot.readListBegin() + for _i964 in xrange(_size960): + _elem965 = iprot.readString() + self.part_vals.append(_elem965) iprot.readListEnd() else: iprot.skip(ftype) @@ -22133,8 +21688,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 iter975 in self.part_vals: - oprot.writeString(iter975) + for iter966 in self.part_vals: + oprot.writeString(iter966) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -22307,10 +21862,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype979, _size976) = iprot.readListBegin() - for _i980 in xrange(_size976): - _elem981 = iprot.readString() - self.part_vals.append(_elem981) + (_etype970, _size967) = iprot.readListBegin() + for _i971 in xrange(_size967): + _elem972 = iprot.readString() + self.part_vals.append(_elem972) iprot.readListEnd() else: iprot.skip(ftype) @@ -22346,8 +21901,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 iter982 in self.part_vals: - oprot.writeString(iter982) + for iter973 in self.part_vals: + oprot.writeString(iter973) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -23084,10 +22639,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype986, _size983) = iprot.readListBegin() - for _i987 in xrange(_size983): - _elem988 = iprot.readString() - self.part_vals.append(_elem988) + (_etype977, _size974) = iprot.readListBegin() + for _i978 in xrange(_size974): + _elem979 = iprot.readString() + self.part_vals.append(_elem979) iprot.readListEnd() else: iprot.skip(ftype) @@ -23112,8 +22667,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 iter989 in self.part_vals: - oprot.writeString(iter989) + for iter980 in self.part_vals: + oprot.writeString(iter980) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23272,6 +22827,254 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} + (_ktype982, _vtype983, _size981 ) = iprot.readMapBegin() + for _i985 in xrange(_size981): + _key986 = iprot.readString() + _val987 = iprot.readString() + self.partitionSpecs[_key986] = _val987 + iprot.readMapEnd() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.source_db = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.source_table_name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.dest_db = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.STRING: + self.dest_table_name = iprot.readString() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('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 kiter988,viter989 in self.partitionSpecs.items(): + oprot.writeString(kiter988) + oprot.writeString(viter989) + oprot.writeMapEnd() + oprot.writeFieldEnd() + if self.source_db is not None: + oprot.writeFieldBegin('source_db', TType.STRING, 2) + oprot.writeString(self.source_db) + oprot.writeFieldEnd() + if self.source_table_name is not None: + oprot.writeFieldBegin('source_table_name', TType.STRING, 3) + oprot.writeString(self.source_table_name) + oprot.writeFieldEnd() + if self.dest_db is not None: + oprot.writeFieldBegin('dest_db', TType.STRING, 4) + oprot.writeString(self.dest_db) + oprot.writeFieldEnd() + if self.dest_table_name is not None: + oprot.writeFieldBegin('dest_table_name', TType.STRING, 5) + oprot.writeString(self.dest_table_name) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.partitionSpecs) + value = (value * 31) ^ hash(self.source_db) + value = (value * 31) ^ hash(self.source_table_name) + value = (value * 31) ^ hash(self.dest_db) + value = (value * 31) ^ hash(self.dest_table_name) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class exchange_partition_result: + """ + Attributes: + - success + - o1 + - o2 + - o3 + - o4 + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'o3', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'o4', (InvalidInputException, InvalidInputException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, o1=None, o2=None, o3=None, o4=None,): + self.success = success + self.o1 = o1 + self.o2 = o2 + self.o3 = o3 + self.o4 = o4 + + 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 = Partition() + self.success.read(iprot) + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = MetaException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = NoSuchObjectException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.o3 = InvalidObjectException() + self.o3.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.o4 = InvalidInputException() + self.o4.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('exchange_partition_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() + if self.o3 is not None: + oprot.writeFieldBegin('o3', TType.STRUCT, 3) + self.o3.write(oprot) + oprot.writeFieldEnd() + if self.o4 is not None: + oprot.writeFieldBegin('o4', TType.STRUCT, 4) + self.o4.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.success) + value = (value * 31) ^ hash(self.o1) + value = (value * 31) ^ hash(self.o2) + value = (value * 31) ^ hash(self.o3) + value = (value * 31) ^ hash(self.o4) + 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 exchange_partitions_args: + """ + Attributes: + - partitionSpecs + - source_db + - source_table_name + - dest_db + - dest_table_name + """ + + thrift_spec = ( + None, # 0 + (1, TType.MAP, 'partitionSpecs', (TType.STRING,None,TType.STRING,None), None, ), # 1 + (2, TType.STRING, 'source_db', None, None, ), # 2 + (3, TType.STRING, 'source_table_name', None, None, ), # 3 + (4, TType.STRING, 'dest_db', None, None, ), # 4 + (5, TType.STRING, 'dest_table_name', None, None, ), # 5 + ) + + def __init__(self, partitionSpecs=None, source_db=None, source_table_name=None, dest_db=None, dest_table_name=None,): + self.partitionSpecs = partitionSpecs + self.source_db = source_db + self.source_table_name = source_table_name + self.dest_db = dest_db + self.dest_table_name = dest_table_name + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.MAP: + self.partitionSpecs = {} (_ktype991, _vtype992, _size990 ) = iprot.readMapBegin() for _i994 in xrange(_size990): _key995 = iprot.readString() @@ -23309,7 +23112,7 @@ class exchange_partition_args: 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('exchange_partition_args') + oprot.writeStructBegin('exchange_partitions_args') if self.partitionSpecs is not None: oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs)) @@ -23361,7 +23164,7 @@ class exchange_partition_args: def __ne__(self, other): return not (self == other) -class exchange_partition_result: +class exchange_partitions_result: """ Attributes: - success @@ -23372,7 +23175,7 @@ class exchange_partition_result: """ thrift_spec = ( - (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 0 (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2 (3, TType.STRUCT, 'o3', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 3 @@ -23396,9 +23199,14 @@ class exchange_partition_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.STRUCT: - self.success = Partition() - self.success.read(iprot) + if ftype == TType.LIST: + self.success = [] + (_etype1002, _size999) = iprot.readListBegin() + for _i1003 in xrange(_size999): + _elem1004 = Partition() + _elem1004.read(iprot) + self.success.append(_elem1004) + iprot.readListEnd() else: iprot.skip(ftype) elif fid == 1: @@ -23434,10 +23242,13 @@ class exchange_partition_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('exchange_partition_result') + oprot.writeStructBegin('exchange_partitions_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter1005 in self.success: + iter1005.write(oprot) + oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) @@ -23482,31 +23293,31 @@ class exchange_partition_result: def __ne__(self, other): return not (self == other) -class exchange_partitions_args: +class get_partition_with_auth_args: """ Attributes: - - partitionSpecs - - source_db - - source_table_name - - dest_db - - dest_table_name + - db_name + - tbl_name + - part_vals + - user_name + - group_names """ thrift_spec = ( None, # 0 - (1, TType.MAP, 'partitionSpecs', (TType.STRING,None,TType.STRING,None), None, ), # 1 - (2, TType.STRING, 'source_db', None, None, ), # 2 - (3, TType.STRING, 'source_table_name', None, None, ), # 3 - (4, TType.STRING, 'dest_db', None, None, ), # 4 - (5, TType.STRING, 'dest_table_name', None, None, ), # 5 + (1, TType.STRING, 'db_name', None, None, ), # 1 + (2, TType.STRING, 'tbl_name', None, None, ), # 2 + (3, TType.LIST, 'part_vals', (TType.STRING,None), None, ), # 3 + (4, TType.STRING, 'user_name', None, None, ), # 4 + (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5 ) - def __init__(self, partitionSpecs=None, source_db=None, source_table_name=None, dest_db=None, dest_table_name=None,): - self.partitionSpecs = partitionSpecs - self.source_db = source_db - self.source_table_name = source_table_name - self.dest_db = dest_db - self.dest_table_name = dest_table_name + def __init__(self, db_name=None, tbl_name=None, part_vals=None, user_name=None, group_names=None,): + self.db_name = db_name + self.tbl_name = tbl_name + self.part_vals = part_vals + self.user_name = user_name + self.group_names = group_names 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: @@ -23518,34 +23329,38 @@ class exchange_partitions_args: if ftype == TType.STOP: break if fid == 1: - if ftype == TType.MAP: - self.partitionSpecs = {} - (_ktype1000, _vtype1001, _size999 ) = iprot.readMapBegin() - for _i1003 in xrange(_size999): - _key1004 = iprot.readString() - _val1005 = iprot.readString() - self.partitionSpecs[_key1004] = _val1005 - iprot.readMapEnd() + if ftype == TType.STRING: + self.db_name = iprot.readString() else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: - self.source_db = iprot.readString() + self.tbl_name = iprot.readString() else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.STRING: - self.source_table_name = iprot.readString() + if ftype == TType.LIST: + self.part_vals = [] + (_etype1009, _size1006) = iprot.readListBegin() + for _i1010 in xrange(_size1006): + _elem1011 = iprot.readString() + self.part_vals.append(_elem1011) + iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.STRING: - self.dest_db = iprot.readString() + self.user_name = iprot.readString() else: iprot.skip(ftype) elif fid == 5: - if ftype == TType.STRING: - self.dest_table_name = iprot.readString() + if ftype == TType.LIST: + self.group_names = [] + (_etype1015, _size1012) = iprot.readListBegin() + for _i1016 in xrange(_size1012): + _elem1017 = iprot.readString() + self.group_names.append(_elem1017) + iprot.readListEnd() else: iprot.skip(ftype) else: @@ -23557,30 +23372,32 @@ class exchange_partitions_args: 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('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 kiter1006,viter1007 in self.partitionSpecs.items(): - oprot.writeString(kiter1006) - oprot.writeString(viter1007) - oprot.writeMapEnd() + oprot.writeStructBegin('get_partition_with_auth_args') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) oprot.writeFieldEnd() - if self.source_db is not None: - oprot.writeFieldBegin('source_db', TType.STRING, 2) - oprot.writeString(self.source_db) + if self.tbl_name is not None: + oprot.writeFieldBegin('tbl_name', TType.STRING, 2) + oprot.writeString(self.tbl_name) oprot.writeFieldEnd() - if self.source_table_name is not None: - oprot.writeFieldBegin('source_table_name', TType.STRING, 3) - oprot.writeString(self.source_table_name) + if self.part_vals is not None: + oprot.writeFieldBegin('part_vals', TType.LIST, 3) + oprot.writeListBegin(TType.STRING, len(self.part_vals)) + for iter1018 in self.part_vals: + oprot.writeString(iter1018) + oprot.writeListEnd() oprot.writeFieldEnd() - if self.dest_db is not None: - oprot.writeFieldBegin('dest_db', TType.STRING, 4) - oprot.writeString(self.dest_db) + if self.user_name is not None: + oprot.writeFieldBegin('user_name', TType.STRING, 4) + oprot.writeString(self.user_name) oprot.writeFieldEnd() - if self.dest_table_name is not None: - oprot.writeFieldBegin('dest_table_name', TType.STRING, 5) - oprot.writeString(self.dest_table_name) + if self.group_names is not None: + oprot.writeFieldBegin('group_names', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.group_names)) + for iter1019 in self.group_names: + oprot.writeString(iter1019) + oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -23591,11 +23408,11 @@ class exchange_partitions_args: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.partitionSpecs) - value = (value * 31) ^ hash(self.source_db) - value = (value * 31) ^ hash(self.source_table_name) - value = (value * 31) ^ hash(self.dest_db) - value = (value * 31) ^ hash(self.dest_table_name) + value = (value * 31) ^ hash(self.db_name) + value = (value * 31) ^ hash(self.tbl_name) + value = (value * 31) ^ hash(self.part_vals) + value = (value * 31) ^ hash(self.user_name) + value = (value * 31) ^ hash(self.group_names) return value def __repr__(self): @@ -23609,30 +23426,24 @@ class exchange_partitions_args: def __ne__(self, other): return not (self == other) -class exchange_partitions_result: +class get_partition_with_auth_result: """ Attributes: - success - o1 - o2 - - o3 - - o4 """ thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 0 + (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0 (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2 - (3, TType.STRUCT, 'o3', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 3 - (4, TType.STRUCT, 'o4', (InvalidInputException, InvalidInputException.thrift_spec), None, ), # 4 ) - def __init__(self, success=None, o1=None, o2=None, o3=None, o4=None,): + def __init__(self, success=None, o1=None, o2=None,): self.success = success self.o1 = o1 self.o2 = o2 - self.o3 = o3 - self.o4 = o4 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: @@ -23644,14 +23455,9 @@ class exchange_partitions_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.LIST: - self.success = [] - (_etype1011, _size1008) = iprot.readListBegin() - for _i1012 in xrange(_size1008): - _elem1013 = Partition() - _elem1013.read(iprot) - self.success.append(_elem1013) - iprot.readListEnd() + if ftype == TType.STRUCT: + self.success = Partition() + self.success.read(iprot) else: iprot.skip(ftype) elif fid == 1: @@ -23666,18 +23472,6 @@ class exchange_partitions_result: self.o2.read(iprot) else: iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.o3 = InvalidObjectException() - self.o3.read(iprot) - else: - iprot.skip(ftype) - elif fid == 4: - if ftype == TType.STRUCT: - self.o4 = InvalidInputException() - self.o4.read(iprot) - else: - iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -23687,13 +23481,10 @@ class exchange_partitions_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('exchange_partitions_result') + oprot.writeStructBegin('get_partition_with_auth_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.LIST, 0) - oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter1014 in self.success: - iter1014.write(oprot) - oprot.writeListEnd() + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) oprot.writeFieldEnd() if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) @@ -23703,14 +23494,6 @@ class exchange_partitions_result: oprot.writeFieldBegin('o2', TType.STRUCT, 2) self.o2.write(oprot) oprot.writeFieldEnd() - if self.o3 is not None: - oprot.writeFieldBegin('o3', TType.STRUCT, 3) - self.o3.write(oprot) - oprot.writeFieldEnd() - if self.o4 is not None: - oprot.writeFieldBegin('o4', TType.STRUCT, 4) - self.o4.write(oprot) - oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -23723,8 +23506,6 @@ class exchange_partitions_result: value = (value * 31) ^ hash(self.success) value = (value * 31) ^ hash(self.o1) value = (value * 31) ^ hash(self.o2) - value = (value * 31) ^ hash(self.o3) - value = (value * 31) ^ hash(self.o4) return value def __repr__(self): @@ -23738,31 +23519,25 @@ class exchange_partitions_result: def __ne__(self, other): return not (self == other) -class get_partition_with_auth_args: +class get_partition_by_name_args: """ Attributes: - db_name - tbl_name - - part_vals - - user_name - - group_names + - part_name """ thrift_spec = ( None, # 0 (1, TType.STRING, 'db_name', None, None, ), # 1 (2, TType.STRING, 'tbl_name', None, None, ), # 2 - (3, TType.LIST, 'part_vals', (TType.STRING,None), None, ), # 3 - (4, TType.STRING, 'user_name', None, None, ), # 4 - (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5 + (3, TType.STRING, 'part_name', None, None, ), # 3 ) - def __init__(self, db_name=None, tbl_name=None, part_vals=None, user_name=None, group_names=None,): + def __init__(self, db_name=None, tbl_name=None, part_name=None,): self.db_name = db_name self.tbl_name = tbl_name - self.part_vals = part_vals - self.user_name = user_name - self.group_names = group_names + self.part_name = part_name def read(self, iprot): if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: @@ -23784,28 +23559,8 @@ class get_partition_with_auth_args: else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.LIST: - self.part_vals = [] - (_etype1018, _size1015) = iprot.readListBegin() - for _i1019 in xrange(_size1015): - _elem1020 = iprot.readString() - self.part_vals.append(_elem1020) - iprot.readListEnd() - else: - iprot.skip(ftype) - elif fid == 4: if ftype == TType.STRING: - self.user_name = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 5: - if ftype == TType.LIST: - self.group_names = [] - (_etype1024, _size1021) = iprot.readListBegin() - for _i1025 in xrange(_size1021): - _elem1026 = iprot.readString() - self.group_names.append(_elem1026) - iprot.readListEnd() + self.part_name = iprot.readString() else: iprot.skip(ftype) else: @@ -23817,7 +23572,7 @@ class get_partition_with_auth_args: 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_partition_with_auth_args') + oprot.writeStructBegin('get_partition_by_name_args') if self.db_name is not None: oprot.writeFieldBegin('db_name', TType.STRING, 1) oprot.writeString(self.db_name) @@ -23826,23 +23581,9 @@ class get_partition_with_auth_args: oprot.writeFieldBegin('tbl_name', TType.STRING, 2) oprot.writeString(self.tbl_name) oprot.writeFieldEnd() - if self.part_vals is not None: - oprot.writeFieldBegin('part_vals', TType.LIST, 3) - oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter1027 in self.part_vals: - oprot.writeString(iter1027) - oprot.writeListEnd() - oprot.writeFieldEnd() - if self.user_name is not None: - oprot.writeFieldBegin('user_name', TType.STRING, 4) - oprot.writeString(self.user_name) - oprot.writeFieldEnd() - if self.group_names is not None: - oprot.writeFieldBegin('group_names', TType.LIST, 5) - oprot.writeListBegin(TType.STRING, len(self.group_names)) - for iter1028 in self.group_names: - oprot.writeString(iter1028) - oprot.writeListEnd() + if self.part_name is not None: + oprot.writeFieldBegin('part_name', TType.STRING, 3) + oprot.writeString(self.part_name) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -23855,9 +23596,7 @@ class get_partition_with_auth_args: value = 17 value = (value * 31) ^ hash(self.db_name) value = (value * 31) ^ hash(self.tbl_name) - value = (value * 31) ^ hash(self.part_vals) - value = (value * 31) ^ hash(self.user_name) - value = (value * 31) ^ hash(self.group_names) + value = (value * 31) ^ hash(self.part_name) return value def __repr__(self): @@ -23871,7 +23610,7 @@ class get_partition_with_auth_args: def __ne__(self, other): return not (self == other) -class get_partition_with_auth_result: +class get_partition_by_name_result: """ Attributes: - success @@ -23926,7 +23665,7 @@ class get_partition_with_auth_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_partition_with_auth_result') + oprot.writeStructBegin('get_partition_by_name_result') if self.success is not None: oprot.writeFieldBegin('success', TType.STRUCT, 0) self.success.write(oprot) @@ -23964,25 +23703,25 @@ class get_partition_with_auth_result: def __ne__(self, other): return not (self == other) -class get_partition_by_name_args: +class get_partitions_args: """ Attributes: - db_name - tbl_name - - part_name + - max_parts """ thrift_spec = ( None, # 0 (1, TType.STRING, 'db_name', None, None, ), # 1 (2, TType.STRING, 'tbl_name', None, None, ), # 2 - (3, TType.STRING, 'part_name', None, None, ), # 3 + (3, TType.I16, 'max_parts', None, -1, ), # 3 ) - def __init__(self, db_name=None, tbl_name=None, part_name=None,): + def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],): self.db_name = db_name self.tbl_name = tbl_name - self.part_name = part_name + self.max_parts = max_parts 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: @@ -24004,8 +23743,8 @@ class get_partition_by_name_args: else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.STRING: - self.part_name = iprot.readString() + if ftype == TType.I16: + self.max_parts = iprot.readI16() else: iprot.skip(ftype) else: @@ -24017,7 +23756,7 @@ class get_partition_by_name_args: 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_partition_by_name_args') + oprot.writeStructBegin('get_partitions_args') if self.db_name is not None: oprot.writeFieldBegin('db_name', TType.STRING, 1) oprot.writeString(self.db_name) @@ -24026,9 +23765,9 @@ class get_partition_by_name_args: oprot.writeFieldBegin('tbl_name', TType.STRING, 2) oprot.writeString(self.tbl_name) oprot.writeFieldEnd() - if self.part_name is not None: - oprot.writeFieldBegin('part_name', TType.STRING, 3) - oprot.writeString(self.part_name) + if self.max_parts is not None: + oprot.writeFieldBegin('max_parts', TType.I16, 3) + oprot.writeI16(self.max_parts) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -24041,7 +23780,7 @@ class get_partition_by_name_args: value = 17 value = (value * 31) ^ hash(self.db_name) value = (value * 31) ^ hash(self.tbl_name) - value = (value * 31) ^ hash(self.part_name) + value = (value * 31) ^ hash(self.max_parts) return value def __repr__(self): @@ -24055,7 +23794,7 @@ class get_partition_by_name_args: def __ne__(self, other): return not (self == other) -class get_partition_by_name_result: +class get_partitions_result: """ Attributes: - success @@ -24064,9 +23803,9 @@ class get_partition_by_name_result: """ thrift_spec = ( - (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0 - (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2 + (0, TType.LIST, 'success', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 0 + (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 ) def __init__(self, success=None, o1=None, o2=None,): @@ -24084,20 +23823,25 @@ class get_partition_by_name_result: if ftype == TType.STOP: break if fid == 0: - if ftype == TType.STRUCT: - self.success = Partition() - self.success.read(iprot) + if ftype == TType.LIST: + self.success = [] + (_etype1023, _size1020) = iprot.readListBegin() + for _i1024 in xrange(_size1020): + _elem1025 = Partition() + _elem1025.read(iprot) + self.success.append(_elem1025) + iprot.readListEnd() else: iprot.skip(ftype) elif fid == 1: if ftype == TType.STRUCT: - self.o1 = MetaException() + self.o1 = NoSuchObjectException() self.o1.read(iprot) else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRUCT: - self.o2 = NoSuchObjectException() + self.o2 = MetaException() self.o2.read(iprot) else: iprot.skip(ftype) @@ -24110,10 +23854,13 @@ class get_partition_by_name_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_partition_by_name_result') + oprot.writeStructBegin('get_partitions_result') if self.success is not None: - oprot.writeFieldBegin('success', TType.STRUCT, 0) - self.success.write(oprot) + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter1026 in self.success: + iter1026.write(oprot) + oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: oprot.writeFieldBegin('o1', TType.STRUCT, 1) @@ -24148,12 +23895,14 @@ class get_partition_by_name_result: def __ne__(self, other): return not (self == other) -class get_partitions_args: +class get_partitions_with_auth_args: """ Attributes: - db_name - tbl_name - max_parts + - user_name + - group_names """ thrift_spec = ( @@ -24161,12 +23910,16 @@ class get_partitions_args: (1, TType.STRING, 'db_name', None, None, ), # 1 (2, TType.STRING, 'tbl_name', None, None, ), # 2 (3, TType.I16, 'max_parts', None, -1, ), # 3 + (4, TType.STRING, 'user_name', None, None, ), # 4 + (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5 ) - def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],): + def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4], user_name=None, group_names=None,): self.db_name = db_name self.tbl_name = tbl_name self.max_parts = max_parts + self.user_name = user_name + self.group_names = group_names 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: @@ -24192,6 +23945,21 @@ class get_partitions_args: self.max_parts = iprot.readI16() else: iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.user_name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.group_names = [] + (_etype1030, _size1027) = iprot.readListBegin() + for _i1031 in xrange(_size1027): + _elem1032 = iprot.readString() + self.group_names.append(_elem1032) + iprot.readListEnd() + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -24201,7 +23969,7 @@ class get_partitions_args: 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_partitions_args') + oprot.writeStructBegin('get_partitions_with_auth_args') if self.db_name is not None: oprot.writeFieldBegin('db_name', TType.STRING, 1) oprot.writeString(self.db_name) @@ -24214,6 +23982,17 @@ class get_partitions_args: oprot.writeFieldBegin('max_parts', TType.I16, 3) oprot.writeI16(self.max_parts) oprot.writeFieldEnd() + if self.user_name is not None: + oprot.writeFieldBegin('user_name', TType.STRING, 4) + oprot.writeString(self.user_name) + oprot.writeFieldEnd() + if self.group_names is not None: + oprot.writeFieldBegin('group_names', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.group_names)) + for iter1033 in self.group_names: + oprot.writeString(iter1033) + oprot.writeListEnd() + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -24226,6 +24005,8 @@ class get_partitions_args: value = (value * 31) ^ hash(self.db_name) value = (value * 31) ^ hash(self.tbl_name) value = (value * 31) ^ hash(self.max_parts) + value = (value * 31) ^ hash(self.user_name) + value = (value * 31) ^ hash(self.group_names) return value def __repr__(self): @@ -24239,7 +24020,7 @@ class get_partitions_args: def __ne__(self, other): return not (self == other) -class get_partitions_result: +class get_partitions_with_auth_result: """ Attributes: - success @@ -24270,11 +24051,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1032, _size1029) = iprot.readListBegin() - for _i1033 in xrange(_size1029): - _elem1034 = Partition() - _elem1034.read(iprot) - self.success.append(_elem1034) + (_etype1037, _size1034) = iprot.readListBegin() + for _i1038 in xrange(_size1034): + _elem1039 = Partition() + _elem1039.read(iprot) + self.success.append(_elem1039) iprot.readListEnd() else: iprot.skip(ftype) @@ -24299,12 +24080,12 @@ class get_partitions_result: if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return - oprot.writeStructBegin('get_partitions_result') + oprot.writeStructBegin('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 iter1035 in self.success: - iter1035.write(oprot) + for iter1040 in self.success: + iter1040.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24340,31 +24121,25 @@ class get_partitions_result: def __ne__(self, other): return not (self == other) -class get_partitions_with_auth_args: +class get_partitions_pspec_args: """ Attributes: - db_name - tbl_name - max_parts - - user_name - - group_names """ thrift_spec = ( None, # 0 (1, TType.STRING, 'db_name', None, None, ), # 1 (2, TType.STRING, 'tbl_name', None, None, ), # 2 - (3, TType.I16, 'max_parts', None, -1, ), # 3 - (4, TType.STRING, 'user_name', None, None, ), # 4 - (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5 + (3, TType.I32, 'max_parts', None, -1, ), # 3 ) - def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4], user_name=None, group_names=None,): + def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],): self.db_name = db_name self.tbl_name = tbl_name self.max_parts = max_parts - self.user_name = user_name - self.group_names = group_names 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: @@ -24386,23 +24161,8 @@ class get_partitions_with_auth_args: else: iprot.skip(ftype) elif fid == 3: -
<TRUNCATED>