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); } }