http://git-wip-us.apache.org/repos/asf/hive/blob/0d832335/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php index 997e1f7..e78a851 100644 --- a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php +++ b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php @@ -22300,22 +22300,26 @@ class WMValidateResourcePlanResponse { static $_TSPEC; /** - * @var bool + * @var string[] */ - public $isValid = null; + public $errors = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( - 'var' => 'isValid', - 'type' => TType::BOOL, + 'var' => 'errors', + 'type' => TType::LST, + 'etype' => TType::STRING, + 'elem' => array( + 'type' => TType::STRING, + ), ), ); } if (is_array($vals)) { - if (isset($vals['isValid'])) { - $this->isValid = $vals['isValid']; + if (isset($vals['errors'])) { + $this->errors = $vals['errors']; } } } @@ -22340,8 +22344,18 @@ class WMValidateResourcePlanResponse { switch ($fid) { case 1: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->isValid); + if ($ftype == TType::LST) { + $this->errors = array(); + $_size687 = 0; + $_etype690 = 0; + $xfer += $input->readListBegin($_etype690, $_size687); + for ($_i691 = 0; $_i691 < $_size687; ++$_i691) + { + $elem692 = null; + $xfer += $input->readString($elem692); + $this->errors []= $elem692; + } + $xfer += $input->readListEnd(); } else { $xfer += $input->skip($ftype); } @@ -22359,9 +22373,21 @@ class WMValidateResourcePlanResponse { public function write($output) { $xfer = 0; $xfer += $output->writeStructBegin('WMValidateResourcePlanResponse'); - if ($this->isValid !== null) { - $xfer += $output->writeFieldBegin('isValid', TType::BOOL, 1); - $xfer += $output->writeBool($this->isValid); + if ($this->errors !== null) { + if (!is_array($this->errors)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('errors', TType::LST, 1); + { + $output->writeListBegin(TType::STRING, count($this->errors)); + { + foreach ($this->errors as $iter693) + { + $xfer += $output->writeString($iter693); + } + } + $output->writeListEnd(); + } $xfer += $output->writeFieldEnd(); } $xfer += $output->writeFieldStop(); @@ -23030,15 +23056,15 @@ class WMGetTriggersForResourePlanResponse { case 1: if ($ftype == TType::LST) { $this->triggers = array(); - $_size687 = 0; - $_etype690 = 0; - $xfer += $input->readListBegin($_etype690, $_size687); - for ($_i691 = 0; $_i691 < $_size687; ++$_i691) + $_size694 = 0; + $_etype697 = 0; + $xfer += $input->readListBegin($_etype697, $_size694); + for ($_i698 = 0; $_i698 < $_size694; ++$_i698) { - $elem692 = null; - $elem692 = new \metastore\WMTrigger(); - $xfer += $elem692->read($input); - $this->triggers []= $elem692; + $elem699 = null; + $elem699 = new \metastore\WMTrigger(); + $xfer += $elem699->read($input); + $this->triggers []= $elem699; } $xfer += $input->readListEnd(); } else { @@ -23066,9 +23092,9 @@ class WMGetTriggersForResourePlanResponse { { $output->writeListBegin(TType::STRUCT, count($this->triggers)); { - foreach ($this->triggers as $iter693) + foreach ($this->triggers as $iter700) { - $xfer += $iter693->write($output); + $xfer += $iter700->write($output); } } $output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/0d832335/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 807e6b7..808ee09 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 @@ -13371,10 +13371,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype695, _size692) = iprot.readListBegin() - for _i696 in xrange(_size692): - _elem697 = iprot.readString() - self.success.append(_elem697) + (_etype702, _size699) = iprot.readListBegin() + for _i703 in xrange(_size699): + _elem704 = iprot.readString() + self.success.append(_elem704) iprot.readListEnd() else: iprot.skip(ftype) @@ -13397,8 +13397,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 iter698 in self.success: - oprot.writeString(iter698) + for iter705 in self.success: + oprot.writeString(iter705) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13503,10 +13503,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype702, _size699) = iprot.readListBegin() - for _i703 in xrange(_size699): - _elem704 = iprot.readString() - self.success.append(_elem704) + (_etype709, _size706) = iprot.readListBegin() + for _i710 in xrange(_size706): + _elem711 = iprot.readString() + self.success.append(_elem711) iprot.readListEnd() else: iprot.skip(ftype) @@ -13529,8 +13529,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 iter705 in self.success: - oprot.writeString(iter705) + for iter712 in self.success: + oprot.writeString(iter712) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14300,12 +14300,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype707, _vtype708, _size706 ) = iprot.readMapBegin() - for _i710 in xrange(_size706): - _key711 = iprot.readString() - _val712 = Type() - _val712.read(iprot) - self.success[_key711] = _val712 + (_ktype714, _vtype715, _size713 ) = iprot.readMapBegin() + for _i717 in xrange(_size713): + _key718 = iprot.readString() + _val719 = Type() + _val719.read(iprot) + self.success[_key718] = _val719 iprot.readMapEnd() else: iprot.skip(ftype) @@ -14328,9 +14328,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 kiter713,viter714 in self.success.items(): - oprot.writeString(kiter713) - viter714.write(oprot) + for kiter720,viter721 in self.success.items(): + oprot.writeString(kiter720) + viter721.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -14473,11 +14473,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype718, _size715) = iprot.readListBegin() - for _i719 in xrange(_size715): - _elem720 = FieldSchema() - _elem720.read(iprot) - self.success.append(_elem720) + (_etype725, _size722) = iprot.readListBegin() + for _i726 in xrange(_size722): + _elem727 = FieldSchema() + _elem727.read(iprot) + self.success.append(_elem727) iprot.readListEnd() else: iprot.skip(ftype) @@ -14512,8 +14512,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 iter721 in self.success: - iter721.write(oprot) + for iter728 in self.success: + iter728.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14680,11 +14680,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype725, _size722) = iprot.readListBegin() - for _i726 in xrange(_size722): - _elem727 = FieldSchema() - _elem727.read(iprot) - self.success.append(_elem727) + (_etype732, _size729) = iprot.readListBegin() + for _i733 in xrange(_size729): + _elem734 = FieldSchema() + _elem734.read(iprot) + self.success.append(_elem734) iprot.readListEnd() else: iprot.skip(ftype) @@ -14719,8 +14719,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 iter728 in self.success: - iter728.write(oprot) + for iter735 in self.success: + iter735.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14873,11 +14873,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype732, _size729) = iprot.readListBegin() - for _i733 in xrange(_size729): - _elem734 = FieldSchema() - _elem734.read(iprot) - self.success.append(_elem734) + (_etype739, _size736) = iprot.readListBegin() + for _i740 in xrange(_size736): + _elem741 = FieldSchema() + _elem741.read(iprot) + self.success.append(_elem741) iprot.readListEnd() else: iprot.skip(ftype) @@ -14912,8 +14912,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 iter735 in self.success: - iter735.write(oprot) + for iter742 in self.success: + iter742.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15080,11 +15080,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype739, _size736) = iprot.readListBegin() - for _i740 in xrange(_size736): - _elem741 = FieldSchema() - _elem741.read(iprot) - self.success.append(_elem741) + (_etype746, _size743) = iprot.readListBegin() + for _i747 in xrange(_size743): + _elem748 = FieldSchema() + _elem748.read(iprot) + self.success.append(_elem748) iprot.readListEnd() else: iprot.skip(ftype) @@ -15119,8 +15119,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 iter742 in self.success: - iter742.write(oprot) + for iter749 in self.success: + iter749.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15567,44 +15567,44 @@ class create_table_with_constraints_args: elif fid == 2: if ftype == TType.LIST: self.primaryKeys = [] - (_etype746, _size743) = iprot.readListBegin() - for _i747 in xrange(_size743): - _elem748 = SQLPrimaryKey() - _elem748.read(iprot) - self.primaryKeys.append(_elem748) + (_etype753, _size750) = iprot.readListBegin() + for _i754 in xrange(_size750): + _elem755 = SQLPrimaryKey() + _elem755.read(iprot) + self.primaryKeys.append(_elem755) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.foreignKeys = [] - (_etype752, _size749) = iprot.readListBegin() - for _i753 in xrange(_size749): - _elem754 = SQLForeignKey() - _elem754.read(iprot) - self.foreignKeys.append(_elem754) + (_etype759, _size756) = iprot.readListBegin() + for _i760 in xrange(_size756): + _elem761 = SQLForeignKey() + _elem761.read(iprot) + self.foreignKeys.append(_elem761) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.uniqueConstraints = [] - (_etype758, _size755) = iprot.readListBegin() - for _i759 in xrange(_size755): - _elem760 = SQLUniqueConstraint() - _elem760.read(iprot) - self.uniqueConstraints.append(_elem760) + (_etype765, _size762) = iprot.readListBegin() + for _i766 in xrange(_size762): + _elem767 = SQLUniqueConstraint() + _elem767.read(iprot) + self.uniqueConstraints.append(_elem767) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.LIST: self.notNullConstraints = [] - (_etype764, _size761) = iprot.readListBegin() - for _i765 in xrange(_size761): - _elem766 = SQLNotNullConstraint() - _elem766.read(iprot) - self.notNullConstraints.append(_elem766) + (_etype771, _size768) = iprot.readListBegin() + for _i772 in xrange(_size768): + _elem773 = SQLNotNullConstraint() + _elem773.read(iprot) + self.notNullConstraints.append(_elem773) iprot.readListEnd() else: iprot.skip(ftype) @@ -15625,29 +15625,29 @@ class create_table_with_constraints_args: if self.primaryKeys is not None: oprot.writeFieldBegin('primaryKeys', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys)) - for iter767 in self.primaryKeys: - iter767.write(oprot) + for iter774 in self.primaryKeys: + iter774.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 iter768 in self.foreignKeys: - iter768.write(oprot) + for iter775 in self.foreignKeys: + iter775.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 iter769 in self.uniqueConstraints: - iter769.write(oprot) + for iter776 in self.uniqueConstraints: + iter776.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 iter770 in self.notNullConstraints: - iter770.write(oprot) + for iter777 in self.notNullConstraints: + iter777.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16913,10 +16913,10 @@ class truncate_table_args: elif fid == 3: if ftype == TType.LIST: self.partNames = [] - (_etype774, _size771) = iprot.readListBegin() - for _i775 in xrange(_size771): - _elem776 = iprot.readString() - self.partNames.append(_elem776) + (_etype781, _size778) = iprot.readListBegin() + for _i782 in xrange(_size778): + _elem783 = iprot.readString() + self.partNames.append(_elem783) iprot.readListEnd() else: iprot.skip(ftype) @@ -16941,8 +16941,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 iter777 in self.partNames: - oprot.writeString(iter777) + for iter784 in self.partNames: + oprot.writeString(iter784) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17142,10 +17142,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype781, _size778) = iprot.readListBegin() - for _i782 in xrange(_size778): - _elem783 = iprot.readString() - self.success.append(_elem783) + (_etype788, _size785) = iprot.readListBegin() + for _i789 in xrange(_size785): + _elem790 = iprot.readString() + self.success.append(_elem790) iprot.readListEnd() else: iprot.skip(ftype) @@ -17168,8 +17168,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 iter784 in self.success: - oprot.writeString(iter784) + for iter791 in self.success: + oprot.writeString(iter791) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17319,10 +17319,10 @@ class get_tables_by_type_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype788, _size785) = iprot.readListBegin() - for _i789 in xrange(_size785): - _elem790 = iprot.readString() - self.success.append(_elem790) + (_etype795, _size792) = iprot.readListBegin() + for _i796 in xrange(_size792): + _elem797 = iprot.readString() + self.success.append(_elem797) iprot.readListEnd() else: iprot.skip(ftype) @@ -17345,8 +17345,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 iter791 in self.success: - oprot.writeString(iter791) + for iter798 in self.success: + oprot.writeString(iter798) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17419,10 +17419,10 @@ class get_table_meta_args: elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] - (_etype795, _size792) = iprot.readListBegin() - for _i796 in xrange(_size792): - _elem797 = iprot.readString() - self.tbl_types.append(_elem797) + (_etype802, _size799) = iprot.readListBegin() + for _i803 in xrange(_size799): + _elem804 = iprot.readString() + self.tbl_types.append(_elem804) iprot.readListEnd() else: iprot.skip(ftype) @@ -17447,8 +17447,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 iter798 in self.tbl_types: - oprot.writeString(iter798) + for iter805 in self.tbl_types: + oprot.writeString(iter805) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17504,11 +17504,11 @@ class get_table_meta_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype802, _size799) = iprot.readListBegin() - for _i803 in xrange(_size799): - _elem804 = TableMeta() - _elem804.read(iprot) - self.success.append(_elem804) + (_etype809, _size806) = iprot.readListBegin() + for _i810 in xrange(_size806): + _elem811 = TableMeta() + _elem811.read(iprot) + self.success.append(_elem811) iprot.readListEnd() else: iprot.skip(ftype) @@ -17531,8 +17531,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 iter805 in self.success: - iter805.write(oprot) + for iter812 in self.success: + iter812.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17656,10 +17656,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype809, _size806) = iprot.readListBegin() - for _i810 in xrange(_size806): - _elem811 = iprot.readString() - self.success.append(_elem811) + (_etype816, _size813) = iprot.readListBegin() + for _i817 in xrange(_size813): + _elem818 = iprot.readString() + self.success.append(_elem818) iprot.readListEnd() else: iprot.skip(ftype) @@ -17682,8 +17682,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 iter812 in self.success: - oprot.writeString(iter812) + for iter819 in self.success: + oprot.writeString(iter819) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17919,10 +17919,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype816, _size813) = iprot.readListBegin() - for _i817 in xrange(_size813): - _elem818 = iprot.readString() - self.tbl_names.append(_elem818) + (_etype823, _size820) = iprot.readListBegin() + for _i824 in xrange(_size820): + _elem825 = iprot.readString() + self.tbl_names.append(_elem825) iprot.readListEnd() else: iprot.skip(ftype) @@ -17943,8 +17943,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 iter819 in self.tbl_names: - oprot.writeString(iter819) + for iter826 in self.tbl_names: + oprot.writeString(iter826) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17996,11 +17996,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype823, _size820) = iprot.readListBegin() - for _i824 in xrange(_size820): - _elem825 = Table() - _elem825.read(iprot) - self.success.append(_elem825) + (_etype830, _size827) = iprot.readListBegin() + for _i831 in xrange(_size827): + _elem832 = Table() + _elem832.read(iprot) + self.success.append(_elem832) iprot.readListEnd() else: iprot.skip(ftype) @@ -18017,8 +18017,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 iter826 in self.success: - iter826.write(oprot) + for iter833 in self.success: + iter833.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18501,10 +18501,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype830, _size827) = iprot.readListBegin() - for _i831 in xrange(_size827): - _elem832 = iprot.readString() - self.success.append(_elem832) + (_etype837, _size834) = iprot.readListBegin() + for _i838 in xrange(_size834): + _elem839 = iprot.readString() + self.success.append(_elem839) iprot.readListEnd() else: iprot.skip(ftype) @@ -18539,8 +18539,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 iter833 in self.success: - oprot.writeString(iter833) + for iter840 in self.success: + oprot.writeString(iter840) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19510,11 +19510,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype837, _size834) = iprot.readListBegin() - for _i838 in xrange(_size834): - _elem839 = Partition() - _elem839.read(iprot) - self.new_parts.append(_elem839) + (_etype844, _size841) = iprot.readListBegin() + for _i845 in xrange(_size841): + _elem846 = Partition() + _elem846.read(iprot) + self.new_parts.append(_elem846) iprot.readListEnd() else: iprot.skip(ftype) @@ -19531,8 +19531,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 iter840 in self.new_parts: - iter840.write(oprot) + for iter847 in self.new_parts: + iter847.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19690,11 +19690,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype844, _size841) = iprot.readListBegin() - for _i845 in xrange(_size841): - _elem846 = PartitionSpec() - _elem846.read(iprot) - self.new_parts.append(_elem846) + (_etype851, _size848) = iprot.readListBegin() + for _i852 in xrange(_size848): + _elem853 = PartitionSpec() + _elem853.read(iprot) + self.new_parts.append(_elem853) iprot.readListEnd() else: iprot.skip(ftype) @@ -19711,8 +19711,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 iter847 in self.new_parts: - iter847.write(oprot) + for iter854 in self.new_parts: + iter854.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19886,10 +19886,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype851, _size848) = iprot.readListBegin() - for _i852 in xrange(_size848): - _elem853 = iprot.readString() - self.part_vals.append(_elem853) + (_etype858, _size855) = iprot.readListBegin() + for _i859 in xrange(_size855): + _elem860 = iprot.readString() + self.part_vals.append(_elem860) iprot.readListEnd() else: iprot.skip(ftype) @@ -19914,8 +19914,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 iter854 in self.part_vals: - oprot.writeString(iter854) + for iter861 in self.part_vals: + oprot.writeString(iter861) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20268,10 +20268,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype858, _size855) = iprot.readListBegin() - for _i859 in xrange(_size855): - _elem860 = iprot.readString() - self.part_vals.append(_elem860) + (_etype865, _size862) = iprot.readListBegin() + for _i866 in xrange(_size862): + _elem867 = iprot.readString() + self.part_vals.append(_elem867) iprot.readListEnd() else: iprot.skip(ftype) @@ -20302,8 +20302,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 iter861 in self.part_vals: - oprot.writeString(iter861) + for iter868 in self.part_vals: + oprot.writeString(iter868) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -20898,10 +20898,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype865, _size862) = iprot.readListBegin() - for _i866 in xrange(_size862): - _elem867 = iprot.readString() - self.part_vals.append(_elem867) + (_etype872, _size869) = iprot.readListBegin() + for _i873 in xrange(_size869): + _elem874 = iprot.readString() + self.part_vals.append(_elem874) iprot.readListEnd() else: iprot.skip(ftype) @@ -20931,8 +20931,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 iter868 in self.part_vals: - oprot.writeString(iter868) + for iter875 in self.part_vals: + oprot.writeString(iter875) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -21105,10 +21105,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype872, _size869) = iprot.readListBegin() - for _i873 in xrange(_size869): - _elem874 = iprot.readString() - self.part_vals.append(_elem874) + (_etype879, _size876) = iprot.readListBegin() + for _i880 in xrange(_size876): + _elem881 = iprot.readString() + self.part_vals.append(_elem881) iprot.readListEnd() else: iprot.skip(ftype) @@ -21144,8 +21144,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 iter875 in self.part_vals: - oprot.writeString(iter875) + for iter882 in self.part_vals: + oprot.writeString(iter882) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -21882,10 +21882,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype879, _size876) = iprot.readListBegin() - for _i880 in xrange(_size876): - _elem881 = iprot.readString() - self.part_vals.append(_elem881) + (_etype886, _size883) = iprot.readListBegin() + for _i887 in xrange(_size883): + _elem888 = iprot.readString() + self.part_vals.append(_elem888) iprot.readListEnd() else: iprot.skip(ftype) @@ -21910,8 +21910,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 iter882 in self.part_vals: - oprot.writeString(iter882) + for iter889 in self.part_vals: + oprot.writeString(iter889) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22070,11 +22070,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype884, _vtype885, _size883 ) = iprot.readMapBegin() - for _i887 in xrange(_size883): - _key888 = iprot.readString() - _val889 = iprot.readString() - self.partitionSpecs[_key888] = _val889 + (_ktype891, _vtype892, _size890 ) = iprot.readMapBegin() + for _i894 in xrange(_size890): + _key895 = iprot.readString() + _val896 = iprot.readString() + self.partitionSpecs[_key895] = _val896 iprot.readMapEnd() else: iprot.skip(ftype) @@ -22111,9 +22111,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 kiter890,viter891 in self.partitionSpecs.items(): - oprot.writeString(kiter890) - oprot.writeString(viter891) + for kiter897,viter898 in self.partitionSpecs.items(): + oprot.writeString(kiter897) + oprot.writeString(viter898) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -22318,11 +22318,11 @@ class exchange_partitions_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype893, _vtype894, _size892 ) = iprot.readMapBegin() - for _i896 in xrange(_size892): - _key897 = iprot.readString() - _val898 = iprot.readString() - self.partitionSpecs[_key897] = _val898 + (_ktype900, _vtype901, _size899 ) = iprot.readMapBegin() + for _i903 in xrange(_size899): + _key904 = iprot.readString() + _val905 = iprot.readString() + self.partitionSpecs[_key904] = _val905 iprot.readMapEnd() else: iprot.skip(ftype) @@ -22359,9 +22359,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 kiter899,viter900 in self.partitionSpecs.items(): - oprot.writeString(kiter899) - oprot.writeString(viter900) + for kiter906,viter907 in self.partitionSpecs.items(): + oprot.writeString(kiter906) + oprot.writeString(viter907) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -22444,11 +22444,11 @@ class exchange_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype904, _size901) = iprot.readListBegin() - for _i905 in xrange(_size901): - _elem906 = Partition() - _elem906.read(iprot) - self.success.append(_elem906) + (_etype911, _size908) = iprot.readListBegin() + for _i912 in xrange(_size908): + _elem913 = Partition() + _elem913.read(iprot) + self.success.append(_elem913) iprot.readListEnd() else: iprot.skip(ftype) @@ -22489,8 +22489,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 iter907 in self.success: - iter907.write(oprot) + for iter914 in self.success: + iter914.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22584,10 +22584,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype911, _size908) = iprot.readListBegin() - for _i912 in xrange(_size908): - _elem913 = iprot.readString() - self.part_vals.append(_elem913) + (_etype918, _size915) = iprot.readListBegin() + for _i919 in xrange(_size915): + _elem920 = iprot.readString() + self.part_vals.append(_elem920) iprot.readListEnd() else: iprot.skip(ftype) @@ -22599,10 +22599,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype917, _size914) = iprot.readListBegin() - for _i918 in xrange(_size914): - _elem919 = iprot.readString() - self.group_names.append(_elem919) + (_etype924, _size921) = iprot.readListBegin() + for _i925 in xrange(_size921): + _elem926 = iprot.readString() + self.group_names.append(_elem926) iprot.readListEnd() else: iprot.skip(ftype) @@ -22627,8 +22627,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 iter920 in self.part_vals: - oprot.writeString(iter920) + for iter927 in self.part_vals: + oprot.writeString(iter927) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -22638,8 +22638,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 iter921 in self.group_names: - oprot.writeString(iter921) + for iter928 in self.group_names: + oprot.writeString(iter928) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23068,11 +23068,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype925, _size922) = iprot.readListBegin() - for _i926 in xrange(_size922): - _elem927 = Partition() - _elem927.read(iprot) - self.success.append(_elem927) + (_etype932, _size929) = iprot.readListBegin() + for _i933 in xrange(_size929): + _elem934 = Partition() + _elem934.read(iprot) + self.success.append(_elem934) iprot.readListEnd() else: iprot.skip(ftype) @@ -23101,8 +23101,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 iter928 in self.success: - iter928.write(oprot) + for iter935 in self.success: + iter935.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23196,10 +23196,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype932, _size929) = iprot.readListBegin() - for _i933 in xrange(_size929): - _elem934 = iprot.readString() - self.group_names.append(_elem934) + (_etype939, _size936) = iprot.readListBegin() + for _i940 in xrange(_size936): + _elem941 = iprot.readString() + self.group_names.append(_elem941) iprot.readListEnd() else: iprot.skip(ftype) @@ -23232,8 +23232,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 iter935 in self.group_names: - oprot.writeString(iter935) + for iter942 in self.group_names: + oprot.writeString(iter942) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23294,11 +23294,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype939, _size936) = iprot.readListBegin() - for _i940 in xrange(_size936): - _elem941 = Partition() - _elem941.read(iprot) - self.success.append(_elem941) + (_etype946, _size943) = iprot.readListBegin() + for _i947 in xrange(_size943): + _elem948 = Partition() + _elem948.read(iprot) + self.success.append(_elem948) iprot.readListEnd() else: iprot.skip(ftype) @@ -23327,8 +23327,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 iter942 in self.success: - iter942.write(oprot) + for iter949 in self.success: + iter949.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23486,11 +23486,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype946, _size943) = iprot.readListBegin() - for _i947 in xrange(_size943): - _elem948 = PartitionSpec() - _elem948.read(iprot) - self.success.append(_elem948) + (_etype953, _size950) = iprot.readListBegin() + for _i954 in xrange(_size950): + _elem955 = PartitionSpec() + _elem955.read(iprot) + self.success.append(_elem955) iprot.readListEnd() else: iprot.skip(ftype) @@ -23519,8 +23519,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 iter949 in self.success: - iter949.write(oprot) + for iter956 in self.success: + iter956.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23678,10 +23678,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype953, _size950) = iprot.readListBegin() - for _i954 in xrange(_size950): - _elem955 = iprot.readString() - self.success.append(_elem955) + (_etype960, _size957) = iprot.readListBegin() + for _i961 in xrange(_size957): + _elem962 = iprot.readString() + self.success.append(_elem962) iprot.readListEnd() else: iprot.skip(ftype) @@ -23710,8 +23710,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 iter956 in self.success: - oprot.writeString(iter956) + for iter963 in self.success: + oprot.writeString(iter963) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23951,10 +23951,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype960, _size957) = iprot.readListBegin() - for _i961 in xrange(_size957): - _elem962 = iprot.readString() - self.part_vals.append(_elem962) + (_etype967, _size964) = iprot.readListBegin() + for _i968 in xrange(_size964): + _elem969 = iprot.readString() + self.part_vals.append(_elem969) iprot.readListEnd() else: iprot.skip(ftype) @@ -23984,8 +23984,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 iter963 in self.part_vals: - oprot.writeString(iter963) + for iter970 in self.part_vals: + oprot.writeString(iter970) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -24049,11 +24049,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype967, _size964) = iprot.readListBegin() - for _i968 in xrange(_size964): - _elem969 = Partition() - _elem969.read(iprot) - self.success.append(_elem969) + (_etype974, _size971) = iprot.readListBegin() + for _i975 in xrange(_size971): + _elem976 = Partition() + _elem976.read(iprot) + self.success.append(_elem976) iprot.readListEnd() else: iprot.skip(ftype) @@ -24082,8 +24082,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 iter970 in self.success: - iter970.write(oprot) + for iter977 in self.success: + iter977.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24170,10 +24170,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype974, _size971) = iprot.readListBegin() - for _i975 in xrange(_size971): - _elem976 = iprot.readString() - self.part_vals.append(_elem976) + (_etype981, _size978) = iprot.readListBegin() + for _i982 in xrange(_size978): + _elem983 = iprot.readString() + self.part_vals.append(_elem983) iprot.readListEnd() else: iprot.skip(ftype) @@ -24190,10 +24190,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype980, _size977) = iprot.readListBegin() - for _i981 in xrange(_size977): - _elem982 = iprot.readString() - self.group_names.append(_elem982) + (_etype987, _size984) = iprot.readListBegin() + for _i988 in xrange(_size984): + _elem989 = iprot.readString() + self.group_names.append(_elem989) iprot.readListEnd() else: iprot.skip(ftype) @@ -24218,8 +24218,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 iter983 in self.part_vals: - oprot.writeString(iter983) + for iter990 in self.part_vals: + oprot.writeString(iter990) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -24233,8 +24233,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 iter984 in self.group_names: - oprot.writeString(iter984) + for iter991 in self.group_names: + oprot.writeString(iter991) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24296,11 +24296,11 @@ class get_partitions_ps_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype988, _size985) = iprot.readListBegin() - for _i989 in xrange(_size985): - _elem990 = Partition() - _elem990.read(iprot) - self.success.append(_elem990) + (_etype995, _size992) = iprot.readListBegin() + for _i996 in xrange(_size992): + _elem997 = Partition() + _elem997.read(iprot) + self.success.append(_elem997) iprot.readListEnd() else: iprot.skip(ftype) @@ -24329,8 +24329,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 iter991 in self.success: - iter991.write(oprot) + for iter998 in self.success: + iter998.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24411,10 +24411,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype995, _size992) = iprot.readListBegin() - for _i996 in xrange(_size992): - _elem997 = iprot.readString() - self.part_vals.append(_elem997) + (_etype1002, _size999) = iprot.readListBegin() + for _i1003 in xrange(_size999): + _elem1004 = iprot.readString() + self.part_vals.append(_elem1004) iprot.readListEnd() else: iprot.skip(ftype) @@ -24444,8 +24444,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 iter998 in self.part_vals: - oprot.writeString(iter998) + for iter1005 in self.part_vals: + oprot.writeString(iter1005) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -24509,10 +24509,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1002, _size999) = iprot.readListBegin() - for _i1003 in xrange(_size999): - _elem1004 = iprot.readString() - self.success.append(_elem1004) + (_etype1009, _size1006) = iprot.readListBegin() + for _i1010 in xrange(_size1006): + _elem1011 = iprot.readString() + self.success.append(_elem1011) iprot.readListEnd() else: iprot.skip(ftype) @@ -24541,8 +24541,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 iter1005 in self.success: - oprot.writeString(iter1005) + for iter1012 in self.success: + oprot.writeString(iter1012) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24713,11 +24713,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1009, _size1006) = iprot.readListBegin() - for _i1010 in xrange(_size1006): - _elem1011 = Partition() - _elem1011.read(iprot) - self.success.append(_elem1011) + (_etype1016, _size1013) = iprot.readListBegin() + for _i1017 in xrange(_size1013): + _elem1018 = Partition() + _elem1018.read(iprot) + self.success.append(_elem1018) iprot.readListEnd() else: iprot.skip(ftype) @@ -24746,8 +24746,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 iter1012 in self.success: - iter1012.write(oprot) + for iter1019 in self.success: + iter1019.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24918,11 +24918,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1016, _size1013) = iprot.readListBegin() - for _i1017 in xrange(_size1013): - _elem1018 = PartitionSpec() - _elem1018.read(iprot) - self.success.append(_elem1018) + (_etype1023, _size1020) = iprot.readListBegin() + for _i1024 in xrange(_size1020): + _elem1025 = PartitionSpec() + _elem1025.read(iprot) + self.success.append(_elem1025) iprot.readListEnd() else: iprot.skip(ftype) @@ -24951,8 +24951,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 iter1019 in self.success: - iter1019.write(oprot) + for iter1026 in self.success: + iter1026.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -25372,10 +25372,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype1023, _size1020) = iprot.readListBegin() - for _i1024 in xrange(_size1020): - _elem1025 = iprot.readString() - self.names.append(_elem1025) + (_etype1030, _size1027) = iprot.readListBegin() + for _i1031 in xrange(_size1027): + _elem1032 = iprot.readString() + self.names.append(_elem1032) iprot.readListEnd() else: iprot.skip(ftype) @@ -25400,8 +25400,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 iter1026 in self.names: - oprot.writeString(iter1026) + for iter1033 in self.names: + oprot.writeString(iter1033) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -25460,11 +25460,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1030, _size1027) = iprot.readListBegin() - for _i1031 in xrange(_size1027): - _elem1032 = Partition() - _elem1032.read(iprot) - self.success.append(_elem1032) + (_etype1037, _size1034) = iprot.readListBegin() + for _i1038 in xrange(_size1034): + _elem1039 = Partition() + _elem1039.read(iprot) + self.success.append(_elem1039) iprot.readListEnd() else: iprot.skip(ftype) @@ -25493,8 +25493,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 iter1033 in self.success: - iter1033.write(oprot) + for iter1040 in self.success: + iter1040.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -25744,11 +25744,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1037, _size1034) = iprot.readListBegin() - for _i1038 in xrange(_size1034): - _elem1039 = Partition() - _elem1039.read(iprot) - self.new_parts.append(_elem1039) + (_etype1044, _size1041) = iprot.readListBegin() + for _i1045 in xrange(_size1041): + _elem1046 = Partition() + _elem1046.read(iprot) + self.new_parts.append(_elem1046) iprot.readListEnd() else: iprot.skip(ftype) @@ -25773,8 +25773,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 iter1040 in self.new_parts: - iter1040.write(oprot) + for iter1047 in self.new_parts: + iter1047.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -25927,11 +25927,11 @@ class alter_partitions_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1044, _size1041) = iprot.readListBegin() - for _i1045 in xrange(_size1041): - _elem1046 = Partition() - _elem1046.read(iprot) - self.new_parts.append(_elem1046) + (_etype1051, _size1048) = iprot.readListBegin() + for _i1052 in xrange(_size1048): + _elem1053 = Partition() + _elem1053.read(iprot) + self.new_parts.append(_elem1053) iprot.readListEnd() else: iprot.skip(ftype) @@ -25962,8 +25962,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 iter1047 in self.new_parts: - iter1047.write(oprot) + for iter1054 in self.new_parts: + iter1054.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -26307,10 +26307,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1051, _size1048) = iprot.readListBegin() - for _i1052 in xrange(_size1048): - _elem1053 = iprot.readString() - self.part_vals.append(_elem1053) + (_etype1058, _size1055) = iprot.readListBegin() + for _i1059 in xrange(_size1055): + _elem1060 = iprot.readString() + self.part_vals.append(_elem1060) iprot.readListEnd() else: iprot.skip(ftype) @@ -26341,8 +26341,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 iter1054 in self.part_vals: - oprot.writeString(iter1054) + for iter1061 in self.part_vals: + oprot.writeString(iter1061) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -26484,10 +26484,10 @@ class partition_name_has_valid_characters_args: if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype1058, _size1055) = iprot.readListBegin() - for _i1059 in xrange(_size1055): - _elem1060 = iprot.readString() - self.part_vals.append(_elem1060) + (_etype1065, _size1062) = iprot.readListBegin() + for _i1066 in xrange(_size1062): + _elem1067 = iprot.readString() + self.part_vals.append(_elem1067) iprot.readListEnd() else: iprot.skip(ftype) @@ -26509,8 +26509,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 iter1061 in self.part_vals: - oprot.writeString(iter1061) + for iter1068 in self.part_vals: + oprot.writeString(iter1068) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -26868,10 +26868,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1065, _size1062) = iprot.readListBegin() - for _i1066 in xrange(_size1062): - _elem1067 = iprot.readString() - self.success.append(_elem1067) + (_etype1072, _size1069) = iprot.readListBegin() + for _i1073 in xrange(_size1069): + _elem1074 = iprot.readString() + self.success.append(_elem1074) iprot.readListEnd() else: iprot.skip(ftype) @@ -26894,8 +26894,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 iter1068 in self.success: - oprot.writeString(iter1068) + for iter1075 in self.success: + oprot.writeString(iter1075) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27019,11 +27019,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype1070, _vtype1071, _size1069 ) = iprot.readMapBegin() - for _i1073 in xrange(_size1069): - _key1074 = iprot.readString() - _val1075 = iprot.readString() - self.success[_key1074] = _val1075 + (_ktype1077, _vtype1078, _size1076 ) = iprot.readMapBegin() + for _i1080 in xrange(_size1076): + _key1081 = iprot.readString() + _val1082 = iprot.readString() + self.success[_key1081] = _val1082 iprot.readMapEnd() else: iprot.skip(ftype) @@ -27046,9 +27046,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 kiter1076,viter1077 in self.success.items(): - oprot.writeString(kiter1076) - oprot.writeString(viter1077) + for kiter1083,viter1084 in self.success.items(): + oprot.writeString(kiter1083) + oprot.writeString(viter1084) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27124,11 +27124,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype1079, _vtype1080, _size1078 ) = iprot.readMapBegin() - for _i1082 in xrange(_size1078): - _key1083 = iprot.readString() - _val1084 = iprot.readString() - self.part_vals[_key1083] = _val1084 + (_ktype1086, _vtype1087, _size1085 ) = iprot.readMapBegin() + for _i1089 in xrange(_size1085): + _key1090 = iprot.readString() + _val1091 = iprot.readString() + self.part_vals[_key1090] = _val1091 iprot.readMapEnd() else: iprot.skip(ftype) @@ -27158,9 +27158,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 kiter1085,viter1086 in self.part_vals.items(): - oprot.writeString(kiter1085) - oprot.writeString(viter1086) + for kiter1092,viter1093 in self.part_vals.items(): + oprot.writeString(kiter1092) + oprot.writeString(viter1093) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -27374,11 +27374,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype1088, _vtype1089, _size1087 ) = iprot.readMapBegin() - for _i1091 in xrange(_size1087): - _key1092 = iprot.readString() - _val1093 = iprot.readString() - self.part_vals[_key1092] = _val1093 + (_ktype1095, _vtype1096, _size1094 ) = iprot.readMapBegin() + for _i1098 in xrange(_size1094): + _key1099 = iprot.readString() + _val1100 = iprot.readString() + self.part_vals[_key1099] = _val1100 iprot.readMapEnd() else: iprot.skip(ftype) @@ -27408,9 +27408,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 kiter1094,viter1095 in self.part_vals.items(): - oprot.writeString(kiter1094) - oprot.writeString(viter1095) + for kiter1101,viter1102 in self.part_vals.items(): + oprot.writeString(kiter1101) + oprot.writeString(viter1102) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -28465,11 +28465,11 @@ class get_indexes_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1099, _size1096) = iprot.readListBegin() - for _i1100 in xrange(_size1096): - _elem1101 = Index() - _elem1101.read(iprot) - self.success.append(_elem1101) + (_etype1106, _size1103) = iprot.readListBegin() + for _i1107 in xrange(_size1103): + _elem1108 = Index() + _elem1108.read(iprot) + self.success.append(_elem1108) iprot.readListEnd() else: iprot.skip(ftype) @@ -28498,8 +28498,8 @@ class get_indexes_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter1102 in self.success: - iter1102.write(oprot) + for iter1109 in self.success: + iter1109.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28654,10 +28654,10 @@ class get_index_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1106, _size1103) = iprot.readListBegin() - for _i1107 in xrange(_size1103): - _elem1108 = iprot.readString() - self.success.append(_elem1108) + (_etype1113, _size1110) = iprot.readListBegin() + for _i1114 in xrange(_size1110): + _elem1115 = iprot.readString() + self.success.append(_elem1115) iprot.readListEnd() else: iprot.skip(ftype) @@ -28680,8 +28680,8 @@ class get_index_names_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter1109 in self.success: - oprot.writeString(iter1109) + for iter1116 in self.success: + oprot.writeString(iter1116) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -31865,10 +31865,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1113, _size1110) = iprot.readListBegin() - for _i1114 in xrange(_size1110): - _elem1115 = iprot.readString() - self.success.append(_elem1115) + (_etype1120, _size1117) = iprot.readListBegin() + for _i1121 in xrange(_size1117): + _elem1122 = iprot.readString() + self.success.append(_elem1122) iprot.readListEnd() else: iprot.skip(ftype) @@ -31891,8 +31891,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 iter1116 in self.success: - oprot.writeString(iter1116) + for iter1123 in self.success: + oprot.writeString(iter1123) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -32580,10 +32580,10 @@ class get_role_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1120, _size1117) = iprot.readListBegin() - for _i1121 in xrange(_size1117): - _elem1122 = iprot.readString() - self.success.append(_elem1122) + (_etype1127, _size1124) = iprot.readListBegin() + for _i1128 in xrange(_size1124): + _elem1129 = iprot.readString() + self.success.append(_elem1129) iprot.readListEnd() else: iprot.skip(ftype) @@ -32606,8 +32606,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 iter1123 in self.success: - oprot.writeString(iter1123) + for iter1130 in self.success: + oprot.writeString(iter1130) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -33121,11 +33121,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1127, _size1124) = iprot.readListBegin() - for _i1128 in xrange(_size1124): - _elem1129 = Role() - _elem1129.read(iprot) - self.success.append(_elem1129) + (_etype1134, _size1131) = iprot.readListBegin() + for _i1135 in xrange(_size1131): + _elem1136 = Role() + _elem1136.read(iprot) + self.success.append(_elem1136) iprot.readListEnd() else: iprot.skip(ftype) @@ -33148,8 +33148,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 iter1130 in self.success: - iter1130.write(oprot) + for iter1137 in self.success: + iter1137.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -33658,10 +33658,10 @@ class get_privilege_set_args: elif fid == 3: if ftype == TType.LIST: self.group_names = [] - (_etype1134, _size1131) = iprot.readListBegin() - for _i1135 in xrange(_size1131): - _elem1136 = iprot.readString() - self.group_names.append(_elem1136) + (_etype1141, _size1138) = iprot.readListBegin() + for _i1142 in xrange(_size1138): + _elem1143 = iprot.readString() + self.group_names.append(_elem1143) iprot.readListEnd() else: iprot.skip(ftype) @@ -33686,8 +33686,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 iter1137 in self.group_names: - oprot.writeString(iter1137) + for iter1144 in self.group_names: + oprot.writeString(iter1144) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -33914,11 +33914,11 @@ class list_privileges_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1141, _size1138) = iprot.readListBegin() - for _i1142 in xrange(_size1138): - _elem1143 = HiveObjectPrivilege() - _elem1143.read(iprot) - self.success.append(_elem1143) + (_etype1148, _size1145) = iprot.readListBegin() + for _i1149 in xrange(_size1145): + _elem1150 = HiveObjectPrivilege() + _elem1150.read(iprot) + self.success.append(_elem1150) iprot.readListEnd() else: iprot.skip(ftype) @@ -33941,8 +33941,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 iter1144 in self.success: - iter1144.write(oprot) + for iter1151 in self.success: + iter1151.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -34440,10 +34440,10 @@ class set_ugi_args: elif fid == 2: if ftype == TType.LIST: self.group_names = [] - (_etype1148, _size1145) = iprot.readListBegin() - for _i1149 in xrange(_size1145): - _elem1150 = iprot.readString() - self.group_names.append(_elem1150) + (_etype1155, _size1152) = iprot.readListBegin() + for _i1156 in xrange(_size1152): + _elem1157 = iprot.readString() + self.group_names.append(_elem1157) iprot.readListEnd() else: iprot.skip(ftype) @@ -34464,8 +34464,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 iter1151 in self.group_names: - oprot.writeString(iter1151) + for iter1158 in self.group_names: + oprot.writeString(iter1158) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -34520,10 +34520,10 @@ class set_ugi_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1155, _size1152) = iprot.readListBegin() - for _i1156 in xrange(_size1152): - _elem1157 = iprot.readString() - self.success.append(_elem1157) + (_etype1162, _size1159) = iprot.readListBegin() + for _i1163 in xrange(_size1159): + _elem1164 = iprot.readString() + self.success.append(_elem1164) iprot.readListEnd() else: iprot.skip(ftype) @@ -34546,8 +34546,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 iter1158 in self.success: - oprot.writeString(iter1158) + for iter1165 in self.success: + oprot.writeString(iter1165) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -35479,10 +35479,10 @@ class get_all_token_identifiers_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1162, _size1159) = iprot.readListBegin() - for _i1163 in xrange(_size1159): - _elem1164 = iprot.readString() - self.success.append(_elem1164) + (_etype1169, _size1166) = iprot.readListBegin() + for _i1170 in xrange(_size1166): + _elem1171 = iprot.readString() + self.success.append(_elem1171) iprot.readListEnd() else: iprot.skip(ftype) @@ -35499,8 +35499,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 iter1165 in self.success: - oprot.writeString(iter1165) + for iter1172 in self.success: + oprot.writeString(iter1172) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -36027,10 +36027,10 @@ class get_master_keys_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1169, _size1166) = iprot.readListBegin() - for _i1170 in xrange(_size1166): - _elem1171 = iprot.readString() - self.success.append(_elem1171) + (_etype1176, _size1173) = iprot.readListBegin() + for _i1177 in xrange(_size1173): + _elem1178 = iprot.readString() + self.success.append(_elem1178) iprot.readListEnd() else: iprot.skip(ftype) @@ -36047,8 +36047,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 iter1172 in self.success: - oprot.writeString(iter1172) + for iter1179 in self.success: + oprot.writeString(iter1179) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() http://git-wip-us.apache.org/repos/asf/hive/blob/0d832335/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py index 68d6c9c..863031d 100644 --- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py +++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py @@ -15821,16 +15821,16 @@ class WMValidateResourcePlanRequest: class WMValidateResourcePlanResponse: """ Attributes: - - isValid + - errors """ thrift_spec = ( None, # 0 - (1, TType.BOOL, 'isValid', None, None, ), # 1 + (1, TType.LIST, 'errors', (TType.STRING,None), None, ), # 1 ) - def __init__(self, isValid=None,): - self.isValid = isValid + def __init__(self, errors=None,): + self.errors = errors 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: @@ -15842,8 +15842,13 @@ class WMValidateResourcePlanResponse: if ftype == TType.STOP: break if fid == 1: - if ftype == TType.BOOL: - self.isValid = iprot.readBool() + if ftype == TType.LIST: + self.errors = [] + (_etype688, _size685) = iprot.readListBegin() + for _i689 in xrange(_size685): + _elem690 = iprot.readString() + self.errors.append(_elem690) + iprot.readListEnd() else: iprot.skip(ftype) else: @@ -15856,9 +15861,12 @@ class WMValidateResourcePlanResponse: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return oprot.writeStructBegin('WMValidateResourcePlanResponse') - if self.isValid is not None: - oprot.writeFieldBegin('isValid', TType.BOOL, 1) - oprot.writeBool(self.isValid) + if self.errors is not None: + oprot.writeFieldBegin('errors', TType.LIST, 1) + oprot.writeListBegin(TType.STRING, len(self.errors)) + for iter691 in self.errors: + oprot.writeString(iter691) + oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() @@ -15869,7 +15877,7 @@ class WMValidateResourcePlanResponse: def __hash__(self): value = 17 - value = (value * 31) ^ hash(self.isValid) + value = (value * 31) ^ hash(self.errors) return value def __repr__(self): @@ -16433,11 +16441,11 @@ class WMGetTriggersForResourePlanResponse: if fid == 1: if ftype == TType.LIST: self.triggers = [] - (_etype688, _size685) = iprot.readListBegin() - for _i689 in xrange(_size685): - _elem690 = WMTrigger() - _elem690.read(iprot) - self.triggers.append(_elem690) + (_etype695, _size692) = iprot.readListBegin() + for _i696 in xrange(_size692): + _elem697 = WMTrigger() + _elem697.read(iprot) + self.triggers.append(_elem697) iprot.readListEnd() else: iprot.skip(ftype) @@ -16454,8 +16462,8 @@ class WMGetTriggersForResourePlanResponse: if self.triggers is not None: oprot.writeFieldBegin('triggers', TType.LIST, 1) oprot.writeListBegin(TType.STRUCT, len(self.triggers)) - for iter691 in self.triggers: - iter691.write(oprot) + for iter698 in self.triggers: + iter698.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() http://git-wip-us.apache.org/repos/asf/hive/blob/0d832335/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb b/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb index cc57c85..ec967a6 100644 --- a/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb +++ b/standalone-metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb @@ -3581,10 +3581,10 @@ end class WMValidateResourcePlanResponse include ::Thrift::Struct, ::Thrift::Struct_Union - ISVALID = 1 + ERRORS = 1 FIELDS = { - ISVALID => {:type => ::Thrift::Types::BOOL, :name => 'isValid', :optional => true} + ERRORS => {:type => ::Thrift::Types::LIST, :name => 'errors', :element => {:type => ::Thrift::Types::STRING}, :optional => true} } def struct_fields; FIELDS; end http://git-wip-us.apache.org/repos/asf/hive/blob/0d832335/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java index 78efe38..6e0da57 100644 --- a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java +++ b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java @@ -7342,9 +7342,9 @@ public class HiveMetaStore extends ThriftHiveMetastore { public WMValidateResourcePlanResponse validate_resource_plan(WMValidateResourcePlanRequest request) throws NoSuchObjectException, MetaException, TException { try { - boolean isValid = getMS().validateResourcePlan(request.getResourcePlanName()); + List<String> errors = getMS().validateResourcePlan(request.getResourcePlanName()); WMValidateResourcePlanResponse resp = new WMValidateResourcePlanResponse(); - resp.setIsValid(isValid); + resp.setErrors(errors); return resp; } catch (MetaException e) { LOG.error("Exception while trying to validate resource plan", e); http://git-wip-us.apache.org/repos/asf/hive/blob/0d832335/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java index fcd06a8..0818704 100644 --- a/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java +++ b/standalone-metastore/src/main/java/org/apache/hadoop/hive/metastore/ObjectStore.java @@ -9799,8 +9799,8 @@ public class ObjectStore implements RawStore, Configurable { if (doValidate) { // Note: this may use additional inputs from the caller, e.g. maximum query // parallelism in the cluster based on physical constraints. - String planErrors = getResourcePlanErrors(mResourcePlan); - if (planErrors != null) { + List<String> planErrors = getResourcePlanErrors(mResourcePlan); + if (!planErrors.isEmpty()) { throw new InvalidOperationException( "ResourcePlan: " + name + " is invalid: " + planErrors); } @@ -9834,12 +9834,74 @@ public class ObjectStore implements RawStore, Configurable { } } - private String getResourcePlanErrors(MWMResourcePlan mResourcePlan) { - return null; + private static class PoolData { + int queryParallelism = 0; + int totalChildrenQueryParallelism = 0; + double totalChildrenAllocFraction = 0; + boolean found = false; + boolean hasChildren = false; + } + + private PoolData getPoolData(Map<String, PoolData> poolInfo, String poolPath) { + PoolData poolData = poolInfo.get(poolPath); + if (poolData == null) { + poolData = new PoolData(); + poolInfo.put(poolPath, poolData); + } + return poolData; + } + + private List<String> getResourcePlanErrors(MWMResourcePlan mResourcePlan) { + List<String> errors = new ArrayList<>(); + if (mResourcePlan.getQueryParallelism() != null && mResourcePlan.getQueryParallelism() < 1) { + errors.add("Query parallelism should for resource plan be positive. Got: " + + mResourcePlan.getQueryParallelism()); + } + Map<String, PoolData> poolInfo = new HashMap<>(); + for (MWMPool pool : mResourcePlan.getPools()) { + PoolData currentPoolData = getPoolData(poolInfo, pool.getPath()); + currentPoolData.found = true; + String parent = getParentPath(pool.getPath(), ""); + PoolData parentPoolData = getPoolData(poolInfo, parent); + parentPoolData.hasChildren = true; + parentPoolData.totalChildrenAllocFraction += pool.getAllocFraction(); + if (pool.getQueryParallelism() != null && pool.getQueryParallelism() < 1) { + errors.add("Invalid query parallelism for pool: " + pool.getPath()); + } else { + currentPoolData.queryParallelism = pool.getQueryParallelism(); + parentPoolData.totalChildrenQueryParallelism += pool.getQueryParallelism(); + } + // Check for valid pool.getSchedulingPolicy(); + } + for (Entry<String, PoolData> entry : poolInfo.entrySet()) { + PoolData poolData = entry.getValue(); + // Special case for root parent + if (entry.getKey().equals("")) { + poolData.found = true; + poolData.queryParallelism = mResourcePlan.getQueryParallelism() == null ? + poolData.totalChildrenQueryParallelism : mResourcePlan.getQueryParallelism(); + } + if (!poolData.found) { + errors.add("Pool does not exists but has children: " + entry.getKey()); + } + if (poolData.hasChildren) { + if (Math.abs(1.0 - poolData.totalChildrenAllocFraction) > 0.001) { + errors.add("Sum of children pools' alloc fraction should be equal 1.0 got: " + + poolData.totalChildrenAllocFraction + " for pool: " + entry.getKey()); + } + if (poolData.queryParallelism != poolData.totalChildrenQueryParallelism) { + errors.add("Sum of children pools' query parallelism: " + + poolData.totalChildrenQueryParallelism + " is not equal to pool parallelism: " + + poolData.queryParallelism + " for pool: " + entry.getKey()); + } + } + } + // TODO: validate trigger and action expressions. mResourcePlan.getTriggers() + return errors; } @Override - public boolean validateResourcePlan(String name) + public List<String> validateResourcePlan(String name) throws NoSuchObjectException, InvalidObjectException, MetaException { name = normalizeIdentifier(name); Query query = null; @@ -9852,7 +9914,7 @@ public class ObjectStore implements RawStore, Configurable { throw new NoSuchObjectException("Cannot find resourcePlan: " + name); } // Validate resource plan. - return getResourcePlanErrors(mResourcePlan) == null; // TODO: propagate errors? + return getResourcePlanErrors(mResourcePlan); } finally { rollbackAndCleanup(true, query); } @@ -10107,12 +10169,19 @@ public class ObjectStore implements RawStore, Configurable { } } - private boolean poolParentExists(MWMResourcePlan resourcePlan, String poolPath) { + private String getParentPath(String poolPath, String defValue) { int idx = poolPath.lastIndexOf('.'); if (idx == -1) { + return defValue; + } + return poolPath.substring(0, idx); + } + + private boolean poolParentExists(MWMResourcePlan resourcePlan, String poolPath) { + String parent = getParentPath(poolPath, null); + if (parent == null) { return true; } - String parent = poolPath.substring(0, idx); try { getPool(resourcePlan, parent); return true;
