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 2018/01/20 00:11:48 UTC
[2/8] hive git commit: HIVE-18231 : validate resource plan - part 2 -
validate action and trigger expressions (Harish Jaiprakash,
reviewed by Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/90d236af/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 6704d9b..6878ee1 100644
--- a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -23340,6 +23340,10 @@ class WMValidateResourcePlanResponse {
* @var string[]
*/
public $errors = null;
+ /**
+ * @var string[]
+ */
+ public $warnings = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -23352,12 +23356,23 @@ class WMValidateResourcePlanResponse {
'type' => TType::STRING,
),
),
+ 2 => array(
+ 'var' => 'warnings',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['errors'])) {
$this->errors = $vals['errors'];
}
+ if (isset($vals['warnings'])) {
+ $this->warnings = $vals['warnings'];
+ }
}
}
@@ -23397,6 +23412,23 @@ class WMValidateResourcePlanResponse {
$xfer += $input->skip($ftype);
}
break;
+ case 2:
+ if ($ftype == TType::LST) {
+ $this->warnings = array();
+ $_size717 = 0;
+ $_etype720 = 0;
+ $xfer += $input->readListBegin($_etype720, $_size717);
+ for ($_i721 = 0; $_i721 < $_size717; ++$_i721)
+ {
+ $elem722 = null;
+ $xfer += $input->readString($elem722);
+ $this->warnings []= $elem722;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -23418,9 +23450,26 @@ class WMValidateResourcePlanResponse {
{
$output->writeListBegin(TType::STRING, count($this->errors));
{
- foreach ($this->errors as $iter717)
+ foreach ($this->errors as $iter723)
+ {
+ $xfer += $output->writeString($iter723);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->warnings !== null) {
+ if (!is_array($this->warnings)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('warnings', TType::LST, 2);
+ {
+ $output->writeListBegin(TType::STRING, count($this->warnings));
+ {
+ foreach ($this->warnings as $iter724)
{
- $xfer += $output->writeString($iter717);
+ $xfer += $output->writeString($iter724);
}
}
$output->writeListEnd();
@@ -24093,15 +24142,15 @@ class WMGetTriggersForResourePlanResponse {
case 1:
if ($ftype == TType::LST) {
$this->triggers = array();
- $_size718 = 0;
- $_etype721 = 0;
- $xfer += $input->readListBegin($_etype721, $_size718);
- for ($_i722 = 0; $_i722 < $_size718; ++$_i722)
+ $_size725 = 0;
+ $_etype728 = 0;
+ $xfer += $input->readListBegin($_etype728, $_size725);
+ for ($_i729 = 0; $_i729 < $_size725; ++$_i729)
{
- $elem723 = null;
- $elem723 = new \metastore\WMTrigger();
- $xfer += $elem723->read($input);
- $this->triggers []= $elem723;
+ $elem730 = null;
+ $elem730 = new \metastore\WMTrigger();
+ $xfer += $elem730->read($input);
+ $this->triggers []= $elem730;
}
$xfer += $input->readListEnd();
} else {
@@ -24129,9 +24178,9 @@ class WMGetTriggersForResourePlanResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->triggers));
{
- foreach ($this->triggers as $iter724)
+ foreach ($this->triggers as $iter731)
{
- $xfer += $iter724->write($output);
+ $xfer += $iter731->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/90d236af/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 13f77bc..988c01a 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
@@ -13638,10 +13638,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype725, _size722) = iprot.readListBegin()
- for _i726 in xrange(_size722):
- _elem727 = iprot.readString()
- self.success.append(_elem727)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = iprot.readString()
+ self.success.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13664,8 +13664,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 iter728 in self.success:
- oprot.writeString(iter728)
+ for iter735 in self.success:
+ oprot.writeString(iter735)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13770,10 +13770,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype732, _size729) = iprot.readListBegin()
- for _i733 in xrange(_size729):
- _elem734 = iprot.readString()
- self.success.append(_elem734)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = iprot.readString()
+ self.success.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13796,8 +13796,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 iter735 in self.success:
- oprot.writeString(iter735)
+ for iter742 in self.success:
+ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14567,12 +14567,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype737, _vtype738, _size736 ) = iprot.readMapBegin()
- for _i740 in xrange(_size736):
- _key741 = iprot.readString()
- _val742 = Type()
- _val742.read(iprot)
- self.success[_key741] = _val742
+ (_ktype744, _vtype745, _size743 ) = iprot.readMapBegin()
+ for _i747 in xrange(_size743):
+ _key748 = iprot.readString()
+ _val749 = Type()
+ _val749.read(iprot)
+ self.success[_key748] = _val749
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -14595,9 +14595,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 kiter743,viter744 in self.success.items():
- oprot.writeString(kiter743)
- viter744.write(oprot)
+ for kiter750,viter751 in self.success.items():
+ oprot.writeString(kiter750)
+ viter751.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -14740,11 +14740,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype748, _size745) = iprot.readListBegin()
- for _i749 in xrange(_size745):
- _elem750 = FieldSchema()
- _elem750.read(iprot)
- self.success.append(_elem750)
+ (_etype755, _size752) = iprot.readListBegin()
+ for _i756 in xrange(_size752):
+ _elem757 = FieldSchema()
+ _elem757.read(iprot)
+ self.success.append(_elem757)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14779,8 +14779,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 iter751 in self.success:
- iter751.write(oprot)
+ for iter758 in self.success:
+ iter758.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14947,11 +14947,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype755, _size752) = iprot.readListBegin()
- for _i756 in xrange(_size752):
- _elem757 = FieldSchema()
- _elem757.read(iprot)
- self.success.append(_elem757)
+ (_etype762, _size759) = iprot.readListBegin()
+ for _i763 in xrange(_size759):
+ _elem764 = FieldSchema()
+ _elem764.read(iprot)
+ self.success.append(_elem764)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14986,8 +14986,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 iter758 in self.success:
- iter758.write(oprot)
+ for iter765 in self.success:
+ iter765.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15140,11 +15140,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype762, _size759) = iprot.readListBegin()
- for _i763 in xrange(_size759):
- _elem764 = FieldSchema()
- _elem764.read(iprot)
- self.success.append(_elem764)
+ (_etype769, _size766) = iprot.readListBegin()
+ for _i770 in xrange(_size766):
+ _elem771 = FieldSchema()
+ _elem771.read(iprot)
+ self.success.append(_elem771)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15179,8 +15179,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 iter765 in self.success:
- iter765.write(oprot)
+ for iter772 in self.success:
+ iter772.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15347,11 +15347,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype769, _size766) = iprot.readListBegin()
- for _i770 in xrange(_size766):
- _elem771 = FieldSchema()
- _elem771.read(iprot)
- self.success.append(_elem771)
+ (_etype776, _size773) = iprot.readListBegin()
+ for _i777 in xrange(_size773):
+ _elem778 = FieldSchema()
+ _elem778.read(iprot)
+ self.success.append(_elem778)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15386,8 +15386,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 iter772 in self.success:
- iter772.write(oprot)
+ for iter779 in self.success:
+ iter779.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15834,44 +15834,44 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype776, _size773) = iprot.readListBegin()
- for _i777 in xrange(_size773):
- _elem778 = SQLPrimaryKey()
- _elem778.read(iprot)
- self.primaryKeys.append(_elem778)
+ (_etype783, _size780) = iprot.readListBegin()
+ for _i784 in xrange(_size780):
+ _elem785 = SQLPrimaryKey()
+ _elem785.read(iprot)
+ self.primaryKeys.append(_elem785)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype782, _size779) = iprot.readListBegin()
- for _i783 in xrange(_size779):
- _elem784 = SQLForeignKey()
- _elem784.read(iprot)
- self.foreignKeys.append(_elem784)
+ (_etype789, _size786) = iprot.readListBegin()
+ for _i790 in xrange(_size786):
+ _elem791 = SQLForeignKey()
+ _elem791.read(iprot)
+ self.foreignKeys.append(_elem791)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype788, _size785) = iprot.readListBegin()
- for _i789 in xrange(_size785):
- _elem790 = SQLUniqueConstraint()
- _elem790.read(iprot)
- self.uniqueConstraints.append(_elem790)
+ (_etype795, _size792) = iprot.readListBegin()
+ for _i796 in xrange(_size792):
+ _elem797 = SQLUniqueConstraint()
+ _elem797.read(iprot)
+ self.uniqueConstraints.append(_elem797)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype794, _size791) = iprot.readListBegin()
- for _i795 in xrange(_size791):
- _elem796 = SQLNotNullConstraint()
- _elem796.read(iprot)
- self.notNullConstraints.append(_elem796)
+ (_etype801, _size798) = iprot.readListBegin()
+ for _i802 in xrange(_size798):
+ _elem803 = SQLNotNullConstraint()
+ _elem803.read(iprot)
+ self.notNullConstraints.append(_elem803)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15892,29 +15892,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 iter797 in self.primaryKeys:
- iter797.write(oprot)
+ for iter804 in self.primaryKeys:
+ iter804.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 iter798 in self.foreignKeys:
- iter798.write(oprot)
+ for iter805 in self.foreignKeys:
+ iter805.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 iter799 in self.uniqueConstraints:
- iter799.write(oprot)
+ for iter806 in self.uniqueConstraints:
+ iter806.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 iter800 in self.notNullConstraints:
- iter800.write(oprot)
+ for iter807 in self.notNullConstraints:
+ iter807.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17180,10 +17180,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype804, _size801) = iprot.readListBegin()
- for _i805 in xrange(_size801):
- _elem806 = iprot.readString()
- self.partNames.append(_elem806)
+ (_etype811, _size808) = iprot.readListBegin()
+ for _i812 in xrange(_size808):
+ _elem813 = iprot.readString()
+ self.partNames.append(_elem813)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17208,8 +17208,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 iter807 in self.partNames:
- oprot.writeString(iter807)
+ for iter814 in self.partNames:
+ oprot.writeString(iter814)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17409,10 +17409,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype811, _size808) = iprot.readListBegin()
- for _i812 in xrange(_size808):
- _elem813 = iprot.readString()
- self.success.append(_elem813)
+ (_etype818, _size815) = iprot.readListBegin()
+ for _i819 in xrange(_size815):
+ _elem820 = iprot.readString()
+ self.success.append(_elem820)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17435,8 +17435,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 iter814 in self.success:
- oprot.writeString(iter814)
+ for iter821 in self.success:
+ oprot.writeString(iter821)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17586,10 +17586,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype818, _size815) = iprot.readListBegin()
- for _i819 in xrange(_size815):
- _elem820 = iprot.readString()
- self.success.append(_elem820)
+ (_etype825, _size822) = iprot.readListBegin()
+ for _i826 in xrange(_size822):
+ _elem827 = iprot.readString()
+ self.success.append(_elem827)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17612,8 +17612,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 iter821 in self.success:
- oprot.writeString(iter821)
+ for iter828 in self.success:
+ oprot.writeString(iter828)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17737,10 +17737,10 @@ class get_materialized_views_for_rewriting_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype825, _size822) = iprot.readListBegin()
- for _i826 in xrange(_size822):
- _elem827 = iprot.readString()
- self.success.append(_elem827)
+ (_etype832, _size829) = iprot.readListBegin()
+ for _i833 in xrange(_size829):
+ _elem834 = iprot.readString()
+ self.success.append(_elem834)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17763,8 +17763,8 @@ class get_materialized_views_for_rewriting_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter828 in self.success:
- oprot.writeString(iter828)
+ for iter835 in self.success:
+ oprot.writeString(iter835)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17837,10 +17837,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype832, _size829) = iprot.readListBegin()
- for _i833 in xrange(_size829):
- _elem834 = iprot.readString()
- self.tbl_types.append(_elem834)
+ (_etype839, _size836) = iprot.readListBegin()
+ for _i840 in xrange(_size836):
+ _elem841 = iprot.readString()
+ self.tbl_types.append(_elem841)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17865,8 +17865,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 iter835 in self.tbl_types:
- oprot.writeString(iter835)
+ for iter842 in self.tbl_types:
+ oprot.writeString(iter842)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17922,11 +17922,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype839, _size836) = iprot.readListBegin()
- for _i840 in xrange(_size836):
- _elem841 = TableMeta()
- _elem841.read(iprot)
- self.success.append(_elem841)
+ (_etype846, _size843) = iprot.readListBegin()
+ for _i847 in xrange(_size843):
+ _elem848 = TableMeta()
+ _elem848.read(iprot)
+ self.success.append(_elem848)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17949,8 +17949,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 iter842 in self.success:
- iter842.write(oprot)
+ for iter849 in self.success:
+ iter849.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18074,10 +18074,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype846, _size843) = iprot.readListBegin()
- for _i847 in xrange(_size843):
- _elem848 = iprot.readString()
- self.success.append(_elem848)
+ (_etype853, _size850) = iprot.readListBegin()
+ for _i854 in xrange(_size850):
+ _elem855 = iprot.readString()
+ self.success.append(_elem855)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18100,8 +18100,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 iter849 in self.success:
- oprot.writeString(iter849)
+ for iter856 in self.success:
+ oprot.writeString(iter856)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18337,10 +18337,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype853, _size850) = iprot.readListBegin()
- for _i854 in xrange(_size850):
- _elem855 = iprot.readString()
- self.tbl_names.append(_elem855)
+ (_etype860, _size857) = iprot.readListBegin()
+ for _i861 in xrange(_size857):
+ _elem862 = iprot.readString()
+ self.tbl_names.append(_elem862)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18361,8 +18361,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 iter856 in self.tbl_names:
- oprot.writeString(iter856)
+ for iter863 in self.tbl_names:
+ oprot.writeString(iter863)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18414,11 +18414,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype860, _size857) = iprot.readListBegin()
- for _i861 in xrange(_size857):
- _elem862 = Table()
- _elem862.read(iprot)
- self.success.append(_elem862)
+ (_etype867, _size864) = iprot.readListBegin()
+ for _i868 in xrange(_size864):
+ _elem869 = Table()
+ _elem869.read(iprot)
+ self.success.append(_elem869)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18435,8 +18435,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 iter863 in self.success:
- iter863.write(oprot)
+ for iter870 in self.success:
+ iter870.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18828,10 +18828,10 @@ class get_materialization_invalidation_info_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype867, _size864) = iprot.readListBegin()
- for _i868 in xrange(_size864):
- _elem869 = iprot.readString()
- self.tbl_names.append(_elem869)
+ (_etype874, _size871) = iprot.readListBegin()
+ for _i875 in xrange(_size871):
+ _elem876 = iprot.readString()
+ self.tbl_names.append(_elem876)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18852,8 +18852,8 @@ class get_materialization_invalidation_info_args:
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter870 in self.tbl_names:
- oprot.writeString(iter870)
+ for iter877 in self.tbl_names:
+ oprot.writeString(iter877)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18914,12 +18914,12 @@ class get_materialization_invalidation_info_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype872, _vtype873, _size871 ) = iprot.readMapBegin()
- for _i875 in xrange(_size871):
- _key876 = iprot.readString()
- _val877 = Materialization()
- _val877.read(iprot)
- self.success[_key876] = _val877
+ (_ktype879, _vtype880, _size878 ) = iprot.readMapBegin()
+ for _i882 in xrange(_size878):
+ _key883 = iprot.readString()
+ _val884 = Materialization()
+ _val884.read(iprot)
+ self.success[_key883] = _val884
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -18954,9 +18954,9 @@ class get_materialization_invalidation_info_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter878,viter879 in self.success.items():
- oprot.writeString(kiter878)
- viter879.write(oprot)
+ for kiter885,viter886 in self.success.items():
+ oprot.writeString(kiter885)
+ viter886.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19122,10 +19122,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype883, _size880) = iprot.readListBegin()
- for _i884 in xrange(_size880):
- _elem885 = iprot.readString()
- self.success.append(_elem885)
+ (_etype890, _size887) = iprot.readListBegin()
+ for _i891 in xrange(_size887):
+ _elem892 = iprot.readString()
+ self.success.append(_elem892)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19160,8 +19160,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 iter886 in self.success:
- oprot.writeString(iter886)
+ for iter893 in self.success:
+ oprot.writeString(iter893)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20131,11 +20131,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype890, _size887) = iprot.readListBegin()
- for _i891 in xrange(_size887):
- _elem892 = Partition()
- _elem892.read(iprot)
- self.new_parts.append(_elem892)
+ (_etype897, _size894) = iprot.readListBegin()
+ for _i898 in xrange(_size894):
+ _elem899 = Partition()
+ _elem899.read(iprot)
+ self.new_parts.append(_elem899)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20152,8 +20152,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 iter893 in self.new_parts:
- iter893.write(oprot)
+ for iter900 in self.new_parts:
+ iter900.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20311,11 +20311,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype897, _size894) = iprot.readListBegin()
- for _i898 in xrange(_size894):
- _elem899 = PartitionSpec()
- _elem899.read(iprot)
- self.new_parts.append(_elem899)
+ (_etype904, _size901) = iprot.readListBegin()
+ for _i905 in xrange(_size901):
+ _elem906 = PartitionSpec()
+ _elem906.read(iprot)
+ self.new_parts.append(_elem906)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20332,8 +20332,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 iter900 in self.new_parts:
- iter900.write(oprot)
+ for iter907 in self.new_parts:
+ iter907.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20507,10 +20507,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype904, _size901) = iprot.readListBegin()
- for _i905 in xrange(_size901):
- _elem906 = iprot.readString()
- self.part_vals.append(_elem906)
+ (_etype911, _size908) = iprot.readListBegin()
+ for _i912 in xrange(_size908):
+ _elem913 = iprot.readString()
+ self.part_vals.append(_elem913)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20535,8 +20535,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 iter907 in self.part_vals:
- oprot.writeString(iter907)
+ for iter914 in self.part_vals:
+ oprot.writeString(iter914)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20889,10 +20889,10 @@ class append_partition_with_environment_context_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)
@@ -20923,8 +20923,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 iter914 in self.part_vals:
- oprot.writeString(iter914)
+ for iter921 in self.part_vals:
+ oprot.writeString(iter921)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -21519,10 +21519,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype918, _size915) = iprot.readListBegin()
- for _i919 in xrange(_size915):
- _elem920 = iprot.readString()
- self.part_vals.append(_elem920)
+ (_etype925, _size922) = iprot.readListBegin()
+ for _i926 in xrange(_size922):
+ _elem927 = iprot.readString()
+ self.part_vals.append(_elem927)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21552,8 +21552,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 iter921 in self.part_vals:
- oprot.writeString(iter921)
+ for iter928 in self.part_vals:
+ oprot.writeString(iter928)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -21726,10 +21726,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype925, _size922) = iprot.readListBegin()
- for _i926 in xrange(_size922):
- _elem927 = iprot.readString()
- self.part_vals.append(_elem927)
+ (_etype932, _size929) = iprot.readListBegin()
+ for _i933 in xrange(_size929):
+ _elem934 = iprot.readString()
+ self.part_vals.append(_elem934)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21765,8 +21765,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 iter928 in self.part_vals:
- oprot.writeString(iter928)
+ for iter935 in self.part_vals:
+ oprot.writeString(iter935)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -22503,10 +22503,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype932, _size929) = iprot.readListBegin()
- for _i933 in xrange(_size929):
- _elem934 = iprot.readString()
- self.part_vals.append(_elem934)
+ (_etype939, _size936) = iprot.readListBegin()
+ for _i940 in xrange(_size936):
+ _elem941 = iprot.readString()
+ self.part_vals.append(_elem941)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22531,8 +22531,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 iter935 in self.part_vals:
- oprot.writeString(iter935)
+ for iter942 in self.part_vals:
+ oprot.writeString(iter942)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22691,11 +22691,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype937, _vtype938, _size936 ) = iprot.readMapBegin()
- for _i940 in xrange(_size936):
- _key941 = iprot.readString()
- _val942 = iprot.readString()
- self.partitionSpecs[_key941] = _val942
+ (_ktype944, _vtype945, _size943 ) = iprot.readMapBegin()
+ for _i947 in xrange(_size943):
+ _key948 = iprot.readString()
+ _val949 = iprot.readString()
+ self.partitionSpecs[_key948] = _val949
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -22732,9 +22732,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 kiter943,viter944 in self.partitionSpecs.items():
- oprot.writeString(kiter943)
- oprot.writeString(viter944)
+ for kiter950,viter951 in self.partitionSpecs.items():
+ oprot.writeString(kiter950)
+ oprot.writeString(viter951)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -22939,11 +22939,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype946, _vtype947, _size945 ) = iprot.readMapBegin()
- for _i949 in xrange(_size945):
- _key950 = iprot.readString()
- _val951 = iprot.readString()
- self.partitionSpecs[_key950] = _val951
+ (_ktype953, _vtype954, _size952 ) = iprot.readMapBegin()
+ for _i956 in xrange(_size952):
+ _key957 = iprot.readString()
+ _val958 = iprot.readString()
+ self.partitionSpecs[_key957] = _val958
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -22980,9 +22980,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 kiter952,viter953 in self.partitionSpecs.items():
- oprot.writeString(kiter952)
- oprot.writeString(viter953)
+ for kiter959,viter960 in self.partitionSpecs.items():
+ oprot.writeString(kiter959)
+ oprot.writeString(viter960)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -23065,11 +23065,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype957, _size954) = iprot.readListBegin()
- for _i958 in xrange(_size954):
- _elem959 = Partition()
- _elem959.read(iprot)
- self.success.append(_elem959)
+ (_etype964, _size961) = iprot.readListBegin()
+ for _i965 in xrange(_size961):
+ _elem966 = Partition()
+ _elem966.read(iprot)
+ self.success.append(_elem966)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23110,8 +23110,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 iter960 in self.success:
- iter960.write(oprot)
+ for iter967 in self.success:
+ iter967.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23205,10 +23205,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype964, _size961) = iprot.readListBegin()
- for _i965 in xrange(_size961):
- _elem966 = iprot.readString()
- self.part_vals.append(_elem966)
+ (_etype971, _size968) = iprot.readListBegin()
+ for _i972 in xrange(_size968):
+ _elem973 = iprot.readString()
+ self.part_vals.append(_elem973)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23220,10 +23220,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype970, _size967) = iprot.readListBegin()
- for _i971 in xrange(_size967):
- _elem972 = iprot.readString()
- self.group_names.append(_elem972)
+ (_etype977, _size974) = iprot.readListBegin()
+ for _i978 in xrange(_size974):
+ _elem979 = iprot.readString()
+ self.group_names.append(_elem979)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23248,8 +23248,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 iter973 in self.part_vals:
- oprot.writeString(iter973)
+ for iter980 in self.part_vals:
+ oprot.writeString(iter980)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -23259,8 +23259,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 iter974 in self.group_names:
- oprot.writeString(iter974)
+ for iter981 in self.group_names:
+ oprot.writeString(iter981)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23689,11 +23689,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype978, _size975) = iprot.readListBegin()
- for _i979 in xrange(_size975):
- _elem980 = Partition()
- _elem980.read(iprot)
- self.success.append(_elem980)
+ (_etype985, _size982) = iprot.readListBegin()
+ for _i986 in xrange(_size982):
+ _elem987 = Partition()
+ _elem987.read(iprot)
+ self.success.append(_elem987)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23722,8 +23722,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 iter981 in self.success:
- iter981.write(oprot)
+ for iter988 in self.success:
+ iter988.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23817,10 +23817,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype985, _size982) = iprot.readListBegin()
- for _i986 in xrange(_size982):
- _elem987 = iprot.readString()
- self.group_names.append(_elem987)
+ (_etype992, _size989) = iprot.readListBegin()
+ for _i993 in xrange(_size989):
+ _elem994 = iprot.readString()
+ self.group_names.append(_elem994)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23853,8 +23853,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 iter988 in self.group_names:
- oprot.writeString(iter988)
+ for iter995 in self.group_names:
+ oprot.writeString(iter995)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23915,11 +23915,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype992, _size989) = iprot.readListBegin()
- for _i993 in xrange(_size989):
- _elem994 = Partition()
- _elem994.read(iprot)
- self.success.append(_elem994)
+ (_etype999, _size996) = iprot.readListBegin()
+ for _i1000 in xrange(_size996):
+ _elem1001 = Partition()
+ _elem1001.read(iprot)
+ self.success.append(_elem1001)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23948,8 +23948,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 iter995 in self.success:
- iter995.write(oprot)
+ for iter1002 in self.success:
+ iter1002.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24107,11 +24107,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype999, _size996) = iprot.readListBegin()
- for _i1000 in xrange(_size996):
- _elem1001 = PartitionSpec()
- _elem1001.read(iprot)
- self.success.append(_elem1001)
+ (_etype1006, _size1003) = iprot.readListBegin()
+ for _i1007 in xrange(_size1003):
+ _elem1008 = PartitionSpec()
+ _elem1008.read(iprot)
+ self.success.append(_elem1008)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24140,8 +24140,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 iter1002 in self.success:
- iter1002.write(oprot)
+ for iter1009 in self.success:
+ iter1009.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24299,10 +24299,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1006, _size1003) = iprot.readListBegin()
- for _i1007 in xrange(_size1003):
- _elem1008 = iprot.readString()
- self.success.append(_elem1008)
+ (_etype1013, _size1010) = iprot.readListBegin()
+ for _i1014 in xrange(_size1010):
+ _elem1015 = iprot.readString()
+ self.success.append(_elem1015)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24331,8 +24331,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 iter1009 in self.success:
- oprot.writeString(iter1009)
+ for iter1016 in self.success:
+ oprot.writeString(iter1016)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24572,10 +24572,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1013, _size1010) = iprot.readListBegin()
- for _i1014 in xrange(_size1010):
- _elem1015 = iprot.readString()
- self.part_vals.append(_elem1015)
+ (_etype1020, _size1017) = iprot.readListBegin()
+ for _i1021 in xrange(_size1017):
+ _elem1022 = iprot.readString()
+ self.part_vals.append(_elem1022)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24605,8 +24605,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 iter1016 in self.part_vals:
- oprot.writeString(iter1016)
+ for iter1023 in self.part_vals:
+ oprot.writeString(iter1023)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -24670,11 +24670,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1020, _size1017) = iprot.readListBegin()
- for _i1021 in xrange(_size1017):
- _elem1022 = Partition()
- _elem1022.read(iprot)
- self.success.append(_elem1022)
+ (_etype1027, _size1024) = iprot.readListBegin()
+ for _i1028 in xrange(_size1024):
+ _elem1029 = Partition()
+ _elem1029.read(iprot)
+ self.success.append(_elem1029)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24703,8 +24703,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 iter1023 in self.success:
- iter1023.write(oprot)
+ for iter1030 in self.success:
+ iter1030.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24791,10 +24791,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1027, _size1024) = iprot.readListBegin()
- for _i1028 in xrange(_size1024):
- _elem1029 = iprot.readString()
- self.part_vals.append(_elem1029)
+ (_etype1034, _size1031) = iprot.readListBegin()
+ for _i1035 in xrange(_size1031):
+ _elem1036 = iprot.readString()
+ self.part_vals.append(_elem1036)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24811,10 +24811,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype1033, _size1030) = iprot.readListBegin()
- for _i1034 in xrange(_size1030):
- _elem1035 = iprot.readString()
- self.group_names.append(_elem1035)
+ (_etype1040, _size1037) = iprot.readListBegin()
+ for _i1041 in xrange(_size1037):
+ _elem1042 = iprot.readString()
+ self.group_names.append(_elem1042)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24839,8 +24839,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 iter1036 in self.part_vals:
- oprot.writeString(iter1036)
+ for iter1043 in self.part_vals:
+ oprot.writeString(iter1043)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -24854,8 +24854,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 iter1037 in self.group_names:
- oprot.writeString(iter1037)
+ for iter1044 in self.group_names:
+ oprot.writeString(iter1044)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24917,11 +24917,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1041, _size1038) = iprot.readListBegin()
- for _i1042 in xrange(_size1038):
- _elem1043 = Partition()
- _elem1043.read(iprot)
- self.success.append(_elem1043)
+ (_etype1048, _size1045) = iprot.readListBegin()
+ for _i1049 in xrange(_size1045):
+ _elem1050 = Partition()
+ _elem1050.read(iprot)
+ self.success.append(_elem1050)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24950,8 +24950,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 iter1044 in self.success:
- iter1044.write(oprot)
+ for iter1051 in self.success:
+ iter1051.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25032,10 +25032,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1048, _size1045) = iprot.readListBegin()
- for _i1049 in xrange(_size1045):
- _elem1050 = iprot.readString()
- self.part_vals.append(_elem1050)
+ (_etype1055, _size1052) = iprot.readListBegin()
+ for _i1056 in xrange(_size1052):
+ _elem1057 = iprot.readString()
+ self.part_vals.append(_elem1057)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25065,8 +25065,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 iter1051 in self.part_vals:
- oprot.writeString(iter1051)
+ for iter1058 in self.part_vals:
+ oprot.writeString(iter1058)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -25130,10 +25130,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1055, _size1052) = iprot.readListBegin()
- for _i1056 in xrange(_size1052):
- _elem1057 = iprot.readString()
- self.success.append(_elem1057)
+ (_etype1062, _size1059) = iprot.readListBegin()
+ for _i1063 in xrange(_size1059):
+ _elem1064 = iprot.readString()
+ self.success.append(_elem1064)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25162,8 +25162,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 iter1058 in self.success:
- oprot.writeString(iter1058)
+ for iter1065 in self.success:
+ oprot.writeString(iter1065)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25334,11 +25334,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1062, _size1059) = iprot.readListBegin()
- for _i1063 in xrange(_size1059):
- _elem1064 = Partition()
- _elem1064.read(iprot)
- self.success.append(_elem1064)
+ (_etype1069, _size1066) = iprot.readListBegin()
+ for _i1070 in xrange(_size1066):
+ _elem1071 = Partition()
+ _elem1071.read(iprot)
+ self.success.append(_elem1071)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25367,8 +25367,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 iter1065 in self.success:
- iter1065.write(oprot)
+ for iter1072 in self.success:
+ iter1072.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25539,11 +25539,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1069, _size1066) = iprot.readListBegin()
- for _i1070 in xrange(_size1066):
- _elem1071 = PartitionSpec()
- _elem1071.read(iprot)
- self.success.append(_elem1071)
+ (_etype1076, _size1073) = iprot.readListBegin()
+ for _i1077 in xrange(_size1073):
+ _elem1078 = PartitionSpec()
+ _elem1078.read(iprot)
+ self.success.append(_elem1078)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25572,8 +25572,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 iter1072 in self.success:
- iter1072.write(oprot)
+ for iter1079 in self.success:
+ iter1079.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25993,10 +25993,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype1076, _size1073) = iprot.readListBegin()
- for _i1077 in xrange(_size1073):
- _elem1078 = iprot.readString()
- self.names.append(_elem1078)
+ (_etype1083, _size1080) = iprot.readListBegin()
+ for _i1084 in xrange(_size1080):
+ _elem1085 = iprot.readString()
+ self.names.append(_elem1085)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26021,8 +26021,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 iter1079 in self.names:
- oprot.writeString(iter1079)
+ for iter1086 in self.names:
+ oprot.writeString(iter1086)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26081,11 +26081,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1083, _size1080) = iprot.readListBegin()
- for _i1084 in xrange(_size1080):
- _elem1085 = Partition()
- _elem1085.read(iprot)
- self.success.append(_elem1085)
+ (_etype1090, _size1087) = iprot.readListBegin()
+ for _i1091 in xrange(_size1087):
+ _elem1092 = Partition()
+ _elem1092.read(iprot)
+ self.success.append(_elem1092)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26114,8 +26114,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 iter1086 in self.success:
- iter1086.write(oprot)
+ for iter1093 in self.success:
+ iter1093.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26365,11 +26365,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1090, _size1087) = iprot.readListBegin()
- for _i1091 in xrange(_size1087):
- _elem1092 = Partition()
- _elem1092.read(iprot)
- self.new_parts.append(_elem1092)
+ (_etype1097, _size1094) = iprot.readListBegin()
+ for _i1098 in xrange(_size1094):
+ _elem1099 = Partition()
+ _elem1099.read(iprot)
+ self.new_parts.append(_elem1099)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26394,8 +26394,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 iter1093 in self.new_parts:
- iter1093.write(oprot)
+ for iter1100 in self.new_parts:
+ iter1100.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26548,11 +26548,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1097, _size1094) = iprot.readListBegin()
- for _i1098 in xrange(_size1094):
- _elem1099 = Partition()
- _elem1099.read(iprot)
- self.new_parts.append(_elem1099)
+ (_etype1104, _size1101) = iprot.readListBegin()
+ for _i1105 in xrange(_size1101):
+ _elem1106 = Partition()
+ _elem1106.read(iprot)
+ self.new_parts.append(_elem1106)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26583,8 +26583,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 iter1100 in self.new_parts:
- iter1100.write(oprot)
+ for iter1107 in self.new_parts:
+ iter1107.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -26928,10 +26928,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1104, _size1101) = iprot.readListBegin()
- for _i1105 in xrange(_size1101):
- _elem1106 = iprot.readString()
- self.part_vals.append(_elem1106)
+ (_etype1111, _size1108) = iprot.readListBegin()
+ for _i1112 in xrange(_size1108):
+ _elem1113 = iprot.readString()
+ self.part_vals.append(_elem1113)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26962,8 +26962,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 iter1107 in self.part_vals:
- oprot.writeString(iter1107)
+ for iter1114 in self.part_vals:
+ oprot.writeString(iter1114)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -27105,10 +27105,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1111, _size1108) = iprot.readListBegin()
- for _i1112 in xrange(_size1108):
- _elem1113 = iprot.readString()
- self.part_vals.append(_elem1113)
+ (_etype1118, _size1115) = iprot.readListBegin()
+ for _i1119 in xrange(_size1115):
+ _elem1120 = iprot.readString()
+ self.part_vals.append(_elem1120)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27130,8 +27130,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 iter1114 in self.part_vals:
- oprot.writeString(iter1114)
+ for iter1121 in self.part_vals:
+ oprot.writeString(iter1121)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -27489,10 +27489,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1118, _size1115) = iprot.readListBegin()
- for _i1119 in xrange(_size1115):
- _elem1120 = iprot.readString()
- self.success.append(_elem1120)
+ (_etype1125, _size1122) = iprot.readListBegin()
+ for _i1126 in xrange(_size1122):
+ _elem1127 = iprot.readString()
+ self.success.append(_elem1127)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27515,8 +27515,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 iter1121 in self.success:
- oprot.writeString(iter1121)
+ for iter1128 in self.success:
+ oprot.writeString(iter1128)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27640,11 +27640,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1123, _vtype1124, _size1122 ) = iprot.readMapBegin()
- for _i1126 in xrange(_size1122):
- _key1127 = iprot.readString()
- _val1128 = iprot.readString()
- self.success[_key1127] = _val1128
+ (_ktype1130, _vtype1131, _size1129 ) = iprot.readMapBegin()
+ for _i1133 in xrange(_size1129):
+ _key1134 = iprot.readString()
+ _val1135 = iprot.readString()
+ self.success[_key1134] = _val1135
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -27667,9 +27667,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 kiter1129,viter1130 in self.success.items():
- oprot.writeString(kiter1129)
- oprot.writeString(viter1130)
+ for kiter1136,viter1137 in self.success.items():
+ oprot.writeString(kiter1136)
+ oprot.writeString(viter1137)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27745,11 +27745,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1132, _vtype1133, _size1131 ) = iprot.readMapBegin()
- for _i1135 in xrange(_size1131):
- _key1136 = iprot.readString()
- _val1137 = iprot.readString()
- self.part_vals[_key1136] = _val1137
+ (_ktype1139, _vtype1140, _size1138 ) = iprot.readMapBegin()
+ for _i1142 in xrange(_size1138):
+ _key1143 = iprot.readString()
+ _val1144 = iprot.readString()
+ self.part_vals[_key1143] = _val1144
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -27779,9 +27779,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 kiter1138,viter1139 in self.part_vals.items():
- oprot.writeString(kiter1138)
- oprot.writeString(viter1139)
+ for kiter1145,viter1146 in self.part_vals.items():
+ oprot.writeString(kiter1145)
+ oprot.writeString(viter1146)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -27995,11 +27995,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1141, _vtype1142, _size1140 ) = iprot.readMapBegin()
- for _i1144 in xrange(_size1140):
- _key1145 = iprot.readString()
- _val1146 = iprot.readString()
- self.part_vals[_key1145] = _val1146
+ (_ktype1148, _vtype1149, _size1147 ) = iprot.readMapBegin()
+ for _i1151 in xrange(_size1147):
+ _key1152 = iprot.readString()
+ _val1153 = iprot.readString()
+ self.part_vals[_key1152] = _val1153
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -28029,9 +28029,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 kiter1147,viter1148 in self.part_vals.items():
- oprot.writeString(kiter1147)
- oprot.writeString(viter1148)
+ for kiter1154,viter1155 in self.part_vals.items():
+ oprot.writeString(kiter1154)
+ oprot.writeString(viter1155)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -29086,11 +29086,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1152, _size1149) = iprot.readListBegin()
- for _i1153 in xrange(_size1149):
- _elem1154 = Index()
- _elem1154.read(iprot)
- self.success.append(_elem1154)
+ (_etype1159, _size1156) = iprot.readListBegin()
+ for _i1160 in xrange(_size1156):
+ _elem1161 = Index()
+ _elem1161.read(iprot)
+ self.success.append(_elem1161)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29119,8 +29119,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 iter1155 in self.success:
- iter1155.write(oprot)
+ for iter1162 in self.success:
+ iter1162.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29275,10 +29275,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1159, _size1156) = iprot.readListBegin()
- for _i1160 in xrange(_size1156):
- _elem1161 = iprot.readString()
- self.success.append(_elem1161)
+ (_etype1166, _size1163) = iprot.readListBegin()
+ for _i1167 in xrange(_size1163):
+ _elem1168 = iprot.readString()
+ self.success.append(_elem1168)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29301,8 +29301,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 iter1162 in self.success:
- oprot.writeString(iter1162)
+ for iter1169 in self.success:
+ oprot.writeString(iter1169)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -32486,10 +32486,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1166, _size1163) = iprot.readListBegin()
- for _i1167 in xrange(_size1163):
- _elem1168 = iprot.readString()
- self.success.append(_elem1168)
+ (_etype1173, _size1170) = iprot.readListBegin()
+ for _i1174 in xrange(_size1170):
+ _elem1175 = iprot.readString()
+ self.success.append(_elem1175)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32512,8 +32512,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 iter1169 in self.success:
- oprot.writeString(iter1169)
+ for iter1176 in self.success:
+ oprot.writeString(iter1176)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -33201,10 +33201,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1173, _size1170) = iprot.readListBegin()
- for _i1174 in xrange(_size1170):
- _elem1175 = iprot.readString()
- self.success.append(_elem1175)
+ (_etype1180, _size1177) = iprot.readListBegin()
+ for _i1181 in xrange(_size1177):
+ _elem1182 = iprot.readString()
+ self.success.append(_elem1182)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33227,8 +33227,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 iter1176 in self.success:
- oprot.writeString(iter1176)
+ for iter1183 in self.success:
+ oprot.writeString(iter1183)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -33742,11 +33742,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1180, _size1177) = iprot.readListBegin()
- for _i1181 in xrange(_size1177):
- _elem1182 = Role()
- _elem1182.read(iprot)
- self.success.append(_elem1182)
+ (_etype1187, _size1184) = iprot.readListBegin()
+ for _i1188 in xrange(_size1184):
+ _elem1189 = Role()
+ _elem1189.read(iprot)
+ self.success.append(_elem1189)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33769,8 +33769,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 iter1183 in self.success:
- iter1183.write(oprot)
+ for iter1190 in self.success:
+ iter1190.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -34279,10 +34279,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1187, _size1184) = iprot.readListBegin()
- for _i1188 in xrange(_size1184):
- _elem1189 = iprot.readString()
- self.group_names.append(_elem1189)
+ (_etype1194, _size1191) = iprot.readListBegin()
+ for _i1195 in xrange(_size1191):
+ _elem1196 = iprot.readString()
+ self.group_names.append(_elem1196)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34307,8 +34307,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 iter1190 in self.group_names:
- oprot.writeString(iter1190)
+ for iter1197 in self.group_names:
+ oprot.writeString(iter1197)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -34535,11 +34535,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1194, _size1191) = iprot.readListBegin()
- for _i1195 in xrange(_size1191):
- _elem1196 = HiveObjectPrivilege()
- _elem1196.read(iprot)
- self.success.append(_elem1196)
+ (_etype1201, _size1198) = iprot.readListBegin()
+ for _i1202 in xrange(_size1198):
+ _elem1203 = HiveObjectPrivilege()
+ _elem1203.read(iprot)
+ self.success.append(_elem1203)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34562,8 +34562,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 iter1197 in self.success:
- iter1197.write(oprot)
+ for iter1204 in self.success:
+ iter1204.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35061,10 +35061,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1201, _size1198) = iprot.readListBegin()
- for _i1202 in xrange(_size1198):
- _elem1203 = iprot.readString()
- self.group_names.append(_elem1203)
+ (_etype1208, _size1205) = iprot.readListBegin()
+ for _i1209 in xrange(_size1205):
+ _elem1210 = iprot.readString()
+ self.group_names.append(_elem1210)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35085,8 +35085,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 iter1204 in self.group_names:
- oprot.writeString(iter1204)
+ for iter1211 in self.group_names:
+ oprot.writeString(iter1211)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -35141,10 +35141,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1208, _size1205) = iprot.readListBegin()
- for _i1209 in xrange(_size1205):
- _elem1210 = iprot.readString()
- self.success.append(_elem1210)
+ (_etype1215, _size1212) = iprot.readListBegin()
+ for _i1216 in xrange(_size1212):
+ _elem1217 = iprot.readString()
+ self.success.append(_elem1217)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35167,8 +35167,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 iter1211 in self.success:
- oprot.writeString(iter1211)
+ for iter1218 in self.success:
+ oprot.writeString(iter1218)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -36100,10 +36100,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1215, _size1212) = iprot.readListBegin()
- for _i1216 in xrange(_size1212):
- _elem1217 = iprot.readString()
- self.success.append(_elem1217)
+ (_etype1222, _size1219) = iprot.readListBegin()
+ for _i1223 in xrange(_size1219):
+ _elem1224 = iprot.readString()
+ self.success.append(_elem1224)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36120,8 +36120,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 iter1218 in self.success:
- oprot.writeString(iter1218)
+ for iter1225 in self.success:
+ oprot.writeString(iter1225)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -36648,10 +36648,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1222, _size1219) = iprot.readListBegin()
- for _i1223 in xrange(_size1219):
- _elem1224 = iprot.readString()
- self.success.append(_elem1224)
+ (_etype1229, _size1226) = iprot.readListBegin()
+ for _i1230 in xrange(_size1226):
+ _elem1231 = iprot.readString()
+ self.success.append(_elem1231)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36668,8 +36668,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 iter1225 in self.success:
- oprot.writeString(iter1225)
+ for iter1232 in self.success:
+ oprot.writeString(iter1232)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -38910,20 +38910,20 @@ class get_last_completed_transaction_for_tables_args:
if fid == 1:
if ftype == TType.LIST:
self.db_names = []
- (_etype1229, _size1226) = iprot.readListBegin()
- for _i1230 in xrange(_size1226):
- _elem1231 = iprot.readString()
- self.db_names.append(_elem1231)
+ (_etype1236, _size1233) = iprot.readListBegin()
+ for _i1237 in xrange(_size1233):
+ _elem1238 = iprot.readString()
+ self.db_names.append(_elem1238)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.LIST:
self.table_names = []
- (_etype1235, _size1232) = iprot.readListBegin()
- for _i1236 in xrange(_size1232):
- _elem1237 = iprot.readString()
- self.table_names.append(_elem1237)
+ (_etype1242, _size1239) = iprot.readListBegin()
+ for _i1243 in xrange(_size1239):
+ _elem1244 = iprot.readString()
+ self.table_names.append(_elem1244)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38946,15 +38946,15 @@ class get_last_completed_transaction_for_tables_args:
if self.db_names is not None:
oprot.writeFieldBegin('db_names', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.db_names))
- for iter1238 in self.db_names:
- oprot.writeString(iter1238)
+ for iter1245 in self.db_names:
+ oprot.writeString(iter1245)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.table_names is not None:
oprot.writeFieldBegin('table_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.table_names))
- for iter1239 in self.table_names:
- oprot.writeString(iter1239)
+ for iter1246 in self.table_names:
+ oprot.writeString(iter1246)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.txns_snapshot is not None:
@@ -39011,11 +39011,11 @@ class get_last_completed_transaction_for_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1243, _size1240) = iprot.readListBegin()
- for _i1244 in xrange(_size1240):
- _elem1245 = BasicTxnInfo()
- _elem1245.read(iprot)
- self.success.append(_elem1245)
+ (_etype1250, _size1247) = iprot.readListBegin()
+ for _i1251 in xrange(_size1247):
+ _elem1252 = BasicTxnInfo()
+ _elem1252.read(iprot)
+ self.success.append(_elem1252)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -39032,8 +39032,8 @@ class get_last_completed_transaction_for_tables_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1246 in self.success:
- iter1246.write(oprot)
+ for iter1253 in self.success:
+ iter1253.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
http://git-wip-us.apache.org/repos/asf/hive/blob/90d236af/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 c3be4c4..25e9a88 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
@@ -16520,15 +16520,18 @@ class WMValidateResourcePlanResponse:
"""
Attributes:
- errors
+ - warnings
"""
thrift_spec = (
None, # 0
(1, TType.LIST, 'errors', (TType.STRING,None), None, ), # 1
+ (2, TType.LIST, 'warnings', (TType.STRING,None), None, ), # 2
)
- def __init__(self, errors=None,):
+ def __init__(self, errors=None, warnings=None,):
self.errors = errors
+ self.warnings = warnings
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:
@@ -16549,6 +16552,16 @@ class WMValidateResourcePlanResponse:
iprot.readListEnd()
else:
iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.LIST:
+ self.warnings = []
+ (_etype717, _size714) = iprot.readListBegin()
+ for _i718 in xrange(_size714):
+ _elem719 = iprot.readString()
+ self.warnings.append(_elem719)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -16562,8 +16575,15 @@ class WMValidateResourcePlanResponse:
if self.errors is not None:
oprot.writeFieldBegin('errors', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.errors))
- for iter714 in self.errors:
- oprot.writeString(iter714)
+ for iter720 in self.errors:
+ oprot.writeString(iter720)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.warnings is not None:
+ oprot.writeFieldBegin('warnings', TType.LIST, 2)
+ oprot.writeListBegin(TType.STRING, len(self.warnings))
+ for iter721 in self.warnings:
+ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16576,6 +16596,7 @@ class WMValidateResourcePlanResponse:
def __hash__(self):
value = 17
value = (value * 31) ^ hash(self.errors)
+ value = (value * 31) ^ hash(self.warnings)
return value
def __repr__(self):
@@ -17139,11 +17160,11 @@ class WMGetTriggersForResourePlanResponse:
if fid == 1:
if ftype == TType.LIST:
self.triggers = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = WMTrigger()
- _elem720.read(iprot)
- self.triggers.append(_elem720)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = WMTrigger()
+ _elem727.read(iprot)
+ self.triggers.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17160,8 +17181,8 @@ class WMGetTriggersForResourePlanResponse:
if self.triggers is not None:
oprot.writeFieldBegin('triggers', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.triggers))
- for iter721 in self.triggers:
- iter721.write(oprot)
+ for iter728 in self.triggers:
+ iter728.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
http://git-wip-us.apache.org/repos/asf/hive/blob/90d236af/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 439553f..3a11a05 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
@@ -3729,9 +3729,11 @@ end
class WMValidateResourcePlanResponse
include ::Thrift::Struct, ::Thrift::Struct_Union
ERRORS = 1
+ WARNINGS = 2
FIELDS = {
- ERRORS => {:type => ::Thrift::Types::LIST, :name => 'errors', :element => {:type => ::Thrift::Types::STRING}, :optional => true}
+ ERRORS => {:type => ::Thrift::Types::LIST, :name => 'errors', :element => {:type => ::Thrift::Types::STRING}, :optional => true},
+ WARNINGS => {:type => ::Thrift::Types::LIST, :name => 'warnings', :element => {:type => ::Thrift::Types::STRING}, :optional => true}
}
def struct_fields; FIELDS; end