You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2016/05/27 22:14:15 UTC
[2/7] hive git commit: HIVE-13354 : Add ability to specify Compaction
options per table and per request (Wei Zheng, reviewed by Eugene Koifman)
http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/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 045864a..925eea4 100644
--- a/metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -12797,6 +12797,10 @@ class CompactionRequest {
* @var string
*/
public $runas = null;
+ /**
+ * @var array
+ */
+ public $properties = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -12821,6 +12825,18 @@ class CompactionRequest {
'var' => 'runas',
'type' => TType::STRING,
),
+ 6 => array(
+ 'var' => 'properties',
+ 'type' => TType::MAP,
+ 'ktype' => TType::STRING,
+ 'vtype' => TType::STRING,
+ 'key' => array(
+ 'type' => TType::STRING,
+ ),
+ 'val' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
);
}
if (is_array($vals)) {
@@ -12839,6 +12855,9 @@ class CompactionRequest {
if (isset($vals['runas'])) {
$this->runas = $vals['runas'];
}
+ if (isset($vals['properties'])) {
+ $this->properties = $vals['properties'];
+ }
}
}
@@ -12896,6 +12915,26 @@ class CompactionRequest {
$xfer += $input->skip($ftype);
}
break;
+ case 6:
+ if ($ftype == TType::MAP) {
+ $this->properties = array();
+ $_size437 = 0;
+ $_ktype438 = 0;
+ $_vtype439 = 0;
+ $xfer += $input->readMapBegin($_ktype438, $_vtype439, $_size437);
+ for ($_i441 = 0; $_i441 < $_size437; ++$_i441)
+ {
+ $key442 = '';
+ $val443 = '';
+ $xfer += $input->readString($key442);
+ $xfer += $input->readString($val443);
+ $this->properties[$key442] = $val443;
+ }
+ $xfer += $input->readMapEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -12934,6 +12973,24 @@ class CompactionRequest {
$xfer += $output->writeString($this->runas);
$xfer += $output->writeFieldEnd();
}
+ if ($this->properties !== null) {
+ if (!is_array($this->properties)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('properties', TType::MAP, 6);
+ {
+ $output->writeMapBegin(TType::STRING, TType::STRING, count($this->properties));
+ {
+ foreach ($this->properties as $kiter444 => $viter445)
+ {
+ $xfer += $output->writeString($kiter444);
+ $xfer += $output->writeString($viter445);
+ }
+ }
+ $output->writeMapEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -13370,15 +13427,15 @@ class ShowCompactResponse {
case 1:
if ($ftype == TType::LST) {
$this->compacts = array();
- $_size437 = 0;
- $_etype440 = 0;
- $xfer += $input->readListBegin($_etype440, $_size437);
- for ($_i441 = 0; $_i441 < $_size437; ++$_i441)
+ $_size446 = 0;
+ $_etype449 = 0;
+ $xfer += $input->readListBegin($_etype449, $_size446);
+ for ($_i450 = 0; $_i450 < $_size446; ++$_i450)
{
- $elem442 = null;
- $elem442 = new \metastore\ShowCompactResponseElement();
- $xfer += $elem442->read($input);
- $this->compacts []= $elem442;
+ $elem451 = null;
+ $elem451 = new \metastore\ShowCompactResponseElement();
+ $xfer += $elem451->read($input);
+ $this->compacts []= $elem451;
}
$xfer += $input->readListEnd();
} else {
@@ -13406,9 +13463,9 @@ class ShowCompactResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->compacts));
{
- foreach ($this->compacts as $iter443)
+ foreach ($this->compacts as $iter452)
{
- $xfer += $iter443->write($output);
+ $xfer += $iter452->write($output);
}
}
$output->writeListEnd();
@@ -13537,14 +13594,14 @@ class AddDynamicPartitions {
case 4:
if ($ftype == TType::LST) {
$this->partitionnames = array();
- $_size444 = 0;
- $_etype447 = 0;
- $xfer += $input->readListBegin($_etype447, $_size444);
- for ($_i448 = 0; $_i448 < $_size444; ++$_i448)
+ $_size453 = 0;
+ $_etype456 = 0;
+ $xfer += $input->readListBegin($_etype456, $_size453);
+ for ($_i457 = 0; $_i457 < $_size453; ++$_i457)
{
- $elem449 = null;
- $xfer += $input->readString($elem449);
- $this->partitionnames []= $elem449;
+ $elem458 = null;
+ $xfer += $input->readString($elem458);
+ $this->partitionnames []= $elem458;
}
$xfer += $input->readListEnd();
} else {
@@ -13594,9 +13651,9 @@ class AddDynamicPartitions {
{
$output->writeListBegin(TType::STRING, count($this->partitionnames));
{
- foreach ($this->partitionnames as $iter450)
+ foreach ($this->partitionnames as $iter459)
{
- $xfer += $output->writeString($iter450);
+ $xfer += $output->writeString($iter459);
}
}
$output->writeListEnd();
@@ -13954,15 +14011,15 @@ class NotificationEventResponse {
case 1:
if ($ftype == TType::LST) {
$this->events = array();
- $_size451 = 0;
- $_etype454 = 0;
- $xfer += $input->readListBegin($_etype454, $_size451);
- for ($_i455 = 0; $_i455 < $_size451; ++$_i455)
+ $_size460 = 0;
+ $_etype463 = 0;
+ $xfer += $input->readListBegin($_etype463, $_size460);
+ for ($_i464 = 0; $_i464 < $_size460; ++$_i464)
{
- $elem456 = null;
- $elem456 = new \metastore\NotificationEvent();
- $xfer += $elem456->read($input);
- $this->events []= $elem456;
+ $elem465 = null;
+ $elem465 = new \metastore\NotificationEvent();
+ $xfer += $elem465->read($input);
+ $this->events []= $elem465;
}
$xfer += $input->readListEnd();
} else {
@@ -13990,9 +14047,9 @@ class NotificationEventResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->events));
{
- foreach ($this->events as $iter457)
+ foreach ($this->events as $iter466)
{
- $xfer += $iter457->write($output);
+ $xfer += $iter466->write($output);
}
}
$output->writeListEnd();
@@ -14131,14 +14188,14 @@ class InsertEventRequestData {
case 1:
if ($ftype == TType::LST) {
$this->filesAdded = array();
- $_size458 = 0;
- $_etype461 = 0;
- $xfer += $input->readListBegin($_etype461, $_size458);
- for ($_i462 = 0; $_i462 < $_size458; ++$_i462)
+ $_size467 = 0;
+ $_etype470 = 0;
+ $xfer += $input->readListBegin($_etype470, $_size467);
+ for ($_i471 = 0; $_i471 < $_size467; ++$_i471)
{
- $elem463 = null;
- $xfer += $input->readString($elem463);
- $this->filesAdded []= $elem463;
+ $elem472 = null;
+ $xfer += $input->readString($elem472);
+ $this->filesAdded []= $elem472;
}
$xfer += $input->readListEnd();
} else {
@@ -14166,9 +14223,9 @@ class InsertEventRequestData {
{
$output->writeListBegin(TType::STRING, count($this->filesAdded));
{
- foreach ($this->filesAdded as $iter464)
+ foreach ($this->filesAdded as $iter473)
{
- $xfer += $output->writeString($iter464);
+ $xfer += $output->writeString($iter473);
}
}
$output->writeListEnd();
@@ -14386,14 +14443,14 @@ class FireEventRequest {
case 5:
if ($ftype == TType::LST) {
$this->partitionVals = array();
- $_size465 = 0;
- $_etype468 = 0;
- $xfer += $input->readListBegin($_etype468, $_size465);
- for ($_i469 = 0; $_i469 < $_size465; ++$_i469)
+ $_size474 = 0;
+ $_etype477 = 0;
+ $xfer += $input->readListBegin($_etype477, $_size474);
+ for ($_i478 = 0; $_i478 < $_size474; ++$_i478)
{
- $elem470 = null;
- $xfer += $input->readString($elem470);
- $this->partitionVals []= $elem470;
+ $elem479 = null;
+ $xfer += $input->readString($elem479);
+ $this->partitionVals []= $elem479;
}
$xfer += $input->readListEnd();
} else {
@@ -14444,9 +14501,9 @@ class FireEventRequest {
{
$output->writeListBegin(TType::STRING, count($this->partitionVals));
{
- foreach ($this->partitionVals as $iter471)
+ foreach ($this->partitionVals as $iter480)
{
- $xfer += $output->writeString($iter471);
+ $xfer += $output->writeString($iter480);
}
}
$output->writeListEnd();
@@ -14561,15 +14618,15 @@ class GetAllFunctionsResponse {
case 1:
if ($ftype == TType::LST) {
$this->functions = array();
- $_size472 = 0;
- $_etype475 = 0;
- $xfer += $input->readListBegin($_etype475, $_size472);
- for ($_i476 = 0; $_i476 < $_size472; ++$_i476)
+ $_size481 = 0;
+ $_etype484 = 0;
+ $xfer += $input->readListBegin($_etype484, $_size481);
+ for ($_i485 = 0; $_i485 < $_size481; ++$_i485)
{
- $elem477 = null;
- $elem477 = new \metastore\Function();
- $xfer += $elem477->read($input);
- $this->functions []= $elem477;
+ $elem486 = null;
+ $elem486 = new \metastore\Function();
+ $xfer += $elem486->read($input);
+ $this->functions []= $elem486;
}
$xfer += $input->readListEnd();
} else {
@@ -14597,9 +14654,9 @@ class GetAllFunctionsResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->functions));
{
- foreach ($this->functions as $iter478)
+ foreach ($this->functions as $iter487)
{
- $xfer += $iter478->write($output);
+ $xfer += $iter487->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/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 d739752..73a375d 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -9862,10 +9862,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype479, _size476) = iprot.readListBegin()
- for _i480 in xrange(_size476):
- _elem481 = iprot.readString()
- self.success.append(_elem481)
+ (_etype488, _size485) = iprot.readListBegin()
+ for _i489 in xrange(_size485):
+ _elem490 = iprot.readString()
+ self.success.append(_elem490)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9888,8 +9888,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 iter482 in self.success:
- oprot.writeString(iter482)
+ for iter491 in self.success:
+ oprot.writeString(iter491)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9994,10 +9994,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype486, _size483) = iprot.readListBegin()
- for _i487 in xrange(_size483):
- _elem488 = iprot.readString()
- self.success.append(_elem488)
+ (_etype495, _size492) = iprot.readListBegin()
+ for _i496 in xrange(_size492):
+ _elem497 = iprot.readString()
+ self.success.append(_elem497)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10020,8 +10020,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 iter489 in self.success:
- oprot.writeString(iter489)
+ for iter498 in self.success:
+ oprot.writeString(iter498)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10791,12 +10791,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype491, _vtype492, _size490 ) = iprot.readMapBegin()
- for _i494 in xrange(_size490):
- _key495 = iprot.readString()
- _val496 = Type()
- _val496.read(iprot)
- self.success[_key495] = _val496
+ (_ktype500, _vtype501, _size499 ) = iprot.readMapBegin()
+ for _i503 in xrange(_size499):
+ _key504 = iprot.readString()
+ _val505 = Type()
+ _val505.read(iprot)
+ self.success[_key504] = _val505
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -10819,9 +10819,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 kiter497,viter498 in self.success.items():
- oprot.writeString(kiter497)
- viter498.write(oprot)
+ for kiter506,viter507 in self.success.items():
+ oprot.writeString(kiter506)
+ viter507.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -10964,11 +10964,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype502, _size499) = iprot.readListBegin()
- for _i503 in xrange(_size499):
- _elem504 = FieldSchema()
- _elem504.read(iprot)
- self.success.append(_elem504)
+ (_etype511, _size508) = iprot.readListBegin()
+ for _i512 in xrange(_size508):
+ _elem513 = FieldSchema()
+ _elem513.read(iprot)
+ self.success.append(_elem513)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11003,8 +11003,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 iter505 in self.success:
- iter505.write(oprot)
+ for iter514 in self.success:
+ iter514.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11171,11 +11171,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype509, _size506) = iprot.readListBegin()
- for _i510 in xrange(_size506):
- _elem511 = FieldSchema()
- _elem511.read(iprot)
- self.success.append(_elem511)
+ (_etype518, _size515) = iprot.readListBegin()
+ for _i519 in xrange(_size515):
+ _elem520 = FieldSchema()
+ _elem520.read(iprot)
+ self.success.append(_elem520)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11210,8 +11210,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 iter512 in self.success:
- iter512.write(oprot)
+ for iter521 in self.success:
+ iter521.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11364,11 +11364,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype516, _size513) = iprot.readListBegin()
- for _i517 in xrange(_size513):
- _elem518 = FieldSchema()
- _elem518.read(iprot)
- self.success.append(_elem518)
+ (_etype525, _size522) = iprot.readListBegin()
+ for _i526 in xrange(_size522):
+ _elem527 = FieldSchema()
+ _elem527.read(iprot)
+ self.success.append(_elem527)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11403,8 +11403,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 iter519 in self.success:
- iter519.write(oprot)
+ for iter528 in self.success:
+ iter528.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11571,11 +11571,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype523, _size520) = iprot.readListBegin()
- for _i524 in xrange(_size520):
- _elem525 = FieldSchema()
- _elem525.read(iprot)
- self.success.append(_elem525)
+ (_etype532, _size529) = iprot.readListBegin()
+ for _i533 in xrange(_size529):
+ _elem534 = FieldSchema()
+ _elem534.read(iprot)
+ self.success.append(_elem534)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11610,8 +11610,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 iter526 in self.success:
- iter526.write(oprot)
+ for iter535 in self.success:
+ iter535.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12476,10 +12476,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype530, _size527) = iprot.readListBegin()
- for _i531 in xrange(_size527):
- _elem532 = iprot.readString()
- self.success.append(_elem532)
+ (_etype539, _size536) = iprot.readListBegin()
+ for _i540 in xrange(_size536):
+ _elem541 = iprot.readString()
+ self.success.append(_elem541)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12502,8 +12502,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 iter533 in self.success:
- oprot.writeString(iter533)
+ for iter542 in self.success:
+ oprot.writeString(iter542)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12627,10 +12627,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype537, _size534) = iprot.readListBegin()
- for _i538 in xrange(_size534):
- _elem539 = iprot.readString()
- self.success.append(_elem539)
+ (_etype546, _size543) = iprot.readListBegin()
+ for _i547 in xrange(_size543):
+ _elem548 = iprot.readString()
+ self.success.append(_elem548)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12653,8 +12653,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 iter540 in self.success:
- oprot.writeString(iter540)
+ for iter549 in self.success:
+ oprot.writeString(iter549)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12890,10 +12890,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype544, _size541) = iprot.readListBegin()
- for _i545 in xrange(_size541):
- _elem546 = iprot.readString()
- self.tbl_names.append(_elem546)
+ (_etype553, _size550) = iprot.readListBegin()
+ for _i554 in xrange(_size550):
+ _elem555 = iprot.readString()
+ self.tbl_names.append(_elem555)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12914,8 +12914,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 iter547 in self.tbl_names:
- oprot.writeString(iter547)
+ for iter556 in self.tbl_names:
+ oprot.writeString(iter556)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12976,11 +12976,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype551, _size548) = iprot.readListBegin()
- for _i552 in xrange(_size548):
- _elem553 = Table()
- _elem553.read(iprot)
- self.success.append(_elem553)
+ (_etype560, _size557) = iprot.readListBegin()
+ for _i561 in xrange(_size557):
+ _elem562 = Table()
+ _elem562.read(iprot)
+ self.success.append(_elem562)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13015,8 +13015,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 iter554 in self.success:
- iter554.write(oprot)
+ for iter563 in self.success:
+ iter563.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13182,10 +13182,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype558, _size555) = iprot.readListBegin()
- for _i559 in xrange(_size555):
- _elem560 = iprot.readString()
- self.success.append(_elem560)
+ (_etype567, _size564) = iprot.readListBegin()
+ for _i568 in xrange(_size564):
+ _elem569 = iprot.readString()
+ self.success.append(_elem569)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13220,8 +13220,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 iter561 in self.success:
- oprot.writeString(iter561)
+ for iter570 in self.success:
+ oprot.writeString(iter570)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14191,11 +14191,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype565, _size562) = iprot.readListBegin()
- for _i566 in xrange(_size562):
- _elem567 = Partition()
- _elem567.read(iprot)
- self.new_parts.append(_elem567)
+ (_etype574, _size571) = iprot.readListBegin()
+ for _i575 in xrange(_size571):
+ _elem576 = Partition()
+ _elem576.read(iprot)
+ self.new_parts.append(_elem576)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14212,8 +14212,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 iter568 in self.new_parts:
- iter568.write(oprot)
+ for iter577 in self.new_parts:
+ iter577.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14371,11 +14371,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype572, _size569) = iprot.readListBegin()
- for _i573 in xrange(_size569):
- _elem574 = PartitionSpec()
- _elem574.read(iprot)
- self.new_parts.append(_elem574)
+ (_etype581, _size578) = iprot.readListBegin()
+ for _i582 in xrange(_size578):
+ _elem583 = PartitionSpec()
+ _elem583.read(iprot)
+ self.new_parts.append(_elem583)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14392,8 +14392,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 iter575 in self.new_parts:
- iter575.write(oprot)
+ for iter584 in self.new_parts:
+ iter584.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14567,10 +14567,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype579, _size576) = iprot.readListBegin()
- for _i580 in xrange(_size576):
- _elem581 = iprot.readString()
- self.part_vals.append(_elem581)
+ (_etype588, _size585) = iprot.readListBegin()
+ for _i589 in xrange(_size585):
+ _elem590 = iprot.readString()
+ self.part_vals.append(_elem590)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14595,8 +14595,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 iter582 in self.part_vals:
- oprot.writeString(iter582)
+ for iter591 in self.part_vals:
+ oprot.writeString(iter591)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14949,10 +14949,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype586, _size583) = iprot.readListBegin()
- for _i587 in xrange(_size583):
- _elem588 = iprot.readString()
- self.part_vals.append(_elem588)
+ (_etype595, _size592) = iprot.readListBegin()
+ for _i596 in xrange(_size592):
+ _elem597 = iprot.readString()
+ self.part_vals.append(_elem597)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14983,8 +14983,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 iter589 in self.part_vals:
- oprot.writeString(iter589)
+ for iter598 in self.part_vals:
+ oprot.writeString(iter598)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -15579,10 +15579,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype593, _size590) = iprot.readListBegin()
- for _i594 in xrange(_size590):
- _elem595 = iprot.readString()
- self.part_vals.append(_elem595)
+ (_etype602, _size599) = iprot.readListBegin()
+ for _i603 in xrange(_size599):
+ _elem604 = iprot.readString()
+ self.part_vals.append(_elem604)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15612,8 +15612,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 iter596 in self.part_vals:
- oprot.writeString(iter596)
+ for iter605 in self.part_vals:
+ oprot.writeString(iter605)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -15786,10 +15786,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype600, _size597) = iprot.readListBegin()
- for _i601 in xrange(_size597):
- _elem602 = iprot.readString()
- self.part_vals.append(_elem602)
+ (_etype609, _size606) = iprot.readListBegin()
+ for _i610 in xrange(_size606):
+ _elem611 = iprot.readString()
+ self.part_vals.append(_elem611)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15825,8 +15825,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 iter603 in self.part_vals:
- oprot.writeString(iter603)
+ for iter612 in self.part_vals:
+ oprot.writeString(iter612)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -16563,10 +16563,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype607, _size604) = iprot.readListBegin()
- for _i608 in xrange(_size604):
- _elem609 = iprot.readString()
- self.part_vals.append(_elem609)
+ (_etype616, _size613) = iprot.readListBegin()
+ for _i617 in xrange(_size613):
+ _elem618 = iprot.readString()
+ self.part_vals.append(_elem618)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16591,8 +16591,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 iter610 in self.part_vals:
- oprot.writeString(iter610)
+ for iter619 in self.part_vals:
+ oprot.writeString(iter619)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16751,11 +16751,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype612, _vtype613, _size611 ) = iprot.readMapBegin()
- for _i615 in xrange(_size611):
- _key616 = iprot.readString()
- _val617 = iprot.readString()
- self.partitionSpecs[_key616] = _val617
+ (_ktype621, _vtype622, _size620 ) = iprot.readMapBegin()
+ for _i624 in xrange(_size620):
+ _key625 = iprot.readString()
+ _val626 = iprot.readString()
+ self.partitionSpecs[_key625] = _val626
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16792,9 +16792,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 kiter618,viter619 in self.partitionSpecs.items():
- oprot.writeString(kiter618)
- oprot.writeString(viter619)
+ for kiter627,viter628 in self.partitionSpecs.items():
+ oprot.writeString(kiter627)
+ oprot.writeString(viter628)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -16999,11 +16999,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype621, _vtype622, _size620 ) = iprot.readMapBegin()
- for _i624 in xrange(_size620):
- _key625 = iprot.readString()
- _val626 = iprot.readString()
- self.partitionSpecs[_key625] = _val626
+ (_ktype630, _vtype631, _size629 ) = iprot.readMapBegin()
+ for _i633 in xrange(_size629):
+ _key634 = iprot.readString()
+ _val635 = iprot.readString()
+ self.partitionSpecs[_key634] = _val635
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -17040,9 +17040,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 kiter627,viter628 in self.partitionSpecs.items():
- oprot.writeString(kiter627)
- oprot.writeString(viter628)
+ for kiter636,viter637 in self.partitionSpecs.items():
+ oprot.writeString(kiter636)
+ oprot.writeString(viter637)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -17125,11 +17125,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype632, _size629) = iprot.readListBegin()
- for _i633 in xrange(_size629):
- _elem634 = Partition()
- _elem634.read(iprot)
- self.success.append(_elem634)
+ (_etype641, _size638) = iprot.readListBegin()
+ for _i642 in xrange(_size638):
+ _elem643 = Partition()
+ _elem643.read(iprot)
+ self.success.append(_elem643)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17170,8 +17170,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 iter635 in self.success:
- iter635.write(oprot)
+ for iter644 in self.success:
+ iter644.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17265,10 +17265,10 @@ class get_partition_with_auth_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)
+ (_etype648, _size645) = iprot.readListBegin()
+ for _i649 in xrange(_size645):
+ _elem650 = iprot.readString()
+ self.part_vals.append(_elem650)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17280,10 +17280,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype645, _size642) = iprot.readListBegin()
- for _i646 in xrange(_size642):
- _elem647 = iprot.readString()
- self.group_names.append(_elem647)
+ (_etype654, _size651) = iprot.readListBegin()
+ for _i655 in xrange(_size651):
+ _elem656 = iprot.readString()
+ self.group_names.append(_elem656)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17308,8 +17308,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 iter648 in self.part_vals:
- oprot.writeString(iter648)
+ for iter657 in self.part_vals:
+ oprot.writeString(iter657)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -17319,8 +17319,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 iter649 in self.group_names:
- oprot.writeString(iter649)
+ for iter658 in self.group_names:
+ oprot.writeString(iter658)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17749,11 +17749,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype653, _size650) = iprot.readListBegin()
- for _i654 in xrange(_size650):
- _elem655 = Partition()
- _elem655.read(iprot)
- self.success.append(_elem655)
+ (_etype662, _size659) = iprot.readListBegin()
+ for _i663 in xrange(_size659):
+ _elem664 = Partition()
+ _elem664.read(iprot)
+ self.success.append(_elem664)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17782,8 +17782,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 iter656 in self.success:
- iter656.write(oprot)
+ for iter665 in self.success:
+ iter665.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17877,10 +17877,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype660, _size657) = iprot.readListBegin()
- for _i661 in xrange(_size657):
- _elem662 = iprot.readString()
- self.group_names.append(_elem662)
+ (_etype669, _size666) = iprot.readListBegin()
+ for _i670 in xrange(_size666):
+ _elem671 = iprot.readString()
+ self.group_names.append(_elem671)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17913,8 +17913,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 iter663 in self.group_names:
- oprot.writeString(iter663)
+ for iter672 in self.group_names:
+ oprot.writeString(iter672)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17975,11 +17975,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype667, _size664) = iprot.readListBegin()
- for _i668 in xrange(_size664):
- _elem669 = Partition()
- _elem669.read(iprot)
- self.success.append(_elem669)
+ (_etype676, _size673) = iprot.readListBegin()
+ for _i677 in xrange(_size673):
+ _elem678 = Partition()
+ _elem678.read(iprot)
+ self.success.append(_elem678)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18008,8 +18008,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 iter670 in self.success:
- iter670.write(oprot)
+ for iter679 in self.success:
+ iter679.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18167,11 +18167,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype674, _size671) = iprot.readListBegin()
- for _i675 in xrange(_size671):
- _elem676 = PartitionSpec()
- _elem676.read(iprot)
- self.success.append(_elem676)
+ (_etype683, _size680) = iprot.readListBegin()
+ for _i684 in xrange(_size680):
+ _elem685 = PartitionSpec()
+ _elem685.read(iprot)
+ self.success.append(_elem685)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18200,8 +18200,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 iter677 in self.success:
- iter677.write(oprot)
+ for iter686 in self.success:
+ iter686.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18356,10 +18356,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype681, _size678) = iprot.readListBegin()
- for _i682 in xrange(_size678):
- _elem683 = iprot.readString()
- self.success.append(_elem683)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = iprot.readString()
+ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18382,8 +18382,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 iter684 in self.success:
- oprot.writeString(iter684)
+ for iter693 in self.success:
+ oprot.writeString(iter693)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -18459,10 +18459,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype688, _size685) = iprot.readListBegin()
- for _i689 in xrange(_size685):
- _elem690 = iprot.readString()
- self.part_vals.append(_elem690)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = iprot.readString()
+ self.part_vals.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18492,8 +18492,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 iter691 in self.part_vals:
- oprot.writeString(iter691)
+ for iter700 in self.part_vals:
+ oprot.writeString(iter700)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -18557,11 +18557,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype695, _size692) = iprot.readListBegin()
- for _i696 in xrange(_size692):
- _elem697 = Partition()
- _elem697.read(iprot)
- self.success.append(_elem697)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = Partition()
+ _elem706.read(iprot)
+ self.success.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18590,8 +18590,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 iter698 in self.success:
- iter698.write(oprot)
+ for iter707 in self.success:
+ iter707.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18678,10 +18678,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype702, _size699) = iprot.readListBegin()
- for _i703 in xrange(_size699):
- _elem704 = iprot.readString()
- self.part_vals.append(_elem704)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = iprot.readString()
+ self.part_vals.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18698,10 +18698,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype708, _size705) = iprot.readListBegin()
- for _i709 in xrange(_size705):
- _elem710 = iprot.readString()
- self.group_names.append(_elem710)
+ (_etype717, _size714) = iprot.readListBegin()
+ for _i718 in xrange(_size714):
+ _elem719 = iprot.readString()
+ self.group_names.append(_elem719)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18726,8 +18726,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 iter711 in self.part_vals:
- oprot.writeString(iter711)
+ for iter720 in self.part_vals:
+ oprot.writeString(iter720)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -18741,8 +18741,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 iter712 in self.group_names:
- oprot.writeString(iter712)
+ for iter721 in self.group_names:
+ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18804,11 +18804,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype716, _size713) = iprot.readListBegin()
- for _i717 in xrange(_size713):
- _elem718 = Partition()
- _elem718.read(iprot)
- self.success.append(_elem718)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = Partition()
+ _elem727.read(iprot)
+ self.success.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18837,8 +18837,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 iter719 in self.success:
- iter719.write(oprot)
+ for iter728 in self.success:
+ iter728.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18919,10 +18919,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype723, _size720) = iprot.readListBegin()
- for _i724 in xrange(_size720):
- _elem725 = iprot.readString()
- self.part_vals.append(_elem725)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = iprot.readString()
+ self.part_vals.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18952,8 +18952,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 iter726 in self.part_vals:
- oprot.writeString(iter726)
+ for iter735 in self.part_vals:
+ oprot.writeString(iter735)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -19017,10 +19017,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype730, _size727) = iprot.readListBegin()
- for _i731 in xrange(_size727):
- _elem732 = iprot.readString()
- self.success.append(_elem732)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = iprot.readString()
+ self.success.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19049,8 +19049,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 iter733 in self.success:
- oprot.writeString(iter733)
+ for iter742 in self.success:
+ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19221,11 +19221,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype737, _size734) = iprot.readListBegin()
- for _i738 in xrange(_size734):
- _elem739 = Partition()
- _elem739.read(iprot)
- self.success.append(_elem739)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = Partition()
+ _elem748.read(iprot)
+ self.success.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19254,8 +19254,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 iter740 in self.success:
- iter740.write(oprot)
+ for iter749 in self.success:
+ iter749.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19426,11 +19426,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype744, _size741) = iprot.readListBegin()
- for _i745 in xrange(_size741):
- _elem746 = PartitionSpec()
- _elem746.read(iprot)
- self.success.append(_elem746)
+ (_etype753, _size750) = iprot.readListBegin()
+ for _i754 in xrange(_size750):
+ _elem755 = PartitionSpec()
+ _elem755.read(iprot)
+ self.success.append(_elem755)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19459,8 +19459,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 iter747 in self.success:
- iter747.write(oprot)
+ for iter756 in self.success:
+ iter756.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19697,10 +19697,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype751, _size748) = iprot.readListBegin()
- for _i752 in xrange(_size748):
- _elem753 = iprot.readString()
- self.names.append(_elem753)
+ (_etype760, _size757) = iprot.readListBegin()
+ for _i761 in xrange(_size757):
+ _elem762 = iprot.readString()
+ self.names.append(_elem762)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19725,8 +19725,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 iter754 in self.names:
- oprot.writeString(iter754)
+ for iter763 in self.names:
+ oprot.writeString(iter763)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19785,11 +19785,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype758, _size755) = iprot.readListBegin()
- for _i759 in xrange(_size755):
- _elem760 = Partition()
- _elem760.read(iprot)
- self.success.append(_elem760)
+ (_etype767, _size764) = iprot.readListBegin()
+ for _i768 in xrange(_size764):
+ _elem769 = Partition()
+ _elem769.read(iprot)
+ self.success.append(_elem769)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19818,8 +19818,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 iter761 in self.success:
- iter761.write(oprot)
+ for iter770 in self.success:
+ iter770.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20069,11 +20069,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype765, _size762) = iprot.readListBegin()
- for _i766 in xrange(_size762):
- _elem767 = Partition()
- _elem767.read(iprot)
- self.new_parts.append(_elem767)
+ (_etype774, _size771) = iprot.readListBegin()
+ for _i775 in xrange(_size771):
+ _elem776 = Partition()
+ _elem776.read(iprot)
+ self.new_parts.append(_elem776)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20098,8 +20098,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 iter768 in self.new_parts:
- iter768.write(oprot)
+ for iter777 in self.new_parts:
+ iter777.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20438,10 +20438,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype772, _size769) = iprot.readListBegin()
- for _i773 in xrange(_size769):
- _elem774 = iprot.readString()
- self.part_vals.append(_elem774)
+ (_etype781, _size778) = iprot.readListBegin()
+ for _i782 in xrange(_size778):
+ _elem783 = iprot.readString()
+ self.part_vals.append(_elem783)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20472,8 +20472,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 iter775 in self.part_vals:
- oprot.writeString(iter775)
+ for iter784 in self.part_vals:
+ oprot.writeString(iter784)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -20615,10 +20615,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype779, _size776) = iprot.readListBegin()
- for _i780 in xrange(_size776):
- _elem781 = iprot.readString()
- self.part_vals.append(_elem781)
+ (_etype788, _size785) = iprot.readListBegin()
+ for _i789 in xrange(_size785):
+ _elem790 = iprot.readString()
+ self.part_vals.append(_elem790)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20640,8 +20640,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 iter782 in self.part_vals:
- oprot.writeString(iter782)
+ for iter791 in self.part_vals:
+ oprot.writeString(iter791)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -20999,10 +20999,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype786, _size783) = iprot.readListBegin()
- for _i787 in xrange(_size783):
- _elem788 = iprot.readString()
- self.success.append(_elem788)
+ (_etype795, _size792) = iprot.readListBegin()
+ for _i796 in xrange(_size792):
+ _elem797 = iprot.readString()
+ self.success.append(_elem797)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21025,8 +21025,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 iter789 in self.success:
- oprot.writeString(iter789)
+ for iter798 in self.success:
+ oprot.writeString(iter798)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21150,11 +21150,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype791, _vtype792, _size790 ) = iprot.readMapBegin()
- for _i794 in xrange(_size790):
- _key795 = iprot.readString()
- _val796 = iprot.readString()
- self.success[_key795] = _val796
+ (_ktype800, _vtype801, _size799 ) = iprot.readMapBegin()
+ for _i803 in xrange(_size799):
+ _key804 = iprot.readString()
+ _val805 = iprot.readString()
+ self.success[_key804] = _val805
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21177,9 +21177,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 kiter797,viter798 in self.success.items():
- oprot.writeString(kiter797)
- oprot.writeString(viter798)
+ for kiter806,viter807 in self.success.items():
+ oprot.writeString(kiter806)
+ oprot.writeString(viter807)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21255,11 +21255,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype800, _vtype801, _size799 ) = iprot.readMapBegin()
- for _i803 in xrange(_size799):
- _key804 = iprot.readString()
- _val805 = iprot.readString()
- self.part_vals[_key804] = _val805
+ (_ktype809, _vtype810, _size808 ) = iprot.readMapBegin()
+ for _i812 in xrange(_size808):
+ _key813 = iprot.readString()
+ _val814 = iprot.readString()
+ self.part_vals[_key813] = _val814
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21289,9 +21289,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 kiter806,viter807 in self.part_vals.items():
- oprot.writeString(kiter806)
- oprot.writeString(viter807)
+ for kiter815,viter816 in self.part_vals.items():
+ oprot.writeString(kiter815)
+ oprot.writeString(viter816)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -21505,11 +21505,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype809, _vtype810, _size808 ) = iprot.readMapBegin()
- for _i812 in xrange(_size808):
- _key813 = iprot.readString()
- _val814 = iprot.readString()
- self.part_vals[_key813] = _val814
+ (_ktype818, _vtype819, _size817 ) = iprot.readMapBegin()
+ for _i821 in xrange(_size817):
+ _key822 = iprot.readString()
+ _val823 = iprot.readString()
+ self.part_vals[_key822] = _val823
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21539,9 +21539,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 kiter815,viter816 in self.part_vals.items():
- oprot.writeString(kiter815)
- oprot.writeString(viter816)
+ for kiter824,viter825 in self.part_vals.items():
+ oprot.writeString(kiter824)
+ oprot.writeString(viter825)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -22596,11 +22596,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype820, _size817) = iprot.readListBegin()
- for _i821 in xrange(_size817):
- _elem822 = Index()
- _elem822.read(iprot)
- self.success.append(_elem822)
+ (_etype829, _size826) = iprot.readListBegin()
+ for _i830 in xrange(_size826):
+ _elem831 = Index()
+ _elem831.read(iprot)
+ self.success.append(_elem831)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22629,8 +22629,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 iter823 in self.success:
- iter823.write(oprot)
+ for iter832 in self.success:
+ iter832.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22785,10 +22785,10 @@ class get_index_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)
+ (_etype836, _size833) = iprot.readListBegin()
+ for _i837 in xrange(_size833):
+ _elem838 = iprot.readString()
+ self.success.append(_elem838)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22811,8 +22811,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 iter830 in self.success:
- oprot.writeString(iter830)
+ for iter839 in self.success:
+ oprot.writeString(iter839)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -25360,10 +25360,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype834, _size831) = iprot.readListBegin()
- for _i835 in xrange(_size831):
- _elem836 = iprot.readString()
- self.success.append(_elem836)
+ (_etype843, _size840) = iprot.readListBegin()
+ for _i844 in xrange(_size840):
+ _elem845 = iprot.readString()
+ self.success.append(_elem845)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25386,8 +25386,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 iter837 in self.success:
- oprot.writeString(iter837)
+ for iter846 in self.success:
+ oprot.writeString(iter846)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26075,10 +26075,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype841, _size838) = iprot.readListBegin()
- for _i842 in xrange(_size838):
- _elem843 = iprot.readString()
- self.success.append(_elem843)
+ (_etype850, _size847) = iprot.readListBegin()
+ for _i851 in xrange(_size847):
+ _elem852 = iprot.readString()
+ self.success.append(_elem852)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26101,8 +26101,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 iter844 in self.success:
- oprot.writeString(iter844)
+ for iter853 in self.success:
+ oprot.writeString(iter853)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26616,11 +26616,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype848, _size845) = iprot.readListBegin()
- for _i849 in xrange(_size845):
- _elem850 = Role()
- _elem850.read(iprot)
- self.success.append(_elem850)
+ (_etype857, _size854) = iprot.readListBegin()
+ for _i858 in xrange(_size854):
+ _elem859 = Role()
+ _elem859.read(iprot)
+ self.success.append(_elem859)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26643,8 +26643,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 iter851 in self.success:
- iter851.write(oprot)
+ for iter860 in self.success:
+ iter860.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27153,10 +27153,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype855, _size852) = iprot.readListBegin()
- for _i856 in xrange(_size852):
- _elem857 = iprot.readString()
- self.group_names.append(_elem857)
+ (_etype864, _size861) = iprot.readListBegin()
+ for _i865 in xrange(_size861):
+ _elem866 = iprot.readString()
+ self.group_names.append(_elem866)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27181,8 +27181,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 iter858 in self.group_names:
- oprot.writeString(iter858)
+ for iter867 in self.group_names:
+ oprot.writeString(iter867)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -27409,11 +27409,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype862, _size859) = iprot.readListBegin()
- for _i863 in xrange(_size859):
- _elem864 = HiveObjectPrivilege()
- _elem864.read(iprot)
- self.success.append(_elem864)
+ (_etype871, _size868) = iprot.readListBegin()
+ for _i872 in xrange(_size868):
+ _elem873 = HiveObjectPrivilege()
+ _elem873.read(iprot)
+ self.success.append(_elem873)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27436,8 +27436,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 iter865 in self.success:
- iter865.write(oprot)
+ for iter874 in self.success:
+ iter874.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27935,10 +27935,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype869, _size866) = iprot.readListBegin()
- for _i870 in xrange(_size866):
- _elem871 = iprot.readString()
- self.group_names.append(_elem871)
+ (_etype878, _size875) = iprot.readListBegin()
+ for _i879 in xrange(_size875):
+ _elem880 = iprot.readString()
+ self.group_names.append(_elem880)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27959,8 +27959,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 iter872 in self.group_names:
- oprot.writeString(iter872)
+ for iter881 in self.group_names:
+ oprot.writeString(iter881)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -28015,10 +28015,10 @@ class set_ugi_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)
+ (_etype885, _size882) = iprot.readListBegin()
+ for _i886 in xrange(_size882):
+ _elem887 = iprot.readString()
+ self.success.append(_elem887)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28041,8 +28041,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 iter879 in self.success:
- oprot.writeString(iter879)
+ for iter888 in self.success:
+ oprot.writeString(iter888)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/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 29ba9b1..2c34c66 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
@@ -8892,6 +8892,7 @@ class CompactionRequest:
- partitionname
- type
- runas
+ - properties
"""
thrift_spec = (
@@ -8901,14 +8902,16 @@ class CompactionRequest:
(3, TType.STRING, 'partitionname', None, None, ), # 3
(4, TType.I32, 'type', None, None, ), # 4
(5, TType.STRING, 'runas', None, None, ), # 5
+ (6, TType.MAP, 'properties', (TType.STRING,None,TType.STRING,None), None, ), # 6
)
- def __init__(self, dbname=None, tablename=None, partitionname=None, type=None, runas=None,):
+ def __init__(self, dbname=None, tablename=None, partitionname=None, type=None, runas=None, properties=None,):
self.dbname = dbname
self.tablename = tablename
self.partitionname = partitionname
self.type = type
self.runas = runas
+ self.properties = properties
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:
@@ -8944,6 +8947,17 @@ class CompactionRequest:
self.runas = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.MAP:
+ self.properties = {}
+ (_ktype435, _vtype436, _size434 ) = iprot.readMapBegin()
+ for _i438 in xrange(_size434):
+ _key439 = iprot.readString()
+ _val440 = iprot.readString()
+ self.properties[_key439] = _val440
+ iprot.readMapEnd()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -8974,6 +8988,14 @@ class CompactionRequest:
oprot.writeFieldBegin('runas', TType.STRING, 5)
oprot.writeString(self.runas)
oprot.writeFieldEnd()
+ if self.properties is not None:
+ oprot.writeFieldBegin('properties', TType.MAP, 6)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.properties))
+ for kiter441,viter442 in self.properties.items():
+ oprot.writeString(kiter441)
+ oprot.writeString(viter442)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -8994,6 +9016,7 @@ class CompactionRequest:
value = (value * 31) ^ hash(self.partitionname)
value = (value * 31) ^ hash(self.type)
value = (value * 31) ^ hash(self.runas)
+ value = (value * 31) ^ hash(self.properties)
return value
def __repr__(self):
@@ -9295,11 +9318,11 @@ class ShowCompactResponse:
if fid == 1:
if ftype == TType.LIST:
self.compacts = []
- (_etype437, _size434) = iprot.readListBegin()
- for _i438 in xrange(_size434):
- _elem439 = ShowCompactResponseElement()
- _elem439.read(iprot)
- self.compacts.append(_elem439)
+ (_etype446, _size443) = iprot.readListBegin()
+ for _i447 in xrange(_size443):
+ _elem448 = ShowCompactResponseElement()
+ _elem448.read(iprot)
+ self.compacts.append(_elem448)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9316,8 +9339,8 @@ class ShowCompactResponse:
if self.compacts is not None:
oprot.writeFieldBegin('compacts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.compacts))
- for iter440 in self.compacts:
- iter440.write(oprot)
+ for iter449 in self.compacts:
+ iter449.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9398,10 +9421,10 @@ class AddDynamicPartitions:
elif fid == 4:
if ftype == TType.LIST:
self.partitionnames = []
- (_etype444, _size441) = iprot.readListBegin()
- for _i445 in xrange(_size441):
- _elem446 = iprot.readString()
- self.partitionnames.append(_elem446)
+ (_etype453, _size450) = iprot.readListBegin()
+ for _i454 in xrange(_size450):
+ _elem455 = iprot.readString()
+ self.partitionnames.append(_elem455)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9435,8 +9458,8 @@ class AddDynamicPartitions:
if self.partitionnames is not None:
oprot.writeFieldBegin('partitionnames', TType.LIST, 4)
oprot.writeListBegin(TType.STRING, len(self.partitionnames))
- for iter447 in self.partitionnames:
- oprot.writeString(iter447)
+ for iter456 in self.partitionnames:
+ oprot.writeString(iter456)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.operationType is not None:
@@ -9722,11 +9745,11 @@ class NotificationEventResponse:
if fid == 1:
if ftype == TType.LIST:
self.events = []
- (_etype451, _size448) = iprot.readListBegin()
- for _i452 in xrange(_size448):
- _elem453 = NotificationEvent()
- _elem453.read(iprot)
- self.events.append(_elem453)
+ (_etype460, _size457) = iprot.readListBegin()
+ for _i461 in xrange(_size457):
+ _elem462 = NotificationEvent()
+ _elem462.read(iprot)
+ self.events.append(_elem462)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9743,8 +9766,8 @@ class NotificationEventResponse:
if self.events is not None:
oprot.writeFieldBegin('events', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.events))
- for iter454 in self.events:
- iter454.write(oprot)
+ for iter463 in self.events:
+ iter463.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9865,10 +9888,10 @@ class InsertEventRequestData:
if fid == 1:
if ftype == TType.LIST:
self.filesAdded = []
- (_etype458, _size455) = iprot.readListBegin()
- for _i459 in xrange(_size455):
- _elem460 = iprot.readString()
- self.filesAdded.append(_elem460)
+ (_etype467, _size464) = iprot.readListBegin()
+ for _i468 in xrange(_size464):
+ _elem469 = iprot.readString()
+ self.filesAdded.append(_elem469)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9885,8 +9908,8 @@ class InsertEventRequestData:
if self.filesAdded is not None:
oprot.writeFieldBegin('filesAdded', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.filesAdded))
- for iter461 in self.filesAdded:
- oprot.writeString(iter461)
+ for iter470 in self.filesAdded:
+ oprot.writeString(iter470)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10039,10 +10062,10 @@ class FireEventRequest:
elif fid == 5:
if ftype == TType.LIST:
self.partitionVals = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = iprot.readString()
- self.partitionVals.append(_elem467)
+ (_etype474, _size471) = iprot.readListBegin()
+ for _i475 in xrange(_size471):
+ _elem476 = iprot.readString()
+ self.partitionVals.append(_elem476)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10075,8 +10098,8 @@ class FireEventRequest:
if self.partitionVals is not None:
oprot.writeFieldBegin('partitionVals', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.partitionVals))
- for iter468 in self.partitionVals:
- oprot.writeString(iter468)
+ for iter477 in self.partitionVals:
+ oprot.writeString(iter477)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10182,11 +10205,11 @@ class GetAllFunctionsResponse:
if fid == 1:
if ftype == TType.LIST:
self.functions = []
- (_etype472, _size469) = iprot.readListBegin()
- for _i473 in xrange(_size469):
- _elem474 = Function()
- _elem474.read(iprot)
- self.functions.append(_elem474)
+ (_etype481, _size478) = iprot.readListBegin()
+ for _i482 in xrange(_size478):
+ _elem483 = Function()
+ _elem483.read(iprot)
+ self.functions.append(_elem483)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10203,8 +10226,8 @@ class GetAllFunctionsResponse:
if self.functions is not None:
oprot.writeFieldBegin('functions', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.functions))
- for iter475 in self.functions:
- iter475.write(oprot)
+ for iter484 in self.functions:
+ iter484.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/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 662658c..762b6d7 100644
--- a/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
+++ b/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
@@ -2015,13 +2015,15 @@ class CompactionRequest
PARTITIONNAME = 3
TYPE = 4
RUNAS = 5
+ PROPERTIES = 6
FIELDS = {
DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'},
TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename'},
PARTITIONNAME => {:type => ::Thrift::Types::STRING, :name => 'partitionname', :optional => true},
TYPE => {:type => ::Thrift::Types::I32, :name => 'type', :enum_class => ::CompactionType},
- RUNAS => {:type => ::Thrift::Types::STRING, :name => 'runas', :optional => true}
+ RUNAS => {:type => ::Thrift::Types::STRING, :name => 'runas', :optional => true},
+ PROPERTIES => {:type => ::Thrift::Types::MAP, :name => 'properties', :key => {:type => ::Thrift::Types::STRING}, :value => {:type => ::Thrift::Types::STRING}, :optional => true}
}
def struct_fields; FIELDS; end
http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
index 83d533f..585a647 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
@@ -1943,6 +1943,7 @@ public class HiveMetaStoreClient implements IMetaStoreClient {
}
@Override
+ @Deprecated
public void compact(String dbname, String tableName, String partitionName, CompactionType type)
throws TException {
CompactionRequest cr = new CompactionRequest();
@@ -1955,6 +1956,19 @@ public class HiveMetaStoreClient implements IMetaStoreClient {
}
@Override
+ public void compact(String dbname, String tableName, String partitionName, CompactionType type,
+ Map<String, String> tblproperties) throws TException {
+ CompactionRequest cr = new CompactionRequest();
+ if (dbname == null) cr.setDbname(DEFAULT_DATABASE_NAME);
+ else cr.setDbname(dbname);
+ cr.setTablename(tableName);
+ if (partitionName != null) cr.setPartitionname(partitionName);
+ cr.setType(type);
+ cr.setProperties(tblproperties);
+ client.compact(cr);
+ }
+
+ @Override
public ShowCompactResponse showCompactions() throws TException {
return client.show_compact(new ShowCompactRequest());
}
http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java b/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
index fc7b70f..6d3b4a5 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
@@ -1390,10 +1390,28 @@ public interface IMetaStoreClient {
* @param type Whether this is a major or minor compaction.
* @throws TException
*/
+ @Deprecated
void compact(String dbname, String tableName, String partitionName, CompactionType type)
throws TException;
/**
+ * Send a request to compact a table or partition. This will not block until the compaction is
+ * complete. It will instead put a request on the queue for that table or partition to be
+ * compacted. No checking is done on the dbname, tableName, or partitionName to make sure they
+ * refer to valid objects. It is assumed this has already been done by the caller.
+ * @param dbname Name of the database the table is in. If null, this will be assumed to be
+ * 'default'.
+ * @param tableName Name of the table to be compacted. This cannot be null. If partitionName
+ * is null, this must be a non-partitioned table.
+ * @param partitionName Name of the partition to be compacted
+ * @param type Whether this is a major or minor compaction.
+ * @param tblproperties the list of tblproperties to override for this compact. Can be null.
+ * @throws TException
+ */
+ void compact(String dbname, String tableName, String partitionName, CompactionType type,
+ Map<String, String> tblproperties) throws TException;
+
+ /**
* Get a list of all current compactions.
* @return List of all current compactions. This includes compactions waiting to happen,
* in progress, and finished but waiting to clean the existing files.
http://git-wip-us.apache.org/repos/asf/hive/blob/6e0504d9/metastore/src/java/org/apache/hadoop/hive/metastore/txn/CompactionInfo.java
----------------------------------------------------------------------
diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/txn/CompactionInfo.java b/metastore/src/java/org/apache/hadoop/hive/metastore/txn/CompactionInfo.java
index bea1473..85e0885 100644
--- a/metastore/src/java/org/apache/hadoop/hive/metastore/txn/CompactionInfo.java
+++ b/metastore/src/java/org/apache/hadoop/hive/metastore/txn/CompactionInfo.java
@@ -37,6 +37,7 @@ public class CompactionInfo implements Comparable<CompactionInfo> {
String workerId;
long start;
public String runAs;
+ public String properties;
public boolean tooManyAborts = false;
/**
* {@code 0} means it wasn't set (e.g. in case of upgrades, since ResultSet.getLong() will return 0 if field is NULL)
@@ -102,6 +103,7 @@ public class CompactionInfo implements Comparable<CompactionInfo> {
"partName:" + partName + "," +
"state:" + state + "," +
"type:" + type + "," +
+ "properties:" + properties + "," +
"runAs:" + runAs + "," +
"tooManyAborts:" + tooManyAborts + "," +
"highestTxnId:" + highestTxnId;
@@ -120,12 +122,13 @@ public class CompactionInfo implements Comparable<CompactionInfo> {
fullCi.partName = rs.getString(4);
fullCi.state = rs.getString(5).charAt(0);//cq_state
fullCi.type = TxnHandler.dbCompactionType2ThriftType(rs.getString(6).charAt(0));
- fullCi.workerId = rs.getString(7);
- fullCi.start = rs.getLong(8);
- fullCi.runAs = rs.getString(9);
- fullCi.highestTxnId = rs.getLong(10);
- fullCi.metaInfo = rs.getBytes(11);
- fullCi.hadoopJobId = rs.getString(12);
+ fullCi.properties = rs.getString(7);
+ fullCi.workerId = rs.getString(8);
+ fullCi.start = rs.getLong(9);
+ fullCi.runAs = rs.getString(10);
+ fullCi.highestTxnId = rs.getLong(11);
+ fullCi.metaInfo = rs.getBytes(12);
+ fullCi.hadoopJobId = rs.getString(13);
return fullCi;
}
static void insertIntoCompletedCompactions(PreparedStatement pStmt, CompactionInfo ci, long endTime) throws SQLException {
@@ -135,12 +138,13 @@ public class CompactionInfo implements Comparable<CompactionInfo> {
pStmt.setString(4, ci.partName);
pStmt.setString(5, Character.toString(ci.state));
pStmt.setString(6, Character.toString(TxnHandler.thriftCompactionType2DbType(ci.type)));
- pStmt.setString(7, ci.workerId);
- pStmt.setLong(8, ci.start);
- pStmt.setLong(9, endTime);
- pStmt.setString(10, ci.runAs);
- pStmt.setLong(11, ci.highestTxnId);
- pStmt.setBytes(12, ci.metaInfo);
- pStmt.setString(13, ci.hadoopJobId);
+ pStmt.setString(7, ci.properties);
+ pStmt.setString(8, ci.workerId);
+ pStmt.setLong(9, ci.start);
+ pStmt.setLong(10, endTime);
+ pStmt.setString(11, ci.runAs);
+ pStmt.setLong(12, ci.highestTxnId);
+ pStmt.setBytes(13, ci.metaInfo);
+ pStmt.setString(14, ci.hadoopJobId);
}
}