You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by vg...@apache.org on 2016/12/19 22:10:03 UTC
[2/8] hive git commit: HIVE-15294: Capture additional metadata to
replicate a simple insert at destination (Vaibhav Gumashta reviewed by Thejas
Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-php/metastore/Types.php
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-php/metastore/Types.php b/metastore/src/gen/thrift/gen-php/metastore/Types.php
index 595c448..103cd86 100644
--- a/metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -15987,6 +15987,10 @@ class InsertEventRequestData {
* @var string[]
*/
public $filesAdded = null;
+ /**
+ * @var string[]
+ */
+ public $filesAddedChecksum = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -15999,12 +16003,23 @@ class InsertEventRequestData {
'type' => TType::STRING,
),
),
+ 2 => array(
+ 'var' => 'filesAddedChecksum',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['filesAdded'])) {
$this->filesAdded = $vals['filesAdded'];
}
+ if (isset($vals['filesAddedChecksum'])) {
+ $this->filesAddedChecksum = $vals['filesAddedChecksum'];
+ }
}
}
@@ -16044,6 +16059,23 @@ class InsertEventRequestData {
$xfer += $input->skip($ftype);
}
break;
+ case 2:
+ if ($ftype == TType::LST) {
+ $this->filesAddedChecksum = array();
+ $_size501 = 0;
+ $_etype504 = 0;
+ $xfer += $input->readListBegin($_etype504, $_size501);
+ for ($_i505 = 0; $_i505 < $_size501; ++$_i505)
+ {
+ $elem506 = null;
+ $xfer += $input->readString($elem506);
+ $this->filesAddedChecksum []= $elem506;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -16065,9 +16097,26 @@ class InsertEventRequestData {
{
$output->writeListBegin(TType::STRING, count($this->filesAdded));
{
- foreach ($this->filesAdded as $iter501)
+ foreach ($this->filesAdded as $iter507)
+ {
+ $xfer += $output->writeString($iter507);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->filesAddedChecksum !== null) {
+ if (!is_array($this->filesAddedChecksum)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('filesAddedChecksum', TType::LST, 2);
+ {
+ $output->writeListBegin(TType::STRING, count($this->filesAddedChecksum));
+ {
+ foreach ($this->filesAddedChecksum as $iter508)
{
- $xfer += $output->writeString($iter501);
+ $xfer += $output->writeString($iter508);
}
}
$output->writeListEnd();
@@ -16285,14 +16334,14 @@ class FireEventRequest {
case 5:
if ($ftype == TType::LST) {
$this->partitionVals = array();
- $_size502 = 0;
- $_etype505 = 0;
- $xfer += $input->readListBegin($_etype505, $_size502);
- for ($_i506 = 0; $_i506 < $_size502; ++$_i506)
+ $_size509 = 0;
+ $_etype512 = 0;
+ $xfer += $input->readListBegin($_etype512, $_size509);
+ for ($_i513 = 0; $_i513 < $_size509; ++$_i513)
{
- $elem507 = null;
- $xfer += $input->readString($elem507);
- $this->partitionVals []= $elem507;
+ $elem514 = null;
+ $xfer += $input->readString($elem514);
+ $this->partitionVals []= $elem514;
}
$xfer += $input->readListEnd();
} else {
@@ -16343,9 +16392,9 @@ class FireEventRequest {
{
$output->writeListBegin(TType::STRING, count($this->partitionVals));
{
- foreach ($this->partitionVals as $iter508)
+ foreach ($this->partitionVals as $iter515)
{
- $xfer += $output->writeString($iter508);
+ $xfer += $output->writeString($iter515);
}
}
$output->writeListEnd();
@@ -16573,18 +16622,18 @@ class GetFileMetadataByExprResult {
case 1:
if ($ftype == TType::MAP) {
$this->metadata = array();
- $_size509 = 0;
- $_ktype510 = 0;
- $_vtype511 = 0;
- $xfer += $input->readMapBegin($_ktype510, $_vtype511, $_size509);
- for ($_i513 = 0; $_i513 < $_size509; ++$_i513)
+ $_size516 = 0;
+ $_ktype517 = 0;
+ $_vtype518 = 0;
+ $xfer += $input->readMapBegin($_ktype517, $_vtype518, $_size516);
+ for ($_i520 = 0; $_i520 < $_size516; ++$_i520)
{
- $key514 = 0;
- $val515 = new \metastore\MetadataPpdResult();
- $xfer += $input->readI64($key514);
- $val515 = new \metastore\MetadataPpdResult();
- $xfer += $val515->read($input);
- $this->metadata[$key514] = $val515;
+ $key521 = 0;
+ $val522 = new \metastore\MetadataPpdResult();
+ $xfer += $input->readI64($key521);
+ $val522 = new \metastore\MetadataPpdResult();
+ $xfer += $val522->read($input);
+ $this->metadata[$key521] = $val522;
}
$xfer += $input->readMapEnd();
} else {
@@ -16619,10 +16668,10 @@ class GetFileMetadataByExprResult {
{
$output->writeMapBegin(TType::I64, TType::STRUCT, count($this->metadata));
{
- foreach ($this->metadata as $kiter516 => $viter517)
+ foreach ($this->metadata as $kiter523 => $viter524)
{
- $xfer += $output->writeI64($kiter516);
- $xfer += $viter517->write($output);
+ $xfer += $output->writeI64($kiter523);
+ $xfer += $viter524->write($output);
}
}
$output->writeMapEnd();
@@ -16724,14 +16773,14 @@ class GetFileMetadataByExprRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size518 = 0;
- $_etype521 = 0;
- $xfer += $input->readListBegin($_etype521, $_size518);
- for ($_i522 = 0; $_i522 < $_size518; ++$_i522)
+ $_size525 = 0;
+ $_etype528 = 0;
+ $xfer += $input->readListBegin($_etype528, $_size525);
+ for ($_i529 = 0; $_i529 < $_size525; ++$_i529)
{
- $elem523 = null;
- $xfer += $input->readI64($elem523);
- $this->fileIds []= $elem523;
+ $elem530 = null;
+ $xfer += $input->readI64($elem530);
+ $this->fileIds []= $elem530;
}
$xfer += $input->readListEnd();
} else {
@@ -16780,9 +16829,9 @@ class GetFileMetadataByExprRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter524)
+ foreach ($this->fileIds as $iter531)
{
- $xfer += $output->writeI64($iter524);
+ $xfer += $output->writeI64($iter531);
}
}
$output->writeListEnd();
@@ -16876,17 +16925,17 @@ class GetFileMetadataResult {
case 1:
if ($ftype == TType::MAP) {
$this->metadata = array();
- $_size525 = 0;
- $_ktype526 = 0;
- $_vtype527 = 0;
- $xfer += $input->readMapBegin($_ktype526, $_vtype527, $_size525);
- for ($_i529 = 0; $_i529 < $_size525; ++$_i529)
+ $_size532 = 0;
+ $_ktype533 = 0;
+ $_vtype534 = 0;
+ $xfer += $input->readMapBegin($_ktype533, $_vtype534, $_size532);
+ for ($_i536 = 0; $_i536 < $_size532; ++$_i536)
{
- $key530 = 0;
- $val531 = '';
- $xfer += $input->readI64($key530);
- $xfer += $input->readString($val531);
- $this->metadata[$key530] = $val531;
+ $key537 = 0;
+ $val538 = '';
+ $xfer += $input->readI64($key537);
+ $xfer += $input->readString($val538);
+ $this->metadata[$key537] = $val538;
}
$xfer += $input->readMapEnd();
} else {
@@ -16921,10 +16970,10 @@ class GetFileMetadataResult {
{
$output->writeMapBegin(TType::I64, TType::STRING, count($this->metadata));
{
- foreach ($this->metadata as $kiter532 => $viter533)
+ foreach ($this->metadata as $kiter539 => $viter540)
{
- $xfer += $output->writeI64($kiter532);
- $xfer += $output->writeString($viter533);
+ $xfer += $output->writeI64($kiter539);
+ $xfer += $output->writeString($viter540);
}
}
$output->writeMapEnd();
@@ -16993,14 +17042,14 @@ class GetFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size534 = 0;
- $_etype537 = 0;
- $xfer += $input->readListBegin($_etype537, $_size534);
- for ($_i538 = 0; $_i538 < $_size534; ++$_i538)
+ $_size541 = 0;
+ $_etype544 = 0;
+ $xfer += $input->readListBegin($_etype544, $_size541);
+ for ($_i545 = 0; $_i545 < $_size541; ++$_i545)
{
- $elem539 = null;
- $xfer += $input->readI64($elem539);
- $this->fileIds []= $elem539;
+ $elem546 = null;
+ $xfer += $input->readI64($elem546);
+ $this->fileIds []= $elem546;
}
$xfer += $input->readListEnd();
} else {
@@ -17028,9 +17077,9 @@ class GetFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter540)
+ foreach ($this->fileIds as $iter547)
{
- $xfer += $output->writeI64($iter540);
+ $xfer += $output->writeI64($iter547);
}
}
$output->writeListEnd();
@@ -17170,14 +17219,14 @@ class PutFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size541 = 0;
- $_etype544 = 0;
- $xfer += $input->readListBegin($_etype544, $_size541);
- for ($_i545 = 0; $_i545 < $_size541; ++$_i545)
+ $_size548 = 0;
+ $_etype551 = 0;
+ $xfer += $input->readListBegin($_etype551, $_size548);
+ for ($_i552 = 0; $_i552 < $_size548; ++$_i552)
{
- $elem546 = null;
- $xfer += $input->readI64($elem546);
- $this->fileIds []= $elem546;
+ $elem553 = null;
+ $xfer += $input->readI64($elem553);
+ $this->fileIds []= $elem553;
}
$xfer += $input->readListEnd();
} else {
@@ -17187,14 +17236,14 @@ class PutFileMetadataRequest {
case 2:
if ($ftype == TType::LST) {
$this->metadata = array();
- $_size547 = 0;
- $_etype550 = 0;
- $xfer += $input->readListBegin($_etype550, $_size547);
- for ($_i551 = 0; $_i551 < $_size547; ++$_i551)
+ $_size554 = 0;
+ $_etype557 = 0;
+ $xfer += $input->readListBegin($_etype557, $_size554);
+ for ($_i558 = 0; $_i558 < $_size554; ++$_i558)
{
- $elem552 = null;
- $xfer += $input->readString($elem552);
- $this->metadata []= $elem552;
+ $elem559 = null;
+ $xfer += $input->readString($elem559);
+ $this->metadata []= $elem559;
}
$xfer += $input->readListEnd();
} else {
@@ -17229,9 +17278,9 @@ class PutFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter553)
+ foreach ($this->fileIds as $iter560)
{
- $xfer += $output->writeI64($iter553);
+ $xfer += $output->writeI64($iter560);
}
}
$output->writeListEnd();
@@ -17246,9 +17295,9 @@ class PutFileMetadataRequest {
{
$output->writeListBegin(TType::STRING, count($this->metadata));
{
- foreach ($this->metadata as $iter554)
+ foreach ($this->metadata as $iter561)
{
- $xfer += $output->writeString($iter554);
+ $xfer += $output->writeString($iter561);
}
}
$output->writeListEnd();
@@ -17367,14 +17416,14 @@ class ClearFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size555 = 0;
- $_etype558 = 0;
- $xfer += $input->readListBegin($_etype558, $_size555);
- for ($_i559 = 0; $_i559 < $_size555; ++$_i559)
+ $_size562 = 0;
+ $_etype565 = 0;
+ $xfer += $input->readListBegin($_etype565, $_size562);
+ for ($_i566 = 0; $_i566 < $_size562; ++$_i566)
{
- $elem560 = null;
- $xfer += $input->readI64($elem560);
- $this->fileIds []= $elem560;
+ $elem567 = null;
+ $xfer += $input->readI64($elem567);
+ $this->fileIds []= $elem567;
}
$xfer += $input->readListEnd();
} else {
@@ -17402,9 +17451,9 @@ class ClearFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter561)
+ foreach ($this->fileIds as $iter568)
{
- $xfer += $output->writeI64($iter561);
+ $xfer += $output->writeI64($iter568);
}
}
$output->writeListEnd();
@@ -17688,15 +17737,15 @@ class GetAllFunctionsResponse {
case 1:
if ($ftype == TType::LST) {
$this->functions = array();
- $_size562 = 0;
- $_etype565 = 0;
- $xfer += $input->readListBegin($_etype565, $_size562);
- for ($_i566 = 0; $_i566 < $_size562; ++$_i566)
+ $_size569 = 0;
+ $_etype572 = 0;
+ $xfer += $input->readListBegin($_etype572, $_size569);
+ for ($_i573 = 0; $_i573 < $_size569; ++$_i573)
{
- $elem567 = null;
- $elem567 = new \metastore\Function();
- $xfer += $elem567->read($input);
- $this->functions []= $elem567;
+ $elem574 = null;
+ $elem574 = new \metastore\Function();
+ $xfer += $elem574->read($input);
+ $this->functions []= $elem574;
}
$xfer += $input->readListEnd();
} else {
@@ -17724,9 +17773,9 @@ class GetAllFunctionsResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->functions));
{
- foreach ($this->functions as $iter568)
+ foreach ($this->functions as $iter575)
{
- $xfer += $iter568->write($output);
+ $xfer += $iter575->write($output);
}
}
$output->writeListEnd();
@@ -17790,14 +17839,14 @@ class ClientCapabilities {
case 1:
if ($ftype == TType::LST) {
$this->values = array();
- $_size569 = 0;
- $_etype572 = 0;
- $xfer += $input->readListBegin($_etype572, $_size569);
- for ($_i573 = 0; $_i573 < $_size569; ++$_i573)
+ $_size576 = 0;
+ $_etype579 = 0;
+ $xfer += $input->readListBegin($_etype579, $_size576);
+ for ($_i580 = 0; $_i580 < $_size576; ++$_i580)
{
- $elem574 = null;
- $xfer += $input->readI32($elem574);
- $this->values []= $elem574;
+ $elem581 = null;
+ $xfer += $input->readI32($elem581);
+ $this->values []= $elem581;
}
$xfer += $input->readListEnd();
} else {
@@ -17825,9 +17874,9 @@ class ClientCapabilities {
{
$output->writeListBegin(TType::I32, count($this->values));
{
- foreach ($this->values as $iter575)
+ foreach ($this->values as $iter582)
{
- $xfer += $output->writeI32($iter575);
+ $xfer += $output->writeI32($iter582);
}
}
$output->writeListEnd();
@@ -18127,14 +18176,14 @@ class GetTablesRequest {
case 2:
if ($ftype == TType::LST) {
$this->tblNames = array();
- $_size576 = 0;
- $_etype579 = 0;
- $xfer += $input->readListBegin($_etype579, $_size576);
- for ($_i580 = 0; $_i580 < $_size576; ++$_i580)
+ $_size583 = 0;
+ $_etype586 = 0;
+ $xfer += $input->readListBegin($_etype586, $_size583);
+ for ($_i587 = 0; $_i587 < $_size583; ++$_i587)
{
- $elem581 = null;
- $xfer += $input->readString($elem581);
- $this->tblNames []= $elem581;
+ $elem588 = null;
+ $xfer += $input->readString($elem588);
+ $this->tblNames []= $elem588;
}
$xfer += $input->readListEnd();
} else {
@@ -18175,9 +18224,9 @@ class GetTablesRequest {
{
$output->writeListBegin(TType::STRING, count($this->tblNames));
{
- foreach ($this->tblNames as $iter582)
+ foreach ($this->tblNames as $iter589)
{
- $xfer += $output->writeString($iter582);
+ $xfer += $output->writeString($iter589);
}
}
$output->writeListEnd();
@@ -18250,15 +18299,15 @@ class GetTablesResult {
case 1:
if ($ftype == TType::LST) {
$this->tables = array();
- $_size583 = 0;
- $_etype586 = 0;
- $xfer += $input->readListBegin($_etype586, $_size583);
- for ($_i587 = 0; $_i587 < $_size583; ++$_i587)
+ $_size590 = 0;
+ $_etype593 = 0;
+ $xfer += $input->readListBegin($_etype593, $_size590);
+ for ($_i594 = 0; $_i594 < $_size590; ++$_i594)
{
- $elem588 = null;
- $elem588 = new \metastore\Table();
- $xfer += $elem588->read($input);
- $this->tables []= $elem588;
+ $elem595 = null;
+ $elem595 = new \metastore\Table();
+ $xfer += $elem595->read($input);
+ $this->tables []= $elem595;
}
$xfer += $input->readListEnd();
} else {
@@ -18286,9 +18335,9 @@ class GetTablesResult {
{
$output->writeListBegin(TType::STRUCT, count($this->tables));
{
- foreach ($this->tables as $iter589)
+ foreach ($this->tables as $iter596)
{
- $xfer += $iter589->write($output);
+ $xfer += $iter596->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/bbd99ed6/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index bc51b75..86bbef3 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -11551,10 +11551,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype590, _size587) = iprot.readListBegin()
- for _i591 in xrange(_size587):
- _elem592 = iprot.readString()
- self.success.append(_elem592)
+ (_etype597, _size594) = iprot.readListBegin()
+ for _i598 in xrange(_size594):
+ _elem599 = iprot.readString()
+ self.success.append(_elem599)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11577,8 +11577,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 iter593 in self.success:
- oprot.writeString(iter593)
+ for iter600 in self.success:
+ oprot.writeString(iter600)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11683,10 +11683,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype597, _size594) = iprot.readListBegin()
- for _i598 in xrange(_size594):
- _elem599 = iprot.readString()
- self.success.append(_elem599)
+ (_etype604, _size601) = iprot.readListBegin()
+ for _i605 in xrange(_size601):
+ _elem606 = iprot.readString()
+ self.success.append(_elem606)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11709,8 +11709,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 iter600 in self.success:
- oprot.writeString(iter600)
+ for iter607 in self.success:
+ oprot.writeString(iter607)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12480,12 +12480,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype602, _vtype603, _size601 ) = iprot.readMapBegin()
- for _i605 in xrange(_size601):
- _key606 = iprot.readString()
- _val607 = Type()
- _val607.read(iprot)
- self.success[_key606] = _val607
+ (_ktype609, _vtype610, _size608 ) = iprot.readMapBegin()
+ for _i612 in xrange(_size608):
+ _key613 = iprot.readString()
+ _val614 = Type()
+ _val614.read(iprot)
+ self.success[_key613] = _val614
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -12508,9 +12508,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 kiter608,viter609 in self.success.items():
- oprot.writeString(kiter608)
- viter609.write(oprot)
+ for kiter615,viter616 in self.success.items():
+ oprot.writeString(kiter615)
+ viter616.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -12653,11 +12653,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype613, _size610) = iprot.readListBegin()
- for _i614 in xrange(_size610):
- _elem615 = FieldSchema()
- _elem615.read(iprot)
- self.success.append(_elem615)
+ (_etype620, _size617) = iprot.readListBegin()
+ for _i621 in xrange(_size617):
+ _elem622 = FieldSchema()
+ _elem622.read(iprot)
+ self.success.append(_elem622)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12692,8 +12692,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 iter616 in self.success:
- iter616.write(oprot)
+ for iter623 in self.success:
+ iter623.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12860,11 +12860,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype620, _size617) = iprot.readListBegin()
- for _i621 in xrange(_size617):
- _elem622 = FieldSchema()
- _elem622.read(iprot)
- self.success.append(_elem622)
+ (_etype627, _size624) = iprot.readListBegin()
+ for _i628 in xrange(_size624):
+ _elem629 = FieldSchema()
+ _elem629.read(iprot)
+ self.success.append(_elem629)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12899,8 +12899,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 iter623 in self.success:
- iter623.write(oprot)
+ for iter630 in self.success:
+ iter630.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13053,11 +13053,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype627, _size624) = iprot.readListBegin()
- for _i628 in xrange(_size624):
- _elem629 = FieldSchema()
- _elem629.read(iprot)
- self.success.append(_elem629)
+ (_etype634, _size631) = iprot.readListBegin()
+ for _i635 in xrange(_size631):
+ _elem636 = FieldSchema()
+ _elem636.read(iprot)
+ self.success.append(_elem636)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13092,8 +13092,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 iter630 in self.success:
- iter630.write(oprot)
+ for iter637 in self.success:
+ iter637.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13260,11 +13260,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype634, _size631) = iprot.readListBegin()
- for _i635 in xrange(_size631):
- _elem636 = FieldSchema()
- _elem636.read(iprot)
- self.success.append(_elem636)
+ (_etype641, _size638) = iprot.readListBegin()
+ for _i642 in xrange(_size638):
+ _elem643 = FieldSchema()
+ _elem643.read(iprot)
+ self.success.append(_elem643)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13299,8 +13299,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 iter637 in self.success:
- iter637.write(oprot)
+ for iter644 in self.success:
+ iter644.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13741,22 +13741,22 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype641, _size638) = iprot.readListBegin()
- for _i642 in xrange(_size638):
- _elem643 = SQLPrimaryKey()
- _elem643.read(iprot)
- self.primaryKeys.append(_elem643)
+ (_etype648, _size645) = iprot.readListBegin()
+ for _i649 in xrange(_size645):
+ _elem650 = SQLPrimaryKey()
+ _elem650.read(iprot)
+ self.primaryKeys.append(_elem650)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype647, _size644) = iprot.readListBegin()
- for _i648 in xrange(_size644):
- _elem649 = SQLForeignKey()
- _elem649.read(iprot)
- self.foreignKeys.append(_elem649)
+ (_etype654, _size651) = iprot.readListBegin()
+ for _i655 in xrange(_size651):
+ _elem656 = SQLForeignKey()
+ _elem656.read(iprot)
+ self.foreignKeys.append(_elem656)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13777,15 +13777,15 @@ 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 iter650 in self.primaryKeys:
- iter650.write(oprot)
+ for iter657 in self.primaryKeys:
+ iter657.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 iter651 in self.foreignKeys:
- iter651.write(oprot)
+ for iter658 in self.foreignKeys:
+ iter658.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14821,10 +14821,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype655, _size652) = iprot.readListBegin()
- for _i656 in xrange(_size652):
- _elem657 = iprot.readString()
- self.success.append(_elem657)
+ (_etype662, _size659) = iprot.readListBegin()
+ for _i663 in xrange(_size659):
+ _elem664 = iprot.readString()
+ self.success.append(_elem664)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14847,8 +14847,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 iter658 in self.success:
- oprot.writeString(iter658)
+ for iter665 in self.success:
+ oprot.writeString(iter665)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14998,10 +14998,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype662, _size659) = iprot.readListBegin()
- for _i663 in xrange(_size659):
- _elem664 = iprot.readString()
- self.success.append(_elem664)
+ (_etype669, _size666) = iprot.readListBegin()
+ for _i670 in xrange(_size666):
+ _elem671 = iprot.readString()
+ self.success.append(_elem671)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15024,8 +15024,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 iter665 in self.success:
- oprot.writeString(iter665)
+ for iter672 in self.success:
+ oprot.writeString(iter672)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15098,10 +15098,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype669, _size666) = iprot.readListBegin()
- for _i670 in xrange(_size666):
- _elem671 = iprot.readString()
- self.tbl_types.append(_elem671)
+ (_etype676, _size673) = iprot.readListBegin()
+ for _i677 in xrange(_size673):
+ _elem678 = iprot.readString()
+ self.tbl_types.append(_elem678)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15126,8 +15126,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 iter672 in self.tbl_types:
- oprot.writeString(iter672)
+ for iter679 in self.tbl_types:
+ oprot.writeString(iter679)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15183,11 +15183,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype676, _size673) = iprot.readListBegin()
- for _i677 in xrange(_size673):
- _elem678 = TableMeta()
- _elem678.read(iprot)
- self.success.append(_elem678)
+ (_etype683, _size680) = iprot.readListBegin()
+ for _i684 in xrange(_size680):
+ _elem685 = TableMeta()
+ _elem685.read(iprot)
+ self.success.append(_elem685)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15210,8 +15210,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 iter679 in self.success:
- iter679.write(oprot)
+ for iter686 in self.success:
+ iter686.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15335,10 +15335,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype683, _size680) = iprot.readListBegin()
- for _i684 in xrange(_size680):
- _elem685 = iprot.readString()
- self.success.append(_elem685)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = iprot.readString()
+ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15361,8 +15361,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 iter686 in self.success:
- oprot.writeString(iter686)
+ for iter693 in self.success:
+ oprot.writeString(iter693)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15598,10 +15598,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = iprot.readString()
- self.tbl_names.append(_elem692)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = iprot.readString()
+ self.tbl_names.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15622,8 +15622,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 iter693 in self.tbl_names:
- oprot.writeString(iter693)
+ for iter700 in self.tbl_names:
+ oprot.writeString(iter700)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15675,11 +15675,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = Table()
- _elem699.read(iprot)
- self.success.append(_elem699)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = Table()
+ _elem706.read(iprot)
+ self.success.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15696,8 +15696,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 iter700 in self.success:
- iter700.write(oprot)
+ for iter707 in self.success:
+ iter707.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16180,10 +16180,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = iprot.readString()
- self.success.append(_elem706)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = iprot.readString()
+ self.success.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16218,8 +16218,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 iter707 in self.success:
- oprot.writeString(iter707)
+ for iter714 in self.success:
+ oprot.writeString(iter714)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17189,11 +17189,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = Partition()
- _elem713.read(iprot)
- self.new_parts.append(_elem713)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = Partition()
+ _elem720.read(iprot)
+ self.new_parts.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17210,8 +17210,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 iter714 in self.new_parts:
- iter714.write(oprot)
+ for iter721 in self.new_parts:
+ iter721.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17369,11 +17369,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = PartitionSpec()
- _elem720.read(iprot)
- self.new_parts.append(_elem720)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = PartitionSpec()
+ _elem727.read(iprot)
+ self.new_parts.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17390,8 +17390,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 iter721 in self.new_parts:
- iter721.write(oprot)
+ for iter728 in self.new_parts:
+ iter728.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17565,10 +17565,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype725, _size722) = iprot.readListBegin()
- for _i726 in xrange(_size722):
- _elem727 = iprot.readString()
- self.part_vals.append(_elem727)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = iprot.readString()
+ self.part_vals.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17593,8 +17593,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 iter728 in self.part_vals:
- oprot.writeString(iter728)
+ for iter735 in self.part_vals:
+ oprot.writeString(iter735)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17947,10 +17947,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype732, _size729) = iprot.readListBegin()
- for _i733 in xrange(_size729):
- _elem734 = iprot.readString()
- self.part_vals.append(_elem734)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = iprot.readString()
+ self.part_vals.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17981,8 +17981,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 iter735 in self.part_vals:
- oprot.writeString(iter735)
+ for iter742 in self.part_vals:
+ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -18577,10 +18577,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype739, _size736) = iprot.readListBegin()
- for _i740 in xrange(_size736):
- _elem741 = iprot.readString()
- self.part_vals.append(_elem741)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = iprot.readString()
+ self.part_vals.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18610,8 +18610,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 iter742 in self.part_vals:
- oprot.writeString(iter742)
+ for iter749 in self.part_vals:
+ oprot.writeString(iter749)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -18784,10 +18784,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype746, _size743) = iprot.readListBegin()
- for _i747 in xrange(_size743):
- _elem748 = iprot.readString()
- self.part_vals.append(_elem748)
+ (_etype753, _size750) = iprot.readListBegin()
+ for _i754 in xrange(_size750):
+ _elem755 = iprot.readString()
+ self.part_vals.append(_elem755)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18823,8 +18823,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 iter749 in self.part_vals:
- oprot.writeString(iter749)
+ for iter756 in self.part_vals:
+ oprot.writeString(iter756)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -19561,10 +19561,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype753, _size750) = iprot.readListBegin()
- for _i754 in xrange(_size750):
- _elem755 = iprot.readString()
- self.part_vals.append(_elem755)
+ (_etype760, _size757) = iprot.readListBegin()
+ for _i761 in xrange(_size757):
+ _elem762 = iprot.readString()
+ self.part_vals.append(_elem762)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19589,8 +19589,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 iter756 in self.part_vals:
- oprot.writeString(iter756)
+ for iter763 in self.part_vals:
+ oprot.writeString(iter763)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19749,11 +19749,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype758, _vtype759, _size757 ) = iprot.readMapBegin()
- for _i761 in xrange(_size757):
- _key762 = iprot.readString()
- _val763 = iprot.readString()
- self.partitionSpecs[_key762] = _val763
+ (_ktype765, _vtype766, _size764 ) = iprot.readMapBegin()
+ for _i768 in xrange(_size764):
+ _key769 = iprot.readString()
+ _val770 = iprot.readString()
+ self.partitionSpecs[_key769] = _val770
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19790,9 +19790,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 kiter764,viter765 in self.partitionSpecs.items():
- oprot.writeString(kiter764)
- oprot.writeString(viter765)
+ for kiter771,viter772 in self.partitionSpecs.items():
+ oprot.writeString(kiter771)
+ oprot.writeString(viter772)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -19997,11 +19997,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype767, _vtype768, _size766 ) = iprot.readMapBegin()
- for _i770 in xrange(_size766):
- _key771 = iprot.readString()
- _val772 = iprot.readString()
- self.partitionSpecs[_key771] = _val772
+ (_ktype774, _vtype775, _size773 ) = iprot.readMapBegin()
+ for _i777 in xrange(_size773):
+ _key778 = iprot.readString()
+ _val779 = iprot.readString()
+ self.partitionSpecs[_key778] = _val779
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -20038,9 +20038,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 kiter773,viter774 in self.partitionSpecs.items():
- oprot.writeString(kiter773)
- oprot.writeString(viter774)
+ for kiter780,viter781 in self.partitionSpecs.items():
+ oprot.writeString(kiter780)
+ oprot.writeString(viter781)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -20123,11 +20123,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype778, _size775) = iprot.readListBegin()
- for _i779 in xrange(_size775):
- _elem780 = Partition()
- _elem780.read(iprot)
- self.success.append(_elem780)
+ (_etype785, _size782) = iprot.readListBegin()
+ for _i786 in xrange(_size782):
+ _elem787 = Partition()
+ _elem787.read(iprot)
+ self.success.append(_elem787)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20168,8 +20168,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 iter781 in self.success:
- iter781.write(oprot)
+ for iter788 in self.success:
+ iter788.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20263,10 +20263,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype785, _size782) = iprot.readListBegin()
- for _i786 in xrange(_size782):
- _elem787 = iprot.readString()
- self.part_vals.append(_elem787)
+ (_etype792, _size789) = iprot.readListBegin()
+ for _i793 in xrange(_size789):
+ _elem794 = iprot.readString()
+ self.part_vals.append(_elem794)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20278,10 +20278,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype791, _size788) = iprot.readListBegin()
- for _i792 in xrange(_size788):
- _elem793 = iprot.readString()
- self.group_names.append(_elem793)
+ (_etype798, _size795) = iprot.readListBegin()
+ for _i799 in xrange(_size795):
+ _elem800 = iprot.readString()
+ self.group_names.append(_elem800)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20306,8 +20306,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 iter794 in self.part_vals:
- oprot.writeString(iter794)
+ for iter801 in self.part_vals:
+ oprot.writeString(iter801)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -20317,8 +20317,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 iter795 in self.group_names:
- oprot.writeString(iter795)
+ for iter802 in self.group_names:
+ oprot.writeString(iter802)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20747,11 +20747,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype799, _size796) = iprot.readListBegin()
- for _i800 in xrange(_size796):
- _elem801 = Partition()
- _elem801.read(iprot)
- self.success.append(_elem801)
+ (_etype806, _size803) = iprot.readListBegin()
+ for _i807 in xrange(_size803):
+ _elem808 = Partition()
+ _elem808.read(iprot)
+ self.success.append(_elem808)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20780,8 +20780,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 iter802 in self.success:
- iter802.write(oprot)
+ for iter809 in self.success:
+ iter809.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20875,10 +20875,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype806, _size803) = iprot.readListBegin()
- for _i807 in xrange(_size803):
- _elem808 = iprot.readString()
- self.group_names.append(_elem808)
+ (_etype813, _size810) = iprot.readListBegin()
+ for _i814 in xrange(_size810):
+ _elem815 = iprot.readString()
+ self.group_names.append(_elem815)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20911,8 +20911,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 iter809 in self.group_names:
- oprot.writeString(iter809)
+ for iter816 in self.group_names:
+ oprot.writeString(iter816)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20973,11 +20973,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype813, _size810) = iprot.readListBegin()
- for _i814 in xrange(_size810):
- _elem815 = Partition()
- _elem815.read(iprot)
- self.success.append(_elem815)
+ (_etype820, _size817) = iprot.readListBegin()
+ for _i821 in xrange(_size817):
+ _elem822 = Partition()
+ _elem822.read(iprot)
+ self.success.append(_elem822)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21006,8 +21006,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 iter816 in self.success:
- iter816.write(oprot)
+ for iter823 in self.success:
+ iter823.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21165,11 +21165,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype820, _size817) = iprot.readListBegin()
- for _i821 in xrange(_size817):
- _elem822 = PartitionSpec()
- _elem822.read(iprot)
- self.success.append(_elem822)
+ (_etype827, _size824) = iprot.readListBegin()
+ for _i828 in xrange(_size824):
+ _elem829 = PartitionSpec()
+ _elem829.read(iprot)
+ self.success.append(_elem829)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21198,8 +21198,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 iter823 in self.success:
- iter823.write(oprot)
+ for iter830 in self.success:
+ iter830.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21354,10 +21354,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype827, _size824) = iprot.readListBegin()
- for _i828 in xrange(_size824):
- _elem829 = iprot.readString()
- self.success.append(_elem829)
+ (_etype834, _size831) = iprot.readListBegin()
+ for _i835 in xrange(_size831):
+ _elem836 = iprot.readString()
+ self.success.append(_elem836)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21380,8 +21380,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 iter830 in self.success:
- oprot.writeString(iter830)
+ for iter837 in self.success:
+ oprot.writeString(iter837)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -21457,10 +21457,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype834, _size831) = iprot.readListBegin()
- for _i835 in xrange(_size831):
- _elem836 = iprot.readString()
- self.part_vals.append(_elem836)
+ (_etype841, _size838) = iprot.readListBegin()
+ for _i842 in xrange(_size838):
+ _elem843 = iprot.readString()
+ self.part_vals.append(_elem843)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21490,8 +21490,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 iter837 in self.part_vals:
- oprot.writeString(iter837)
+ for iter844 in self.part_vals:
+ oprot.writeString(iter844)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -21555,11 +21555,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype841, _size838) = iprot.readListBegin()
- for _i842 in xrange(_size838):
- _elem843 = Partition()
- _elem843.read(iprot)
- self.success.append(_elem843)
+ (_etype848, _size845) = iprot.readListBegin()
+ for _i849 in xrange(_size845):
+ _elem850 = Partition()
+ _elem850.read(iprot)
+ self.success.append(_elem850)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21588,8 +21588,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 iter844 in self.success:
- iter844.write(oprot)
+ for iter851 in self.success:
+ iter851.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21676,10 +21676,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype848, _size845) = iprot.readListBegin()
- for _i849 in xrange(_size845):
- _elem850 = iprot.readString()
- self.part_vals.append(_elem850)
+ (_etype855, _size852) = iprot.readListBegin()
+ for _i856 in xrange(_size852):
+ _elem857 = iprot.readString()
+ self.part_vals.append(_elem857)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21696,10 +21696,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype854, _size851) = iprot.readListBegin()
- for _i855 in xrange(_size851):
- _elem856 = iprot.readString()
- self.group_names.append(_elem856)
+ (_etype861, _size858) = iprot.readListBegin()
+ for _i862 in xrange(_size858):
+ _elem863 = iprot.readString()
+ self.group_names.append(_elem863)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21724,8 +21724,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 iter857 in self.part_vals:
- oprot.writeString(iter857)
+ for iter864 in self.part_vals:
+ oprot.writeString(iter864)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -21739,8 +21739,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 iter858 in self.group_names:
- oprot.writeString(iter858)
+ for iter865 in self.group_names:
+ oprot.writeString(iter865)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21802,11 +21802,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype862, _size859) = iprot.readListBegin()
- for _i863 in xrange(_size859):
- _elem864 = Partition()
- _elem864.read(iprot)
- self.success.append(_elem864)
+ (_etype869, _size866) = iprot.readListBegin()
+ for _i870 in xrange(_size866):
+ _elem871 = Partition()
+ _elem871.read(iprot)
+ self.success.append(_elem871)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21835,8 +21835,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 iter865 in self.success:
- iter865.write(oprot)
+ for iter872 in self.success:
+ iter872.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21917,10 +21917,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype869, _size866) = iprot.readListBegin()
- for _i870 in xrange(_size866):
- _elem871 = iprot.readString()
- self.part_vals.append(_elem871)
+ (_etype876, _size873) = iprot.readListBegin()
+ for _i877 in xrange(_size873):
+ _elem878 = iprot.readString()
+ self.part_vals.append(_elem878)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21950,8 +21950,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 iter872 in self.part_vals:
- oprot.writeString(iter872)
+ for iter879 in self.part_vals:
+ oprot.writeString(iter879)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -22015,10 +22015,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype876, _size873) = iprot.readListBegin()
- for _i877 in xrange(_size873):
- _elem878 = iprot.readString()
- self.success.append(_elem878)
+ (_etype883, _size880) = iprot.readListBegin()
+ for _i884 in xrange(_size880):
+ _elem885 = iprot.readString()
+ self.success.append(_elem885)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22047,8 +22047,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 iter879 in self.success:
- oprot.writeString(iter879)
+ for iter886 in self.success:
+ oprot.writeString(iter886)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22219,11 +22219,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype883, _size880) = iprot.readListBegin()
- for _i884 in xrange(_size880):
- _elem885 = Partition()
- _elem885.read(iprot)
- self.success.append(_elem885)
+ (_etype890, _size887) = iprot.readListBegin()
+ for _i891 in xrange(_size887):
+ _elem892 = Partition()
+ _elem892.read(iprot)
+ self.success.append(_elem892)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22252,8 +22252,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 iter886 in self.success:
- iter886.write(oprot)
+ for iter893 in self.success:
+ iter893.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22424,11 +22424,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype890, _size887) = iprot.readListBegin()
- for _i891 in xrange(_size887):
- _elem892 = PartitionSpec()
- _elem892.read(iprot)
- self.success.append(_elem892)
+ (_etype897, _size894) = iprot.readListBegin()
+ for _i898 in xrange(_size894):
+ _elem899 = PartitionSpec()
+ _elem899.read(iprot)
+ self.success.append(_elem899)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22457,8 +22457,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 iter893 in self.success:
- iter893.write(oprot)
+ for iter900 in self.success:
+ iter900.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22878,10 +22878,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype897, _size894) = iprot.readListBegin()
- for _i898 in xrange(_size894):
- _elem899 = iprot.readString()
- self.names.append(_elem899)
+ (_etype904, _size901) = iprot.readListBegin()
+ for _i905 in xrange(_size901):
+ _elem906 = iprot.readString()
+ self.names.append(_elem906)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22906,8 +22906,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 iter900 in self.names:
- oprot.writeString(iter900)
+ for iter907 in self.names:
+ oprot.writeString(iter907)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22966,11 +22966,11 @@ class get_partitions_by_names_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)
@@ -22999,8 +22999,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 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:
@@ -23250,11 +23250,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype911, _size908) = iprot.readListBegin()
- for _i912 in xrange(_size908):
- _elem913 = Partition()
- _elem913.read(iprot)
- self.new_parts.append(_elem913)
+ (_etype918, _size915) = iprot.readListBegin()
+ for _i919 in xrange(_size915):
+ _elem920 = Partition()
+ _elem920.read(iprot)
+ self.new_parts.append(_elem920)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23279,8 +23279,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 iter914 in self.new_parts:
- iter914.write(oprot)
+ for iter921 in self.new_parts:
+ iter921.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23433,11 +23433,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype918, _size915) = iprot.readListBegin()
- for _i919 in xrange(_size915):
- _elem920 = Partition()
- _elem920.read(iprot)
- self.new_parts.append(_elem920)
+ (_etype925, _size922) = iprot.readListBegin()
+ for _i926 in xrange(_size922):
+ _elem927 = Partition()
+ _elem927.read(iprot)
+ self.new_parts.append(_elem927)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23468,8 +23468,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 iter921 in self.new_parts:
- iter921.write(oprot)
+ for iter928 in self.new_parts:
+ iter928.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -23813,10 +23813,10 @@ class rename_partition_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)
@@ -23847,8 +23847,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 iter928 in self.part_vals:
- oprot.writeString(iter928)
+ for iter935 in self.part_vals:
+ oprot.writeString(iter935)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -23990,10 +23990,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
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)
@@ -24015,8 +24015,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 iter935 in self.part_vals:
- oprot.writeString(iter935)
+ for iter942 in self.part_vals:
+ oprot.writeString(iter942)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -24374,10 +24374,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype939, _size936) = iprot.readListBegin()
- for _i940 in xrange(_size936):
- _elem941 = iprot.readString()
- self.success.append(_elem941)
+ (_etype946, _size943) = iprot.readListBegin()
+ for _i947 in xrange(_size943):
+ _elem948 = iprot.readString()
+ self.success.append(_elem948)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24400,8 +24400,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 iter942 in self.success:
- oprot.writeString(iter942)
+ for iter949 in self.success:
+ oprot.writeString(iter949)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24525,11 +24525,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype944, _vtype945, _size943 ) = iprot.readMapBegin()
- for _i947 in xrange(_size943):
- _key948 = iprot.readString()
- _val949 = iprot.readString()
- self.success[_key948] = _val949
+ (_ktype951, _vtype952, _size950 ) = iprot.readMapBegin()
+ for _i954 in xrange(_size950):
+ _key955 = iprot.readString()
+ _val956 = iprot.readString()
+ self.success[_key955] = _val956
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24552,9 +24552,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 kiter950,viter951 in self.success.items():
- oprot.writeString(kiter950)
- oprot.writeString(viter951)
+ for kiter957,viter958 in self.success.items():
+ oprot.writeString(kiter957)
+ oprot.writeString(viter958)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24630,11 +24630,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype953, _vtype954, _size952 ) = iprot.readMapBegin()
- for _i956 in xrange(_size952):
- _key957 = iprot.readString()
- _val958 = iprot.readString()
- self.part_vals[_key957] = _val958
+ (_ktype960, _vtype961, _size959 ) = iprot.readMapBegin()
+ for _i963 in xrange(_size959):
+ _key964 = iprot.readString()
+ _val965 = iprot.readString()
+ self.part_vals[_key964] = _val965
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24664,9 +24664,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 kiter959,viter960 in self.part_vals.items():
- oprot.writeString(kiter959)
- oprot.writeString(viter960)
+ for kiter966,viter967 in self.part_vals.items():
+ oprot.writeString(kiter966)
+ oprot.writeString(viter967)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -24880,11 +24880,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype962, _vtype963, _size961 ) = iprot.readMapBegin()
- for _i965 in xrange(_size961):
- _key966 = iprot.readString()
- _val967 = iprot.readString()
- self.part_vals[_key966] = _val967
+ (_ktype969, _vtype970, _size968 ) = iprot.readMapBegin()
+ for _i972 in xrange(_size968):
+ _key973 = iprot.readString()
+ _val974 = iprot.readString()
+ self.part_vals[_key973] = _val974
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24914,9 +24914,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 kiter968,viter969 in self.part_vals.items():
- oprot.writeString(kiter968)
- oprot.writeString(viter969)
+ for kiter975,viter976 in self.part_vals.items():
+ oprot.writeString(kiter975)
+ oprot.writeString(viter976)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -25971,11 +25971,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype973, _size970) = iprot.readListBegin()
- for _i974 in xrange(_size970):
- _elem975 = Index()
- _elem975.read(iprot)
- self.success.append(_elem975)
+ (_etype980, _size977) = iprot.readListBegin()
+ for _i981 in xrange(_size977):
+ _elem982 = Index()
+ _elem982.read(iprot)
+ self.success.append(_elem982)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26004,8 +26004,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 iter976 in self.success:
- iter976.write(oprot)
+ for iter983 in self.success:
+ iter983.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26160,10 +26160,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype980, _size977) = iprot.readListBegin()
- for _i981 in xrange(_size977):
- _elem982 = iprot.readString()
- self.success.append(_elem982)
+ (_etype987, _size984) = iprot.readListBegin()
+ for _i988 in xrange(_size984):
+ _elem989 = iprot.readString()
+ self.success.append(_elem989)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26186,8 +26186,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 iter983 in self.success:
- oprot.writeString(iter983)
+ for iter990 in self.success:
+ oprot.writeString(iter990)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -29053,10 +29053,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype987, _size984) = iprot.readListBegin()
- for _i988 in xrange(_size984):
- _elem989 = iprot.readString()
- self.success.append(_elem989)
+ (_etype994, _size991) = iprot.readListBegin()
+ for _i995 in xrange(_size991):
+ _elem996 = iprot.readString()
+ self.success.append(_elem996)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29079,8 +29079,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 iter990 in self.success:
- oprot.writeString(iter990)
+ for iter997 in self.success:
+ oprot.writeString(iter997)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29768,10 +29768,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype994, _size991) = iprot.readListBegin()
- for _i995 in xrange(_size991):
- _elem996 = iprot.readString()
- self.success.append(_elem996)
+ (_etype1001, _size998) = iprot.readListBegin()
+ for _i1002 in xrange(_size998):
+ _elem1003 = iprot.readString()
+ self.success.append(_elem1003)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29794,8 +29794,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 iter997 in self.success:
- oprot.writeString(iter997)
+ for iter1004 in self.success:
+ oprot.writeString(iter1004)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30309,11 +30309,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1001, _size998) = iprot.readListBegin()
- for _i1002 in xrange(_size998):
- _elem1003 = Role()
- _elem1003.read(iprot)
- self.success.append(_elem1003)
+ (_etype1008, _size1005) = iprot.readListBegin()
+ for _i1009 in xrange(_size1005):
+ _elem1010 = Role()
+ _elem1010.read(iprot)
+ self.success.append(_elem1010)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30336,8 +30336,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 iter1004 in self.success:
- iter1004.write(oprot)
+ for iter1011 in self.success:
+ iter1011.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30846,10 +30846,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1008, _size1005) = iprot.readListBegin()
- for _i1009 in xrange(_size1005):
- _elem1010 = iprot.readString()
- self.group_names.append(_elem1010)
+ (_etype1015, _size1012) = iprot.readListBegin()
+ for _i1016 in xrange(_size1012):
+ _elem1017 = iprot.readString()
+ self.group_names.append(_elem1017)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30874,8 +30874,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 iter1011 in self.group_names:
- oprot.writeString(iter1011)
+ for iter1018 in self.group_names:
+ oprot.writeString(iter1018)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -31102,11 +31102,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1015, _size1012) = iprot.readListBegin()
- for _i1016 in xrange(_size1012):
- _elem1017 = HiveObjectPrivilege()
- _elem1017.read(iprot)
- self.success.append(_elem1017)
+ (_etype1022, _size1019) = iprot.readListBegin()
+ for _i1023 in xrange(_size1019):
+ _elem1024 = HiveObjectPrivilege()
+ _elem1024.read(iprot)
+ self.success.append(_elem1024)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31129,8 +31129,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 iter1018 in self.success:
- iter1018.write(oprot)
+ for iter1025 in self.success:
+ iter1025.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -31628,10 +31628,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1022, _size1019) = iprot.readListBegin()
- for _i1023 in xrange(_size1019):
- _elem1024 = iprot.readString()
- self.group_names.append(_elem1024)
+ (_etype1029, _size1026) = iprot.readListBegin()
+ for _i1030 in xrange(_size1026):
+ _elem1031 = iprot.readString()
+ self.group_names.append(_elem1031)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31652,8 +31652,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 iter1025 in self.group_names:
- oprot.writeString(iter1025)
+ for iter1032 in self.group_names:
+ oprot.writeString(iter1032)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -31708,10 +31708,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1029, _size1026) = iprot.readListBegin()
- for _i1030 in xrange(_size1026):
- _elem1031 = iprot.readString()
- self.success.append(_elem1031)
+ (_etype1036, _size1033) = iprot.readListBegin()
+ for _i1037 in xrange(_size1033):
+ _elem1038 = iprot.readString()
+ self.success.append(_elem1038)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31734,8 +31734,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 iter1032 in self.success:
- oprot.writeString(iter1032)
+ for iter1039 in self.success:
+ oprot.writeString(iter1039)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -32667,10 +32667,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1036, _size1033) = iprot.readListBegin()
- for _i1037 in xrange(_size1033):
- _elem1038 = iprot.readString()
- self.success.append(_elem1038)
+ (_etype1043, _size1040) = iprot.readListBegin()
+ for _i1044 in xrange(_size1040):
+ _elem1045 = iprot.readString()
+ self.success.append(_elem1045)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32687,8 +32687,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 iter1039 in self.success:
- oprot.writeString(iter1039)
+ for iter1046 in self.success:
+ oprot.writeString(iter1046)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -33215,10 +33215,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1043, _size1040) = iprot.readListBegin()
- for _i1044 in xrange(_size1040):
- _elem1045 = iprot.readString()
- self.success.append(_elem1045)
+ (_etype1050, _size1047) = iprot.readListBegin()
+ for _i1051 in xrange(_size1047):
+ _elem1052 = iprot.readString()
+ self.success.append(_elem1052)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33235,8 +33235,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 iter1046 in self.success:
- oprot.writeString(iter1046)
+ for iter1053 in self.success:
+ oprot.writeString(iter1053)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()