You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2017/12/06 00:07:32 UTC
[2/8] hive git commit: HIVE-18179 : Implement validate resource plan
(part 1) (Harish Jaiprakash, reviewed by Sergey Shelukhin)
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;