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 2015/10/06 19:51:10 UTC
[04/15] hive git commit: HIVE-12027 : simplify file metadata cache
ppd api (Sergey Shelukhin, reviewed by Alan Gates)
http://git-wip-us.apache.org/repos/asf/hive/blob/25b15fdd/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 0baeef3..d341142 100644
--- a/metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -13970,10 +13970,6 @@ class GetFileMetadataByExprResult {
* @var bool
*/
public $isSupported = null;
- /**
- * @var int[]
- */
- public $unknownFileIds = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -13995,14 +13991,6 @@ class GetFileMetadataByExprResult {
'var' => 'isSupported',
'type' => TType::BOOL,
),
- 3 => array(
- 'var' => 'unknownFileIds',
- 'type' => TType::LST,
- 'etype' => TType::I64,
- 'elem' => array(
- 'type' => TType::I64,
- ),
- ),
);
}
if (is_array($vals)) {
@@ -14012,9 +14000,6 @@ class GetFileMetadataByExprResult {
if (isset($vals['isSupported'])) {
$this->isSupported = $vals['isSupported'];
}
- if (isset($vals['unknownFileIds'])) {
- $this->unknownFileIds = $vals['unknownFileIds'];
- }
}
}
@@ -14065,23 +14050,6 @@ class GetFileMetadataByExprResult {
$xfer += $input->skip($ftype);
}
break;
- case 3:
- if ($ftype == TType::LST) {
- $this->unknownFileIds = array();
- $_size472 = 0;
- $_etype475 = 0;
- $xfer += $input->readListBegin($_etype475, $_size472);
- for ($_i476 = 0; $_i476 < $_size472; ++$_i476)
- {
- $elem477 = null;
- $xfer += $input->readI64($elem477);
- $this->unknownFileIds []= $elem477;
- }
- $xfer += $input->readListEnd();
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
default:
$xfer += $input->skip($ftype);
break;
@@ -14103,10 +14071,10 @@ class GetFileMetadataByExprResult {
{
$output->writeMapBegin(TType::I64, TType::STRUCT, count($this->metadata));
{
- foreach ($this->metadata as $kiter478 => $viter479)
+ foreach ($this->metadata as $kiter472 => $viter473)
{
- $xfer += $output->writeI64($kiter478);
- $xfer += $viter479->write($output);
+ $xfer += $output->writeI64($kiter472);
+ $xfer += $viter473->write($output);
}
}
$output->writeMapEnd();
@@ -14118,23 +14086,6 @@ class GetFileMetadataByExprResult {
$xfer += $output->writeBool($this->isSupported);
$xfer += $output->writeFieldEnd();
}
- if ($this->unknownFileIds !== null) {
- if (!is_array($this->unknownFileIds)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('unknownFileIds', TType::LST, 3);
- {
- $output->writeListBegin(TType::I64, count($this->unknownFileIds));
- {
- foreach ($this->unknownFileIds as $iter480)
- {
- $xfer += $output->writeI64($iter480);
- }
- }
- $output->writeListEnd();
- }
- $xfer += $output->writeFieldEnd();
- }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -14153,6 +14104,10 @@ class GetFileMetadataByExprRequest {
* @var string
*/
public $expr = null;
+ /**
+ * @var bool
+ */
+ public $doGetFooters = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -14169,6 +14124,10 @@ class GetFileMetadataByExprRequest {
'var' => 'expr',
'type' => TType::STRING,
),
+ 3 => array(
+ 'var' => 'doGetFooters',
+ 'type' => TType::BOOL,
+ ),
);
}
if (is_array($vals)) {
@@ -14178,6 +14137,9 @@ class GetFileMetadataByExprRequest {
if (isset($vals['expr'])) {
$this->expr = $vals['expr'];
}
+ if (isset($vals['doGetFooters'])) {
+ $this->doGetFooters = $vals['doGetFooters'];
+ }
}
}
@@ -14203,14 +14165,14 @@ class GetFileMetadataByExprRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size481 = 0;
- $_etype484 = 0;
- $xfer += $input->readListBegin($_etype484, $_size481);
- for ($_i485 = 0; $_i485 < $_size481; ++$_i485)
+ $_size474 = 0;
+ $_etype477 = 0;
+ $xfer += $input->readListBegin($_etype477, $_size474);
+ for ($_i478 = 0; $_i478 < $_size474; ++$_i478)
{
- $elem486 = null;
- $xfer += $input->readI64($elem486);
- $this->fileIds []= $elem486;
+ $elem479 = null;
+ $xfer += $input->readI64($elem479);
+ $this->fileIds []= $elem479;
}
$xfer += $input->readListEnd();
} else {
@@ -14224,6 +14186,13 @@ class GetFileMetadataByExprRequest {
$xfer += $input->skip($ftype);
}
break;
+ case 3:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->doGetFooters);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -14245,9 +14214,9 @@ class GetFileMetadataByExprRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter487)
+ foreach ($this->fileIds as $iter480)
{
- $xfer += $output->writeI64($iter487);
+ $xfer += $output->writeI64($iter480);
}
}
$output->writeListEnd();
@@ -14259,6 +14228,11 @@ class GetFileMetadataByExprRequest {
$xfer += $output->writeString($this->expr);
$xfer += $output->writeFieldEnd();
}
+ if ($this->doGetFooters !== null) {
+ $xfer += $output->writeFieldBegin('doGetFooters', TType::BOOL, 3);
+ $xfer += $output->writeBool($this->doGetFooters);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -14331,17 +14305,17 @@ class GetFileMetadataResult {
case 1:
if ($ftype == TType::MAP) {
$this->metadata = array();
- $_size488 = 0;
- $_ktype489 = 0;
- $_vtype490 = 0;
- $xfer += $input->readMapBegin($_ktype489, $_vtype490, $_size488);
- for ($_i492 = 0; $_i492 < $_size488; ++$_i492)
+ $_size481 = 0;
+ $_ktype482 = 0;
+ $_vtype483 = 0;
+ $xfer += $input->readMapBegin($_ktype482, $_vtype483, $_size481);
+ for ($_i485 = 0; $_i485 < $_size481; ++$_i485)
{
- $key493 = 0;
- $val494 = '';
- $xfer += $input->readI64($key493);
- $xfer += $input->readString($val494);
- $this->metadata[$key493] = $val494;
+ $key486 = 0;
+ $val487 = '';
+ $xfer += $input->readI64($key486);
+ $xfer += $input->readString($val487);
+ $this->metadata[$key486] = $val487;
}
$xfer += $input->readMapEnd();
} else {
@@ -14376,10 +14350,10 @@ class GetFileMetadataResult {
{
$output->writeMapBegin(TType::I64, TType::STRING, count($this->metadata));
{
- foreach ($this->metadata as $kiter495 => $viter496)
+ foreach ($this->metadata as $kiter488 => $viter489)
{
- $xfer += $output->writeI64($kiter495);
- $xfer += $output->writeString($viter496);
+ $xfer += $output->writeI64($kiter488);
+ $xfer += $output->writeString($viter489);
}
}
$output->writeMapEnd();
@@ -14448,14 +14422,14 @@ class GetFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size497 = 0;
- $_etype500 = 0;
- $xfer += $input->readListBegin($_etype500, $_size497);
- for ($_i501 = 0; $_i501 < $_size497; ++$_i501)
+ $_size490 = 0;
+ $_etype493 = 0;
+ $xfer += $input->readListBegin($_etype493, $_size490);
+ for ($_i494 = 0; $_i494 < $_size490; ++$_i494)
{
- $elem502 = null;
- $xfer += $input->readI64($elem502);
- $this->fileIds []= $elem502;
+ $elem495 = null;
+ $xfer += $input->readI64($elem495);
+ $this->fileIds []= $elem495;
}
$xfer += $input->readListEnd();
} else {
@@ -14483,9 +14457,9 @@ class GetFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter503)
+ foreach ($this->fileIds as $iter496)
{
- $xfer += $output->writeI64($iter503);
+ $xfer += $output->writeI64($iter496);
}
}
$output->writeListEnd();
@@ -14614,14 +14588,14 @@ class PutFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size504 = 0;
- $_etype507 = 0;
- $xfer += $input->readListBegin($_etype507, $_size504);
- for ($_i508 = 0; $_i508 < $_size504; ++$_i508)
+ $_size497 = 0;
+ $_etype500 = 0;
+ $xfer += $input->readListBegin($_etype500, $_size497);
+ for ($_i501 = 0; $_i501 < $_size497; ++$_i501)
{
- $elem509 = null;
- $xfer += $input->readI64($elem509);
- $this->fileIds []= $elem509;
+ $elem502 = null;
+ $xfer += $input->readI64($elem502);
+ $this->fileIds []= $elem502;
}
$xfer += $input->readListEnd();
} else {
@@ -14631,14 +14605,14 @@ class PutFileMetadataRequest {
case 2:
if ($ftype == TType::LST) {
$this->metadata = array();
- $_size510 = 0;
- $_etype513 = 0;
- $xfer += $input->readListBegin($_etype513, $_size510);
- for ($_i514 = 0; $_i514 < $_size510; ++$_i514)
+ $_size503 = 0;
+ $_etype506 = 0;
+ $xfer += $input->readListBegin($_etype506, $_size503);
+ for ($_i507 = 0; $_i507 < $_size503; ++$_i507)
{
- $elem515 = null;
- $xfer += $input->readString($elem515);
- $this->metadata []= $elem515;
+ $elem508 = null;
+ $xfer += $input->readString($elem508);
+ $this->metadata []= $elem508;
}
$xfer += $input->readListEnd();
} else {
@@ -14666,9 +14640,9 @@ class PutFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter516)
+ foreach ($this->fileIds as $iter509)
{
- $xfer += $output->writeI64($iter516);
+ $xfer += $output->writeI64($iter509);
}
}
$output->writeListEnd();
@@ -14683,9 +14657,9 @@ class PutFileMetadataRequest {
{
$output->writeListBegin(TType::STRING, count($this->metadata));
{
- foreach ($this->metadata as $iter517)
+ foreach ($this->metadata as $iter510)
{
- $xfer += $output->writeString($iter517);
+ $xfer += $output->writeString($iter510);
}
}
$output->writeListEnd();
@@ -14799,14 +14773,14 @@ class ClearFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size518 = 0;
- $_etype521 = 0;
- $xfer += $input->readListBegin($_etype521, $_size518);
- for ($_i522 = 0; $_i522 < $_size518; ++$_i522)
+ $_size511 = 0;
+ $_etype514 = 0;
+ $xfer += $input->readListBegin($_etype514, $_size511);
+ for ($_i515 = 0; $_i515 < $_size511; ++$_i515)
{
- $elem523 = null;
- $xfer += $input->readI64($elem523);
- $this->fileIds []= $elem523;
+ $elem516 = null;
+ $xfer += $input->readI64($elem516);
+ $this->fileIds []= $elem516;
}
$xfer += $input->readListEnd();
} else {
@@ -14834,9 +14808,9 @@ class ClearFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter524)
+ foreach ($this->fileIds as $iter517)
{
- $xfer += $output->writeI64($iter524);
+ $xfer += $output->writeI64($iter517);
}
}
$output->writeListEnd();
@@ -14901,15 +14875,15 @@ class GetAllFunctionsResponse {
case 1:
if ($ftype == TType::LST) {
$this->functions = array();
- $_size525 = 0;
- $_etype528 = 0;
- $xfer += $input->readListBegin($_etype528, $_size525);
- for ($_i529 = 0; $_i529 < $_size525; ++$_i529)
+ $_size518 = 0;
+ $_etype521 = 0;
+ $xfer += $input->readListBegin($_etype521, $_size518);
+ for ($_i522 = 0; $_i522 < $_size518; ++$_i522)
{
- $elem530 = null;
- $elem530 = new \metastore\Function();
- $xfer += $elem530->read($input);
- $this->functions []= $elem530;
+ $elem523 = null;
+ $elem523 = new \metastore\Function();
+ $xfer += $elem523->read($input);
+ $this->functions []= $elem523;
}
$xfer += $input->readListEnd();
} else {
@@ -14937,9 +14911,9 @@ class GetAllFunctionsResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->functions));
{
- foreach ($this->functions as $iter531)
+ foreach ($this->functions as $iter524)
{
- $xfer += $iter531->write($output);
+ $xfer += $iter524->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/25b15fdd/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 f89320f..8354d38 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -8826,10 +8826,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype532, _size529) = iprot.readListBegin()
- for _i533 in xrange(_size529):
- _elem534 = iprot.readString();
- self.success.append(_elem534)
+ (_etype525, _size522) = iprot.readListBegin()
+ for _i526 in xrange(_size522):
+ _elem527 = iprot.readString();
+ self.success.append(_elem527)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8852,8 +8852,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 iter535 in self.success:
- oprot.writeString(iter535)
+ for iter528 in self.success:
+ oprot.writeString(iter528)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8958,10 +8958,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype539, _size536) = iprot.readListBegin()
- for _i540 in xrange(_size536):
- _elem541 = iprot.readString();
- self.success.append(_elem541)
+ (_etype532, _size529) = iprot.readListBegin()
+ for _i533 in xrange(_size529):
+ _elem534 = iprot.readString();
+ self.success.append(_elem534)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8984,8 +8984,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 iter542 in self.success:
- oprot.writeString(iter542)
+ for iter535 in self.success:
+ oprot.writeString(iter535)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9755,12 +9755,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype544, _vtype545, _size543 ) = iprot.readMapBegin()
- for _i547 in xrange(_size543):
- _key548 = iprot.readString();
- _val549 = Type()
- _val549.read(iprot)
- self.success[_key548] = _val549
+ (_ktype537, _vtype538, _size536 ) = iprot.readMapBegin()
+ for _i540 in xrange(_size536):
+ _key541 = iprot.readString();
+ _val542 = Type()
+ _val542.read(iprot)
+ self.success[_key541] = _val542
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -9783,9 +9783,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 kiter550,viter551 in self.success.items():
- oprot.writeString(kiter550)
- viter551.write(oprot)
+ for kiter543,viter544 in self.success.items():
+ oprot.writeString(kiter543)
+ viter544.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -9928,11 +9928,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype555, _size552) = iprot.readListBegin()
- for _i556 in xrange(_size552):
- _elem557 = FieldSchema()
- _elem557.read(iprot)
- self.success.append(_elem557)
+ (_etype548, _size545) = iprot.readListBegin()
+ for _i549 in xrange(_size545):
+ _elem550 = FieldSchema()
+ _elem550.read(iprot)
+ self.success.append(_elem550)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9967,8 +9967,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 iter558 in self.success:
- iter558.write(oprot)
+ for iter551 in self.success:
+ iter551.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10135,11 +10135,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype562, _size559) = iprot.readListBegin()
- for _i563 in xrange(_size559):
- _elem564 = FieldSchema()
- _elem564.read(iprot)
- self.success.append(_elem564)
+ (_etype555, _size552) = iprot.readListBegin()
+ for _i556 in xrange(_size552):
+ _elem557 = FieldSchema()
+ _elem557.read(iprot)
+ self.success.append(_elem557)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10174,8 +10174,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 iter565 in self.success:
- iter565.write(oprot)
+ for iter558 in self.success:
+ iter558.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10328,11 +10328,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype569, _size566) = iprot.readListBegin()
- for _i570 in xrange(_size566):
- _elem571 = FieldSchema()
- _elem571.read(iprot)
- self.success.append(_elem571)
+ (_etype562, _size559) = iprot.readListBegin()
+ for _i563 in xrange(_size559):
+ _elem564 = FieldSchema()
+ _elem564.read(iprot)
+ self.success.append(_elem564)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10367,8 +10367,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 iter572 in self.success:
- iter572.write(oprot)
+ for iter565 in self.success:
+ iter565.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10535,11 +10535,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype576, _size573) = iprot.readListBegin()
- for _i577 in xrange(_size573):
- _elem578 = FieldSchema()
- _elem578.read(iprot)
- self.success.append(_elem578)
+ (_etype569, _size566) = iprot.readListBegin()
+ for _i570 in xrange(_size566):
+ _elem571 = FieldSchema()
+ _elem571.read(iprot)
+ self.success.append(_elem571)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10574,8 +10574,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 iter579 in self.success:
- iter579.write(oprot)
+ for iter572 in self.success:
+ iter572.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11440,10 +11440,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype583, _size580) = iprot.readListBegin()
- for _i584 in xrange(_size580):
- _elem585 = iprot.readString();
- self.success.append(_elem585)
+ (_etype576, _size573) = iprot.readListBegin()
+ for _i577 in xrange(_size573):
+ _elem578 = iprot.readString();
+ self.success.append(_elem578)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11466,8 +11466,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 iter586 in self.success:
- oprot.writeString(iter586)
+ for iter579 in self.success:
+ oprot.writeString(iter579)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11591,10 +11591,10 @@ class get_all_tables_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)
+ (_etype583, _size580) = iprot.readListBegin()
+ for _i584 in xrange(_size580):
+ _elem585 = iprot.readString();
+ self.success.append(_elem585)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11617,8 +11617,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 iter593 in self.success:
- oprot.writeString(iter593)
+ for iter586 in self.success:
+ oprot.writeString(iter586)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11854,10 +11854,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype597, _size594) = iprot.readListBegin()
- for _i598 in xrange(_size594):
- _elem599 = iprot.readString();
- self.tbl_names.append(_elem599)
+ (_etype590, _size587) = iprot.readListBegin()
+ for _i591 in xrange(_size587):
+ _elem592 = iprot.readString();
+ self.tbl_names.append(_elem592)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11878,8 +11878,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 iter600 in self.tbl_names:
- oprot.writeString(iter600)
+ for iter593 in self.tbl_names:
+ oprot.writeString(iter593)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11940,11 +11940,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype604, _size601) = iprot.readListBegin()
- for _i605 in xrange(_size601):
- _elem606 = Table()
- _elem606.read(iprot)
- self.success.append(_elem606)
+ (_etype597, _size594) = iprot.readListBegin()
+ for _i598 in xrange(_size594):
+ _elem599 = Table()
+ _elem599.read(iprot)
+ self.success.append(_elem599)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11979,8 +11979,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 iter607 in self.success:
- iter607.write(oprot)
+ for iter600 in self.success:
+ iter600.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12146,10 +12146,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype611, _size608) = iprot.readListBegin()
- for _i612 in xrange(_size608):
- _elem613 = iprot.readString();
- self.success.append(_elem613)
+ (_etype604, _size601) = iprot.readListBegin()
+ for _i605 in xrange(_size601):
+ _elem606 = iprot.readString();
+ self.success.append(_elem606)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12184,8 +12184,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 iter614 in self.success:
- oprot.writeString(iter614)
+ for iter607 in self.success:
+ oprot.writeString(iter607)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13155,11 +13155,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype618, _size615) = iprot.readListBegin()
- for _i619 in xrange(_size615):
- _elem620 = Partition()
- _elem620.read(iprot)
- self.new_parts.append(_elem620)
+ (_etype611, _size608) = iprot.readListBegin()
+ for _i612 in xrange(_size608):
+ _elem613 = Partition()
+ _elem613.read(iprot)
+ self.new_parts.append(_elem613)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13176,8 +13176,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 iter621 in self.new_parts:
- iter621.write(oprot)
+ for iter614 in self.new_parts:
+ iter614.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13335,11 +13335,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype625, _size622) = iprot.readListBegin()
- for _i626 in xrange(_size622):
- _elem627 = PartitionSpec()
- _elem627.read(iprot)
- self.new_parts.append(_elem627)
+ (_etype618, _size615) = iprot.readListBegin()
+ for _i619 in xrange(_size615):
+ _elem620 = PartitionSpec()
+ _elem620.read(iprot)
+ self.new_parts.append(_elem620)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13356,8 +13356,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 iter628 in self.new_parts:
- iter628.write(oprot)
+ for iter621 in self.new_parts:
+ iter621.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13531,10 +13531,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype632, _size629) = iprot.readListBegin()
- for _i633 in xrange(_size629):
- _elem634 = iprot.readString();
- self.part_vals.append(_elem634)
+ (_etype625, _size622) = iprot.readListBegin()
+ for _i626 in xrange(_size622):
+ _elem627 = iprot.readString();
+ self.part_vals.append(_elem627)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13559,8 +13559,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 iter635 in self.part_vals:
- oprot.writeString(iter635)
+ for iter628 in self.part_vals:
+ oprot.writeString(iter628)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13913,10 +13913,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype639, _size636) = iprot.readListBegin()
- for _i640 in xrange(_size636):
- _elem641 = iprot.readString();
- self.part_vals.append(_elem641)
+ (_etype632, _size629) = iprot.readListBegin()
+ for _i633 in xrange(_size629):
+ _elem634 = iprot.readString();
+ self.part_vals.append(_elem634)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13947,8 +13947,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 iter642 in self.part_vals:
- oprot.writeString(iter642)
+ for iter635 in self.part_vals:
+ oprot.writeString(iter635)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -14543,10 +14543,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype646, _size643) = iprot.readListBegin()
- for _i647 in xrange(_size643):
- _elem648 = iprot.readString();
- self.part_vals.append(_elem648)
+ (_etype639, _size636) = iprot.readListBegin()
+ for _i640 in xrange(_size636):
+ _elem641 = iprot.readString();
+ self.part_vals.append(_elem641)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14576,8 +14576,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 iter649 in self.part_vals:
- oprot.writeString(iter649)
+ for iter642 in self.part_vals:
+ oprot.writeString(iter642)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -14750,10 +14750,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype653, _size650) = iprot.readListBegin()
- for _i654 in xrange(_size650):
- _elem655 = iprot.readString();
- self.part_vals.append(_elem655)
+ (_etype646, _size643) = iprot.readListBegin()
+ for _i647 in xrange(_size643):
+ _elem648 = iprot.readString();
+ self.part_vals.append(_elem648)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14789,8 +14789,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 iter656 in self.part_vals:
- oprot.writeString(iter656)
+ for iter649 in self.part_vals:
+ oprot.writeString(iter649)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -15527,10 +15527,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype660, _size657) = iprot.readListBegin()
- for _i661 in xrange(_size657):
- _elem662 = iprot.readString();
- self.part_vals.append(_elem662)
+ (_etype653, _size650) = iprot.readListBegin()
+ for _i654 in xrange(_size650):
+ _elem655 = iprot.readString();
+ self.part_vals.append(_elem655)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15555,8 +15555,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 iter663 in self.part_vals:
- oprot.writeString(iter663)
+ for iter656 in self.part_vals:
+ oprot.writeString(iter656)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15715,11 +15715,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype665, _vtype666, _size664 ) = iprot.readMapBegin()
- for _i668 in xrange(_size664):
- _key669 = iprot.readString();
- _val670 = iprot.readString();
- self.partitionSpecs[_key669] = _val670
+ (_ktype658, _vtype659, _size657 ) = iprot.readMapBegin()
+ for _i661 in xrange(_size657):
+ _key662 = iprot.readString();
+ _val663 = iprot.readString();
+ self.partitionSpecs[_key662] = _val663
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -15756,9 +15756,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 kiter671,viter672 in self.partitionSpecs.items():
- oprot.writeString(kiter671)
- oprot.writeString(viter672)
+ for kiter664,viter665 in self.partitionSpecs.items():
+ oprot.writeString(kiter664)
+ oprot.writeString(viter665)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -15973,10 +15973,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype676, _size673) = iprot.readListBegin()
- for _i677 in xrange(_size673):
- _elem678 = iprot.readString();
- self.part_vals.append(_elem678)
+ (_etype669, _size666) = iprot.readListBegin()
+ for _i670 in xrange(_size666):
+ _elem671 = iprot.readString();
+ self.part_vals.append(_elem671)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15988,10 +15988,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype682, _size679) = iprot.readListBegin()
- for _i683 in xrange(_size679):
- _elem684 = iprot.readString();
- self.group_names.append(_elem684)
+ (_etype675, _size672) = iprot.readListBegin()
+ for _i676 in xrange(_size672):
+ _elem677 = iprot.readString();
+ self.group_names.append(_elem677)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16016,8 +16016,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 iter685 in self.part_vals:
- oprot.writeString(iter685)
+ for iter678 in self.part_vals:
+ oprot.writeString(iter678)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -16027,8 +16027,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 iter686 in self.group_names:
- oprot.writeString(iter686)
+ for iter679 in self.group_names:
+ oprot.writeString(iter679)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16457,11 +16457,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = Partition()
- _elem692.read(iprot)
- self.success.append(_elem692)
+ (_etype683, _size680) = iprot.readListBegin()
+ for _i684 in xrange(_size680):
+ _elem685 = Partition()
+ _elem685.read(iprot)
+ self.success.append(_elem685)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16490,8 +16490,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 iter693 in self.success:
- iter693.write(oprot)
+ for iter686 in self.success:
+ iter686.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16585,10 +16585,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = iprot.readString();
- self.group_names.append(_elem699)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = iprot.readString();
+ self.group_names.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16621,8 +16621,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 iter700 in self.group_names:
- oprot.writeString(iter700)
+ for iter693 in self.group_names:
+ oprot.writeString(iter693)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16683,11 +16683,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = Partition()
- _elem706.read(iprot)
- self.success.append(_elem706)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = Partition()
+ _elem699.read(iprot)
+ self.success.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16716,8 +16716,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 iter707 in self.success:
- iter707.write(oprot)
+ for iter700 in self.success:
+ iter700.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16875,11 +16875,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = PartitionSpec()
- _elem713.read(iprot)
- self.success.append(_elem713)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = PartitionSpec()
+ _elem706.read(iprot)
+ self.success.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16908,8 +16908,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 iter714 in self.success:
- iter714.write(oprot)
+ for iter707 in self.success:
+ iter707.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17064,10 +17064,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = iprot.readString();
- self.success.append(_elem720)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = iprot.readString();
+ self.success.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17090,8 +17090,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 iter721 in self.success:
- oprot.writeString(iter721)
+ for iter714 in self.success:
+ oprot.writeString(iter714)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -17167,10 +17167,10 @@ class get_partitions_ps_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)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = iprot.readString();
+ self.part_vals.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17200,8 +17200,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 iter728 in self.part_vals:
- oprot.writeString(iter728)
+ for iter721 in self.part_vals:
+ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -17265,11 +17265,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype732, _size729) = iprot.readListBegin()
- for _i733 in xrange(_size729):
- _elem734 = Partition()
- _elem734.read(iprot)
- self.success.append(_elem734)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = Partition()
+ _elem727.read(iprot)
+ self.success.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17298,8 +17298,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 iter735 in self.success:
- iter735.write(oprot)
+ for iter728 in self.success:
+ iter728.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17386,10 +17386,10 @@ class get_partitions_ps_with_auth_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)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = iprot.readString();
+ self.part_vals.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17406,10 +17406,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype745, _size742) = iprot.readListBegin()
- for _i746 in xrange(_size742):
- _elem747 = iprot.readString();
- self.group_names.append(_elem747)
+ (_etype738, _size735) = iprot.readListBegin()
+ for _i739 in xrange(_size735):
+ _elem740 = iprot.readString();
+ self.group_names.append(_elem740)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17434,8 +17434,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 iter748 in self.part_vals:
- oprot.writeString(iter748)
+ for iter741 in self.part_vals:
+ oprot.writeString(iter741)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -17449,8 +17449,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 iter749 in self.group_names:
- oprot.writeString(iter749)
+ for iter742 in self.group_names:
+ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17512,11 +17512,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype753, _size750) = iprot.readListBegin()
- for _i754 in xrange(_size750):
- _elem755 = Partition()
- _elem755.read(iprot)
- self.success.append(_elem755)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = Partition()
+ _elem748.read(iprot)
+ self.success.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17545,8 +17545,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 iter756 in self.success:
- iter756.write(oprot)
+ for iter749 in self.success:
+ iter749.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17627,10 +17627,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype760, _size757) = iprot.readListBegin()
- for _i761 in xrange(_size757):
- _elem762 = iprot.readString();
- self.part_vals.append(_elem762)
+ (_etype753, _size750) = iprot.readListBegin()
+ for _i754 in xrange(_size750):
+ _elem755 = iprot.readString();
+ self.part_vals.append(_elem755)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17660,8 +17660,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 iter763 in self.part_vals:
- oprot.writeString(iter763)
+ for iter756 in self.part_vals:
+ oprot.writeString(iter756)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -17725,10 +17725,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype767, _size764) = iprot.readListBegin()
- for _i768 in xrange(_size764):
- _elem769 = iprot.readString();
- self.success.append(_elem769)
+ (_etype760, _size757) = iprot.readListBegin()
+ for _i761 in xrange(_size757):
+ _elem762 = iprot.readString();
+ self.success.append(_elem762)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17757,8 +17757,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 iter770 in self.success:
- oprot.writeString(iter770)
+ for iter763 in self.success:
+ oprot.writeString(iter763)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17929,11 +17929,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype774, _size771) = iprot.readListBegin()
- for _i775 in xrange(_size771):
- _elem776 = Partition()
- _elem776.read(iprot)
- self.success.append(_elem776)
+ (_etype767, _size764) = iprot.readListBegin()
+ for _i768 in xrange(_size764):
+ _elem769 = Partition()
+ _elem769.read(iprot)
+ self.success.append(_elem769)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17962,8 +17962,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 iter777 in self.success:
- iter777.write(oprot)
+ for iter770 in self.success:
+ iter770.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18134,11 +18134,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype781, _size778) = iprot.readListBegin()
- for _i782 in xrange(_size778):
- _elem783 = PartitionSpec()
- _elem783.read(iprot)
- self.success.append(_elem783)
+ (_etype774, _size771) = iprot.readListBegin()
+ for _i775 in xrange(_size771):
+ _elem776 = PartitionSpec()
+ _elem776.read(iprot)
+ self.success.append(_elem776)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18167,8 +18167,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 iter784 in self.success:
- iter784.write(oprot)
+ for iter777 in self.success:
+ iter777.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18405,10 +18405,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype788, _size785) = iprot.readListBegin()
- for _i789 in xrange(_size785):
- _elem790 = iprot.readString();
- self.names.append(_elem790)
+ (_etype781, _size778) = iprot.readListBegin()
+ for _i782 in xrange(_size778):
+ _elem783 = iprot.readString();
+ self.names.append(_elem783)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18433,8 +18433,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 iter791 in self.names:
- oprot.writeString(iter791)
+ for iter784 in self.names:
+ oprot.writeString(iter784)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18493,11 +18493,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype795, _size792) = iprot.readListBegin()
- for _i796 in xrange(_size792):
- _elem797 = Partition()
- _elem797.read(iprot)
- self.success.append(_elem797)
+ (_etype788, _size785) = iprot.readListBegin()
+ for _i789 in xrange(_size785):
+ _elem790 = Partition()
+ _elem790.read(iprot)
+ self.success.append(_elem790)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18526,8 +18526,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 iter798 in self.success:
- iter798.write(oprot)
+ for iter791 in self.success:
+ iter791.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18777,11 +18777,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype802, _size799) = iprot.readListBegin()
- for _i803 in xrange(_size799):
- _elem804 = Partition()
- _elem804.read(iprot)
- self.new_parts.append(_elem804)
+ (_etype795, _size792) = iprot.readListBegin()
+ for _i796 in xrange(_size792):
+ _elem797 = Partition()
+ _elem797.read(iprot)
+ self.new_parts.append(_elem797)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18806,8 +18806,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 iter805 in self.new_parts:
- iter805.write(oprot)
+ for iter798 in self.new_parts:
+ iter798.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19146,10 +19146,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype809, _size806) = iprot.readListBegin()
- for _i810 in xrange(_size806):
- _elem811 = iprot.readString();
- self.part_vals.append(_elem811)
+ (_etype802, _size799) = iprot.readListBegin()
+ for _i803 in xrange(_size799):
+ _elem804 = iprot.readString();
+ self.part_vals.append(_elem804)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19180,8 +19180,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 iter812 in self.part_vals:
- oprot.writeString(iter812)
+ for iter805 in self.part_vals:
+ oprot.writeString(iter805)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -19323,10 +19323,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype816, _size813) = iprot.readListBegin()
- for _i817 in xrange(_size813):
- _elem818 = iprot.readString();
- self.part_vals.append(_elem818)
+ (_etype809, _size806) = iprot.readListBegin()
+ for _i810 in xrange(_size806):
+ _elem811 = iprot.readString();
+ self.part_vals.append(_elem811)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19348,8 +19348,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 iter819 in self.part_vals:
- oprot.writeString(iter819)
+ for iter812 in self.part_vals:
+ oprot.writeString(iter812)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -19707,10 +19707,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype823, _size820) = iprot.readListBegin()
- for _i824 in xrange(_size820):
- _elem825 = iprot.readString();
- self.success.append(_elem825)
+ (_etype816, _size813) = iprot.readListBegin()
+ for _i817 in xrange(_size813):
+ _elem818 = iprot.readString();
+ self.success.append(_elem818)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19733,8 +19733,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 iter826 in self.success:
- oprot.writeString(iter826)
+ for iter819 in self.success:
+ oprot.writeString(iter819)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19858,11 +19858,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype828, _vtype829, _size827 ) = iprot.readMapBegin()
- for _i831 in xrange(_size827):
- _key832 = iprot.readString();
- _val833 = iprot.readString();
- self.success[_key832] = _val833
+ (_ktype821, _vtype822, _size820 ) = iprot.readMapBegin()
+ for _i824 in xrange(_size820):
+ _key825 = iprot.readString();
+ _val826 = iprot.readString();
+ self.success[_key825] = _val826
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19885,9 +19885,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 kiter834,viter835 in self.success.items():
- oprot.writeString(kiter834)
- oprot.writeString(viter835)
+ for kiter827,viter828 in self.success.items():
+ oprot.writeString(kiter827)
+ oprot.writeString(viter828)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19963,11 +19963,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype837, _vtype838, _size836 ) = iprot.readMapBegin()
- for _i840 in xrange(_size836):
- _key841 = iprot.readString();
- _val842 = iprot.readString();
- self.part_vals[_key841] = _val842
+ (_ktype830, _vtype831, _size829 ) = iprot.readMapBegin()
+ for _i833 in xrange(_size829):
+ _key834 = iprot.readString();
+ _val835 = iprot.readString();
+ self.part_vals[_key834] = _val835
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19997,9 +19997,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 kiter843,viter844 in self.part_vals.items():
- oprot.writeString(kiter843)
- oprot.writeString(viter844)
+ for kiter836,viter837 in self.part_vals.items():
+ oprot.writeString(kiter836)
+ oprot.writeString(viter837)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -20213,11 +20213,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype846, _vtype847, _size845 ) = iprot.readMapBegin()
- for _i849 in xrange(_size845):
- _key850 = iprot.readString();
- _val851 = iprot.readString();
- self.part_vals[_key850] = _val851
+ (_ktype839, _vtype840, _size838 ) = iprot.readMapBegin()
+ for _i842 in xrange(_size838):
+ _key843 = iprot.readString();
+ _val844 = iprot.readString();
+ self.part_vals[_key843] = _val844
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -20247,9 +20247,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 kiter852,viter853 in self.part_vals.items():
- oprot.writeString(kiter852)
- oprot.writeString(viter853)
+ for kiter845,viter846 in self.part_vals.items():
+ oprot.writeString(kiter845)
+ oprot.writeString(viter846)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -21304,11 +21304,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype857, _size854) = iprot.readListBegin()
- for _i858 in xrange(_size854):
- _elem859 = Index()
- _elem859.read(iprot)
- self.success.append(_elem859)
+ (_etype850, _size847) = iprot.readListBegin()
+ for _i851 in xrange(_size847):
+ _elem852 = Index()
+ _elem852.read(iprot)
+ self.success.append(_elem852)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21337,8 +21337,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 iter860 in self.success:
- iter860.write(oprot)
+ for iter853 in self.success:
+ iter853.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21493,10 +21493,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype864, _size861) = iprot.readListBegin()
- for _i865 in xrange(_size861):
- _elem866 = iprot.readString();
- self.success.append(_elem866)
+ (_etype857, _size854) = iprot.readListBegin()
+ for _i858 in xrange(_size854):
+ _elem859 = iprot.readString();
+ self.success.append(_elem859)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21519,8 +21519,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 iter867 in self.success:
- oprot.writeString(iter867)
+ for iter860 in self.success:
+ oprot.writeString(iter860)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -24068,10 +24068,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype871, _size868) = iprot.readListBegin()
- for _i872 in xrange(_size868):
- _elem873 = iprot.readString();
- self.success.append(_elem873)
+ (_etype864, _size861) = iprot.readListBegin()
+ for _i865 in xrange(_size861):
+ _elem866 = iprot.readString();
+ self.success.append(_elem866)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24094,8 +24094,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 iter874 in self.success:
- oprot.writeString(iter874)
+ for iter867 in self.success:
+ oprot.writeString(iter867)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24783,10 +24783,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype878, _size875) = iprot.readListBegin()
- for _i879 in xrange(_size875):
- _elem880 = iprot.readString();
- self.success.append(_elem880)
+ (_etype871, _size868) = iprot.readListBegin()
+ for _i872 in xrange(_size868):
+ _elem873 = iprot.readString();
+ self.success.append(_elem873)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24809,8 +24809,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 iter881 in self.success:
- oprot.writeString(iter881)
+ for iter874 in self.success:
+ oprot.writeString(iter874)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25324,11 +25324,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype885, _size882) = iprot.readListBegin()
- for _i886 in xrange(_size882):
- _elem887 = Role()
- _elem887.read(iprot)
- self.success.append(_elem887)
+ (_etype878, _size875) = iprot.readListBegin()
+ for _i879 in xrange(_size875):
+ _elem880 = Role()
+ _elem880.read(iprot)
+ self.success.append(_elem880)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25351,8 +25351,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 iter888 in self.success:
- iter888.write(oprot)
+ for iter881 in self.success:
+ iter881.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25861,10 +25861,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype892, _size889) = iprot.readListBegin()
- for _i893 in xrange(_size889):
- _elem894 = iprot.readString();
- self.group_names.append(_elem894)
+ (_etype885, _size882) = iprot.readListBegin()
+ for _i886 in xrange(_size882):
+ _elem887 = iprot.readString();
+ self.group_names.append(_elem887)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25889,8 +25889,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 iter895 in self.group_names:
- oprot.writeString(iter895)
+ for iter888 in self.group_names:
+ oprot.writeString(iter888)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26117,11 +26117,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype899, _size896) = iprot.readListBegin()
- for _i900 in xrange(_size896):
- _elem901 = HiveObjectPrivilege()
- _elem901.read(iprot)
- self.success.append(_elem901)
+ (_etype892, _size889) = iprot.readListBegin()
+ for _i893 in xrange(_size889):
+ _elem894 = HiveObjectPrivilege()
+ _elem894.read(iprot)
+ self.success.append(_elem894)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26144,8 +26144,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 iter902 in self.success:
- iter902.write(oprot)
+ for iter895 in self.success:
+ iter895.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26643,10 +26643,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype906, _size903) = iprot.readListBegin()
- for _i907 in xrange(_size903):
- _elem908 = iprot.readString();
- self.group_names.append(_elem908)
+ (_etype899, _size896) = iprot.readListBegin()
+ for _i900 in xrange(_size896):
+ _elem901 = iprot.readString();
+ self.group_names.append(_elem901)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26667,8 +26667,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 iter909 in self.group_names:
- oprot.writeString(iter909)
+ for iter902 in self.group_names:
+ oprot.writeString(iter902)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26723,10 +26723,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype913, _size910) = iprot.readListBegin()
- for _i914 in xrange(_size910):
- _elem915 = iprot.readString();
- self.success.append(_elem915)
+ (_etype906, _size903) = iprot.readListBegin()
+ for _i907 in xrange(_size903):
+ _elem908 = iprot.readString();
+ self.success.append(_elem908)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26749,8 +26749,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 iter916 in self.success:
- oprot.writeString(iter916)
+ for iter909 in self.success:
+ oprot.writeString(iter909)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
http://git-wip-us.apache.org/repos/asf/hive/blob/25b15fdd/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
index 7fcdd7e..63be238 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
@@ -9808,10 +9808,6 @@ class MetadataPpdResult:
oprot.writeStructEnd()
def validate(self):
- if self.metadata is None:
- raise TProtocol.TProtocolException(message='Required field metadata is unset!')
- if self.includeBitset is None:
- raise TProtocol.TProtocolException(message='Required field includeBitset is unset!')
return
@@ -9837,20 +9833,17 @@ class GetFileMetadataByExprResult:
Attributes:
- metadata
- isSupported
- - unknownFileIds
"""
thrift_spec = (
None, # 0
(1, TType.MAP, 'metadata', (TType.I64,None,TType.STRUCT,(MetadataPpdResult, MetadataPpdResult.thrift_spec)), None, ), # 1
(2, TType.BOOL, 'isSupported', None, None, ), # 2
- (3, TType.LIST, 'unknownFileIds', (TType.I64,None), None, ), # 3
)
- def __init__(self, metadata=None, isSupported=None, unknownFileIds=None,):
+ def __init__(self, metadata=None, isSupported=None,):
self.metadata = metadata
self.isSupported = isSupported
- self.unknownFileIds = unknownFileIds
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:
@@ -9878,16 +9871,6 @@ class GetFileMetadataByExprResult:
self.isSupported = iprot.readBool();
else:
iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.LIST:
- self.unknownFileIds = []
- (_etype472, _size469) = iprot.readListBegin()
- for _i473 in xrange(_size469):
- _elem474 = iprot.readI64();
- self.unknownFileIds.append(_elem474)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -9901,22 +9884,15 @@ class GetFileMetadataByExprResult:
if self.metadata is not None:
oprot.writeFieldBegin('metadata', TType.MAP, 1)
oprot.writeMapBegin(TType.I64, TType.STRUCT, len(self.metadata))
- for kiter475,viter476 in self.metadata.items():
- oprot.writeI64(kiter475)
- viter476.write(oprot)
+ for kiter469,viter470 in self.metadata.items():
+ oprot.writeI64(kiter469)
+ viter470.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.isSupported is not None:
oprot.writeFieldBegin('isSupported', TType.BOOL, 2)
oprot.writeBool(self.isSupported)
oprot.writeFieldEnd()
- if self.unknownFileIds is not None:
- oprot.writeFieldBegin('unknownFileIds', TType.LIST, 3)
- oprot.writeListBegin(TType.I64, len(self.unknownFileIds))
- for iter477 in self.unknownFileIds:
- oprot.writeI64(iter477)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -9925,8 +9901,6 @@ class GetFileMetadataByExprResult:
raise TProtocol.TProtocolException(message='Required field metadata is unset!')
if self.isSupported is None:
raise TProtocol.TProtocolException(message='Required field isSupported is unset!')
- if self.unknownFileIds is None:
- raise TProtocol.TProtocolException(message='Required field unknownFileIds is unset!')
return
@@ -9934,7 +9908,6 @@ class GetFileMetadataByExprResult:
value = 17
value = (value * 31) ^ hash(self.metadata)
value = (value * 31) ^ hash(self.isSupported)
- value = (value * 31) ^ hash(self.unknownFileIds)
return value
def __repr__(self):
@@ -9953,17 +9926,20 @@ class GetFileMetadataByExprRequest:
Attributes:
- fileIds
- expr
+ - doGetFooters
"""
thrift_spec = (
None, # 0
(1, TType.LIST, 'fileIds', (TType.I64,None), None, ), # 1
(2, TType.STRING, 'expr', None, None, ), # 2
+ (3, TType.BOOL, 'doGetFooters', None, None, ), # 3
)
- def __init__(self, fileIds=None, expr=None,):
+ def __init__(self, fileIds=None, expr=None, doGetFooters=None,):
self.fileIds = fileIds
self.expr = expr
+ self.doGetFooters = doGetFooters
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:
@@ -9977,10 +9953,10 @@ class GetFileMetadataByExprRequest:
if fid == 1:
if ftype == TType.LIST:
self.fileIds = []
- (_etype481, _size478) = iprot.readListBegin()
- for _i482 in xrange(_size478):
- _elem483 = iprot.readI64();
- self.fileIds.append(_elem483)
+ (_etype474, _size471) = iprot.readListBegin()
+ for _i475 in xrange(_size471):
+ _elem476 = iprot.readI64();
+ self.fileIds.append(_elem476)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9989,6 +9965,11 @@ class GetFileMetadataByExprRequest:
self.expr = iprot.readString();
else:
iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.BOOL:
+ self.doGetFooters = iprot.readBool();
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -10002,14 +9983,18 @@ class GetFileMetadataByExprRequest:
if self.fileIds is not None:
oprot.writeFieldBegin('fileIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.fileIds))
- for iter484 in self.fileIds:
- oprot.writeI64(iter484)
+ for iter477 in self.fileIds:
+ oprot.writeI64(iter477)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.expr is not None:
oprot.writeFieldBegin('expr', TType.STRING, 2)
oprot.writeString(self.expr)
oprot.writeFieldEnd()
+ if self.doGetFooters is not None:
+ oprot.writeFieldBegin('doGetFooters', TType.BOOL, 3)
+ oprot.writeBool(self.doGetFooters)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -10025,6 +10010,7 @@ class GetFileMetadataByExprRequest:
value = 17
value = (value * 31) ^ hash(self.fileIds)
value = (value * 31) ^ hash(self.expr)
+ value = (value * 31) ^ hash(self.doGetFooters)
return value
def __repr__(self):
@@ -10067,11 +10053,11 @@ class GetFileMetadataResult:
if fid == 1:
if ftype == TType.MAP:
self.metadata = {}
- (_ktype486, _vtype487, _size485 ) = iprot.readMapBegin()
- for _i489 in xrange(_size485):
- _key490 = iprot.readI64();
- _val491 = iprot.readString();
- self.metadata[_key490] = _val491
+ (_ktype479, _vtype480, _size478 ) = iprot.readMapBegin()
+ for _i482 in xrange(_size478):
+ _key483 = iprot.readI64();
+ _val484 = iprot.readString();
+ self.metadata[_key483] = _val484
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -10093,9 +10079,9 @@ class GetFileMetadataResult:
if self.metadata is not None:
oprot.writeFieldBegin('metadata', TType.MAP, 1)
oprot.writeMapBegin(TType.I64, TType.STRING, len(self.metadata))
- for kiter492,viter493 in self.metadata.items():
- oprot.writeI64(kiter492)
- oprot.writeString(viter493)
+ for kiter485,viter486 in self.metadata.items():
+ oprot.writeI64(kiter485)
+ oprot.writeString(viter486)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.isSupported is not None:
@@ -10156,10 +10142,10 @@ class GetFileMetadataRequest:
if fid == 1:
if ftype == TType.LIST:
self.fileIds = []
- (_etype497, _size494) = iprot.readListBegin()
- for _i498 in xrange(_size494):
- _elem499 = iprot.readI64();
- self.fileIds.append(_elem499)
+ (_etype490, _size487) = iprot.readListBegin()
+ for _i491 in xrange(_size487):
+ _elem492 = iprot.readI64();
+ self.fileIds.append(_elem492)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10176,8 +10162,8 @@ class GetFileMetadataRequest:
if self.fileIds is not None:
oprot.writeFieldBegin('fileIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.fileIds))
- for iter500 in self.fileIds:
- oprot.writeI64(iter500)
+ for iter493 in self.fileIds:
+ oprot.writeI64(iter493)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10280,20 +10266,20 @@ class PutFileMetadataRequest:
if fid == 1:
if ftype == TType.LIST:
self.fileIds = []
- (_etype504, _size501) = iprot.readListBegin()
- for _i505 in xrange(_size501):
- _elem506 = iprot.readI64();
- self.fileIds.append(_elem506)
+ (_etype497, _size494) = iprot.readListBegin()
+ for _i498 in xrange(_size494):
+ _elem499 = iprot.readI64();
+ self.fileIds.append(_elem499)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.LIST:
self.metadata = []
- (_etype510, _size507) = iprot.readListBegin()
- for _i511 in xrange(_size507):
- _elem512 = iprot.readString();
- self.metadata.append(_elem512)
+ (_etype503, _size500) = iprot.readListBegin()
+ for _i504 in xrange(_size500):
+ _elem505 = iprot.readString();
+ self.metadata.append(_elem505)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10310,15 +10296,15 @@ class PutFileMetadataRequest:
if self.fileIds is not None:
oprot.writeFieldBegin('fileIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.fileIds))
- for iter513 in self.fileIds:
- oprot.writeI64(iter513)
+ for iter506 in self.fileIds:
+ oprot.writeI64(iter506)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.metadata is not None:
oprot.writeFieldBegin('metadata', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.metadata))
- for iter514 in self.metadata:
- oprot.writeString(iter514)
+ for iter507 in self.metadata:
+ oprot.writeString(iter507)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10421,10 +10407,10 @@ class ClearFileMetadataRequest:
if fid == 1:
if ftype == TType.LIST:
self.fileIds = []
- (_etype518, _size515) = iprot.readListBegin()
- for _i519 in xrange(_size515):
- _elem520 = iprot.readI64();
- self.fileIds.append(_elem520)
+ (_etype511, _size508) = iprot.readListBegin()
+ for _i512 in xrange(_size508):
+ _elem513 = iprot.readI64();
+ self.fileIds.append(_elem513)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10441,8 +10427,8 @@ class ClearFileMetadataRequest:
if self.fileIds is not None:
oprot.writeFieldBegin('fileIds', TType.LIST, 1)
oprot.writeListBegin(TType.I64, len(self.fileIds))
- for iter521 in self.fileIds:
- oprot.writeI64(iter521)
+ for iter514 in self.fileIds:
+ oprot.writeI64(iter514)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10496,11 +10482,11 @@ class GetAllFunctionsResponse:
if fid == 1:
if ftype == TType.LIST:
self.functions = []
- (_etype525, _size522) = iprot.readListBegin()
- for _i526 in xrange(_size522):
- _elem527 = Function()
- _elem527.read(iprot)
- self.functions.append(_elem527)
+ (_etype518, _size515) = iprot.readListBegin()
+ for _i519 in xrange(_size515):
+ _elem520 = Function()
+ _elem520.read(iprot)
+ self.functions.append(_elem520)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10517,8 +10503,8 @@ class GetAllFunctionsResponse:
if self.functions is not None:
oprot.writeFieldBegin('functions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.functions))
- for iter528 in self.functions:
- iter528.write(oprot)
+ for iter521 in self.functions:
+ iter521.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
http://git-wip-us.apache.org/repos/asf/hive/blob/25b15fdd/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb b/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
index 771de51..d231fc1 100644
--- a/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
+++ b/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
@@ -2237,15 +2237,13 @@ class MetadataPpdResult
INCLUDEBITSET = 2
FIELDS = {
- METADATA => {:type => ::Thrift::Types::STRING, :name => 'metadata', :binary => true},
- INCLUDEBITSET => {:type => ::Thrift::Types::STRING, :name => 'includeBitset', :binary => true}
+ METADATA => {:type => ::Thrift::Types::STRING, :name => 'metadata', :binary => true, :optional => true},
+ INCLUDEBITSET => {:type => ::Thrift::Types::STRING, :name => 'includeBitset', :binary => true, :optional => true}
}
def struct_fields; FIELDS; end
def validate
- raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field metadata is unset!') unless @metadata
- raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field includeBitset is unset!') unless @includeBitset
end
::Thrift::Struct.generate_accessors self
@@ -2255,12 +2253,10 @@ class GetFileMetadataByExprResult
include ::Thrift::Struct, ::Thrift::Struct_Union
METADATA = 1
ISSUPPORTED = 2
- UNKNOWNFILEIDS = 3
FIELDS = {
METADATA => {:type => ::Thrift::Types::MAP, :name => 'metadata', :key => {:type => ::Thrift::Types::I64}, :value => {:type => ::Thrift::Types::STRUCT, :class => ::MetadataPpdResult}},
- ISSUPPORTED => {:type => ::Thrift::Types::BOOL, :name => 'isSupported'},
- UNKNOWNFILEIDS => {:type => ::Thrift::Types::LIST, :name => 'unknownFileIds', :element => {:type => ::Thrift::Types::I64}}
+ ISSUPPORTED => {:type => ::Thrift::Types::BOOL, :name => 'isSupported'}
}
def struct_fields; FIELDS; end
@@ -2268,7 +2264,6 @@ class GetFileMetadataByExprResult
def validate
raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field metadata is unset!') unless @metadata
raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field isSupported is unset!') if @isSupported.nil?
- raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field unknownFileIds is unset!') unless @unknownFileIds
end
::Thrift::Struct.generate_accessors self
@@ -2278,10 +2273,12 @@ class GetFileMetadataByExprRequest
include ::Thrift::Struct, ::Thrift::Struct_Union
FILEIDS = 1
EXPR = 2
+ DOGETFOOTERS = 3
FIELDS = {
FILEIDS => {:type => ::Thrift::Types::LIST, :name => 'fileIds', :element => {:type => ::Thrift::Types::I64}},
- EXPR => {:type => ::Thrift::Types::STRING, :name => 'expr', :binary => true}
+ EXPR => {:type => ::Thrift::Types::STRING, :name => 'expr', :binary => true},
+ DOGETFOOTERS => {:type => ::Thrift::Types::BOOL, :name => 'doGetFooters', :optional => true}
}
def struct_fields; FIELDS; end