http://git-wip-us.apache.org/repos/asf/hive/blob/187eb760/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 4dcfc76..a3201cc 100644 --- a/metastore/src/gen/thrift/gen-php/metastore/Types.php +++ b/metastore/src/gen/thrift/gen-php/metastore/Types.php @@ -12130,6 +12130,10 @@ class GetOpenTxnsResponse { * @var int */ public $min_open_txn = null; + /** + * @var string + */ + public $abortedBits = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -12140,7 +12144,7 @@ class GetOpenTxnsResponse { ), 2 => array( 'var' => 'open_txns', - 'type' => TType::SET, + 'type' => TType::LST, 'etype' => TType::I64, 'elem' => array( 'type' => TType::I64, @@ -12150,6 +12154,10 @@ class GetOpenTxnsResponse { 'var' => 'min_open_txn', 'type' => TType::I64, ), + 4 => array( + 'var' => 'abortedBits', + 'type' => TType::STRING, + ), ); } if (is_array($vals)) { @@ -12162,6 +12170,9 @@ class GetOpenTxnsResponse { if (isset($vals['min_open_txn'])) { $this->min_open_txn = $vals['min_open_txn']; } + if (isset($vals['abortedBits'])) { + $this->abortedBits = $vals['abortedBits']; + } } } @@ -12192,22 +12203,18 @@ class GetOpenTxnsResponse { } break; case 2: - if ($ftype == TType::SET) { + if ($ftype == TType::LST) { $this->open_txns = array(); $_size413 = 0; $_etype416 = 0; - $xfer += $input->readSetBegin($_etype416, $_size413); + $xfer += $input->readListBegin($_etype416, $_size413); for ($_i417 = 0; $_i417 < $_size413; ++$_i417) { $elem418 = null; $xfer += $input->readI64($elem418); - if (is_scalar($elem418)) { - $this->open_txns[$elem418] = true; - } else { - $this->open_txns []= $elem418; - } + $this->open_txns []= $elem418; } - $xfer += $input->readSetEnd(); + $xfer += $input->readListEnd(); } else { $xfer += $input->skip($ftype); } @@ -12219,6 +12226,13 @@ class GetOpenTxnsResponse { $xfer += $input->skip($ftype); } break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->abortedBits); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -12241,20 +12255,16 @@ class GetOpenTxnsResponse { if (!is_array($this->open_txns)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('open_txns', TType::SET, 2); + $xfer += $output->writeFieldBegin('open_txns', TType::LST, 2); { - $output->writeSetBegin(TType::I64, count($this->open_txns)); + $output->writeListBegin(TType::I64, count($this->open_txns)); { - foreach ($this->open_txns as $iter419 => $iter420) + foreach ($this->open_txns as $iter419) { - if (is_scalar($iter420)) { $xfer += $output->writeI64($iter419); - } else { - $xfer += $output->writeI64($iter420); - } } } - $output->writeSetEnd(); + $output->writeListEnd(); } $xfer += $output->writeFieldEnd(); } @@ -12263,6 +12273,11 @@ class GetOpenTxnsResponse { $xfer += $output->writeI64($this->min_open_txn); $xfer += $output->writeFieldEnd(); } + if ($this->abortedBits !== null) { + $xfer += $output->writeFieldBegin('abortedBits', TType::STRING, 4); + $xfer += $output->writeString($this->abortedBits); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -12464,14 +12479,14 @@ class OpenTxnsResponse { case 1: if ($ftype == TType::LST) { $this->txn_ids = array(); - $_size421 = 0; - $_etype424 = 0; - $xfer += $input->readListBegin($_etype424, $_size421); - for ($_i425 = 0; $_i425 < $_size421; ++$_i425) + $_size420 = 0; + $_etype423 = 0; + $xfer += $input->readListBegin($_etype423, $_size420); + for ($_i424 = 0; $_i424 < $_size420; ++$_i424) { - $elem426 = null; - $xfer += $input->readI64($elem426); - $this->txn_ids []= $elem426; + $elem425 = null; + $xfer += $input->readI64($elem425); + $this->txn_ids []= $elem425; } $xfer += $input->readListEnd(); } else { @@ -12499,9 +12514,9 @@ class OpenTxnsResponse { { $output->writeListBegin(TType::I64, count($this->txn_ids)); { - foreach ($this->txn_ids as $iter427) + foreach ($this->txn_ids as $iter426) { - $xfer += $output->writeI64($iter427); + $xfer += $output->writeI64($iter426); } } $output->writeListEnd(); @@ -12640,14 +12655,14 @@ class AbortTxnsRequest { case 1: if ($ftype == TType::LST) { $this->txn_ids = array(); - $_size428 = 0; - $_etype431 = 0; - $xfer += $input->readListBegin($_etype431, $_size428); - for ($_i432 = 0; $_i432 < $_size428; ++$_i432) + $_size427 = 0; + $_etype430 = 0; + $xfer += $input->readListBegin($_etype430, $_size427); + for ($_i431 = 0; $_i431 < $_size427; ++$_i431) { - $elem433 = null; - $xfer += $input->readI64($elem433); - $this->txn_ids []= $elem433; + $elem432 = null; + $xfer += $input->readI64($elem432); + $this->txn_ids []= $elem432; } $xfer += $input->readListEnd(); } else { @@ -12675,9 +12690,9 @@ class AbortTxnsRequest { { $output->writeListBegin(TType::I64, count($this->txn_ids)); { - foreach ($this->txn_ids as $iter434) + foreach ($this->txn_ids as $iter433) { - $xfer += $output->writeI64($iter434); + $xfer += $output->writeI64($iter433); } } $output->writeListEnd(); @@ -13097,15 +13112,15 @@ class LockRequest { case 1: if ($ftype == TType::LST) { $this->component = array(); - $_size435 = 0; - $_etype438 = 0; - $xfer += $input->readListBegin($_etype438, $_size435); - for ($_i439 = 0; $_i439 < $_size435; ++$_i439) + $_size434 = 0; + $_etype437 = 0; + $xfer += $input->readListBegin($_etype437, $_size434); + for ($_i438 = 0; $_i438 < $_size434; ++$_i438) { - $elem440 = null; - $elem440 = new \metastore\LockComponent(); - $xfer += $elem440->read($input); - $this->component []= $elem440; + $elem439 = null; + $elem439 = new \metastore\LockComponent(); + $xfer += $elem439->read($input); + $this->component []= $elem439; } $xfer += $input->readListEnd(); } else { @@ -13161,9 +13176,9 @@ class LockRequest { { $output->writeListBegin(TType::STRUCT, count($this->component)); { - foreach ($this->component as $iter441) + foreach ($this->component as $iter440) { - $xfer += $iter441->write($output); + $xfer += $iter440->write($output); } } $output->writeListEnd(); @@ -14106,15 +14121,15 @@ class ShowLocksResponse { case 1: if ($ftype == TType::LST) { $this->locks = array(); - $_size442 = 0; - $_etype445 = 0; - $xfer += $input->readListBegin($_etype445, $_size442); - for ($_i446 = 0; $_i446 < $_size442; ++$_i446) + $_size441 = 0; + $_etype444 = 0; + $xfer += $input->readListBegin($_etype444, $_size441); + for ($_i445 = 0; $_i445 < $_size441; ++$_i445) { - $elem447 = null; - $elem447 = new \metastore\ShowLocksResponseElement(); - $xfer += $elem447->read($input); - $this->locks []= $elem447; + $elem446 = null; + $elem446 = new \metastore\ShowLocksResponseElement(); + $xfer += $elem446->read($input); + $this->locks []= $elem446; } $xfer += $input->readListEnd(); } else { @@ -14142,9 +14157,9 @@ class ShowLocksResponse { { $output->writeListBegin(TType::STRUCT, count($this->locks)); { - foreach ($this->locks as $iter448) + foreach ($this->locks as $iter447) { - $xfer += $iter448->write($output); + $xfer += $iter447->write($output); } } $output->writeListEnd(); @@ -14419,17 +14434,17 @@ class HeartbeatTxnRangeResponse { case 1: if ($ftype == TType::SET) { $this->aborted = array(); - $_size449 = 0; - $_etype452 = 0; - $xfer += $input->readSetBegin($_etype452, $_size449); - for ($_i453 = 0; $_i453 < $_size449; ++$_i453) + $_size448 = 0; + $_etype451 = 0; + $xfer += $input->readSetBegin($_etype451, $_size448); + for ($_i452 = 0; $_i452 < $_size448; ++$_i452) { - $elem454 = null; - $xfer += $input->readI64($elem454); - if (is_scalar($elem454)) { - $this->aborted[$elem454] = true; + $elem453 = null; + $xfer += $input->readI64($elem453); + if (is_scalar($elem453)) { + $this->aborted[$elem453] = true; } else { - $this->aborted []= $elem454; + $this->aborted []= $elem453; } } $xfer += $input->readSetEnd(); @@ -14440,17 +14455,17 @@ class HeartbeatTxnRangeResponse { case 2: if ($ftype == TType::SET) { $this->nosuch = array(); - $_size455 = 0; - $_etype458 = 0; - $xfer += $input->readSetBegin($_etype458, $_size455); - for ($_i459 = 0; $_i459 < $_size455; ++$_i459) + $_size454 = 0; + $_etype457 = 0; + $xfer += $input->readSetBegin($_etype457, $_size454); + for ($_i458 = 0; $_i458 < $_size454; ++$_i458) { - $elem460 = null; - $xfer += $input->readI64($elem460); - if (is_scalar($elem460)) { - $this->nosuch[$elem460] = true; + $elem459 = null; + $xfer += $input->readI64($elem459); + if (is_scalar($elem459)) { + $this->nosuch[$elem459] = true; } else { - $this->nosuch []= $elem460; + $this->nosuch []= $elem459; } } $xfer += $input->readSetEnd(); @@ -14479,12 +14494,12 @@ class HeartbeatTxnRangeResponse { { $output->writeSetBegin(TType::I64, count($this->aborted)); { - foreach ($this->aborted as $iter461 => $iter462) + foreach ($this->aborted as $iter460 => $iter461) { - if (is_scalar($iter462)) { - $xfer += $output->writeI64($iter461); + if (is_scalar($iter461)) { + $xfer += $output->writeI64($iter460); } else { - $xfer += $output->writeI64($iter462); + $xfer += $output->writeI64($iter461); } } } @@ -14500,12 +14515,12 @@ class HeartbeatTxnRangeResponse { { $output->writeSetBegin(TType::I64, count($this->nosuch)); { - foreach ($this->nosuch as $iter463 => $iter464) + foreach ($this->nosuch as $iter462 => $iter463) { - if (is_scalar($iter464)) { - $xfer += $output->writeI64($iter463); + if (is_scalar($iter463)) { + $xfer += $output->writeI64($iter462); } else { - $xfer += $output->writeI64($iter464); + $xfer += $output->writeI64($iter463); } } } @@ -14664,17 +14679,17 @@ class CompactionRequest { case 6: if ($ftype == TType::MAP) { $this->properties = array(); - $_size465 = 0; - $_ktype466 = 0; - $_vtype467 = 0; - $xfer += $input->readMapBegin($_ktype466, $_vtype467, $_size465); - for ($_i469 = 0; $_i469 < $_size465; ++$_i469) + $_size464 = 0; + $_ktype465 = 0; + $_vtype466 = 0; + $xfer += $input->readMapBegin($_ktype465, $_vtype466, $_size464); + for ($_i468 = 0; $_i468 < $_size464; ++$_i468) { - $key470 = ''; - $val471 = ''; - $xfer += $input->readString($key470); - $xfer += $input->readString($val471); - $this->properties[$key470] = $val471; + $key469 = ''; + $val470 = ''; + $xfer += $input->readString($key469); + $xfer += $input->readString($val470); + $this->properties[$key469] = $val470; } $xfer += $input->readMapEnd(); } else { @@ -14727,10 +14742,10 @@ class CompactionRequest { { $output->writeMapBegin(TType::STRING, TType::STRING, count($this->properties)); { - foreach ($this->properties as $kiter472 => $viter473) + foreach ($this->properties as $kiter471 => $viter472) { - $xfer += $output->writeString($kiter472); - $xfer += $output->writeString($viter473); + $xfer += $output->writeString($kiter471); + $xfer += $output->writeString($viter472); } } $output->writeMapEnd(); @@ -15317,15 +15332,15 @@ class ShowCompactResponse { case 1: if ($ftype == TType::LST) { $this->compacts = array(); - $_size474 = 0; - $_etype477 = 0; - $xfer += $input->readListBegin($_etype477, $_size474); - for ($_i478 = 0; $_i478 < $_size474; ++$_i478) + $_size473 = 0; + $_etype476 = 0; + $xfer += $input->readListBegin($_etype476, $_size473); + for ($_i477 = 0; $_i477 < $_size473; ++$_i477) { - $elem479 = null; - $elem479 = new \metastore\ShowCompactResponseElement(); - $xfer += $elem479->read($input); - $this->compacts []= $elem479; + $elem478 = null; + $elem478 = new \metastore\ShowCompactResponseElement(); + $xfer += $elem478->read($input); + $this->compacts []= $elem478; } $xfer += $input->readListEnd(); } else { @@ -15353,9 +15368,9 @@ class ShowCompactResponse { { $output->writeListBegin(TType::STRUCT, count($this->compacts)); { - foreach ($this->compacts as $iter480) + foreach ($this->compacts as $iter479) { - $xfer += $iter480->write($output); + $xfer += $iter479->write($output); } } $output->writeListEnd(); @@ -15484,14 +15499,14 @@ class AddDynamicPartitions { case 4: if ($ftype == TType::LST) { $this->partitionnames = array(); - $_size481 = 0; - $_etype484 = 0; - $xfer += $input->readListBegin($_etype484, $_size481); - for ($_i485 = 0; $_i485 < $_size481; ++$_i485) + $_size480 = 0; + $_etype483 = 0; + $xfer += $input->readListBegin($_etype483, $_size480); + for ($_i484 = 0; $_i484 < $_size480; ++$_i484) { - $elem486 = null; - $xfer += $input->readString($elem486); - $this->partitionnames []= $elem486; + $elem485 = null; + $xfer += $input->readString($elem485); + $this->partitionnames []= $elem485; } $xfer += $input->readListEnd(); } else { @@ -15541,9 +15556,9 @@ class AddDynamicPartitions { { $output->writeListBegin(TType::STRING, count($this->partitionnames)); { - foreach ($this->partitionnames as $iter487) + foreach ($this->partitionnames as $iter486) { - $xfer += $output->writeString($iter487); + $xfer += $output->writeString($iter486); } } $output->writeListEnd(); @@ -15924,15 +15939,15 @@ class NotificationEventResponse { case 1: if ($ftype == TType::LST) { $this->events = array(); - $_size488 = 0; - $_etype491 = 0; - $xfer += $input->readListBegin($_etype491, $_size488); - for ($_i492 = 0; $_i492 < $_size488; ++$_i492) + $_size487 = 0; + $_etype490 = 0; + $xfer += $input->readListBegin($_etype490, $_size487); + for ($_i491 = 0; $_i491 < $_size487; ++$_i491) { - $elem493 = null; - $elem493 = new \metastore\NotificationEvent(); - $xfer += $elem493->read($input); - $this->events []= $elem493; + $elem492 = null; + $elem492 = new \metastore\NotificationEvent(); + $xfer += $elem492->read($input); + $this->events []= $elem492; } $xfer += $input->readListEnd(); } else { @@ -15960,9 +15975,9 @@ class NotificationEventResponse { { $output->writeListBegin(TType::STRUCT, count($this->events)); { - foreach ($this->events as $iter494) + foreach ($this->events as $iter493) { - $xfer += $iter494->write($output); + $xfer += $iter493->write($output); } } $output->writeListEnd(); @@ -16055,6 +16070,10 @@ class InsertEventRequestData { static $_TSPEC; /** + * @var bool + */ + public $replace = null; + /** * @var string[] */ public $filesAdded = null; @@ -16067,6 +16086,10 @@ class InsertEventRequestData { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( + 'var' => 'replace', + 'type' => TType::BOOL, + ), + 2 => array( 'var' => 'filesAdded', 'type' => TType::LST, 'etype' => TType::STRING, @@ -16074,7 +16097,7 @@ class InsertEventRequestData { 'type' => TType::STRING, ), ), - 2 => array( + 3 => array( 'var' => 'filesAddedChecksum', 'type' => TType::LST, 'etype' => TType::STRING, @@ -16085,6 +16108,9 @@ class InsertEventRequestData { ); } if (is_array($vals)) { + if (isset($vals['replace'])) { + $this->replace = $vals['replace']; + } if (isset($vals['filesAdded'])) { $this->filesAdded = $vals['filesAdded']; } @@ -16114,33 +16140,40 @@ class InsertEventRequestData { switch ($fid) { case 1: + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->replace); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: if ($ftype == TType::LST) { $this->filesAdded = array(); - $_size495 = 0; - $_etype498 = 0; - $xfer += $input->readListBegin($_etype498, $_size495); - for ($_i499 = 0; $_i499 < $_size495; ++$_i499) + $_size494 = 0; + $_etype497 = 0; + $xfer += $input->readListBegin($_etype497, $_size494); + for ($_i498 = 0; $_i498 < $_size494; ++$_i498) { - $elem500 = null; - $xfer += $input->readString($elem500); - $this->filesAdded []= $elem500; + $elem499 = null; + $xfer += $input->readString($elem499); + $this->filesAdded []= $elem499; } $xfer += $input->readListEnd(); } else { $xfer += $input->skip($ftype); } break; - case 2: + case 3: if ($ftype == TType::LST) { $this->filesAddedChecksum = array(); - $_size501 = 0; - $_etype504 = 0; - $xfer += $input->readListBegin($_etype504, $_size501); - for ($_i505 = 0; $_i505 < $_size501; ++$_i505) + $_size500 = 0; + $_etype503 = 0; + $xfer += $input->readListBegin($_etype503, $_size500); + for ($_i504 = 0; $_i504 < $_size500; ++$_i504) { - $elem506 = null; - $xfer += $input->readString($elem506); - $this->filesAddedChecksum []= $elem506; + $elem505 = null; + $xfer += $input->readString($elem505); + $this->filesAddedChecksum []= $elem505; } $xfer += $input->readListEnd(); } else { @@ -16160,17 +16193,22 @@ class InsertEventRequestData { public function write($output) { $xfer = 0; $xfer += $output->writeStructBegin('InsertEventRequestData'); + if ($this->replace !== null) { + $xfer += $output->writeFieldBegin('replace', TType::BOOL, 1); + $xfer += $output->writeBool($this->replace); + $xfer += $output->writeFieldEnd(); + } if ($this->filesAdded !== null) { if (!is_array($this->filesAdded)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('filesAdded', TType::LST, 1); + $xfer += $output->writeFieldBegin('filesAdded', TType::LST, 2); { $output->writeListBegin(TType::STRING, count($this->filesAdded)); { - foreach ($this->filesAdded as $iter507) + foreach ($this->filesAdded as $iter506) { - $xfer += $output->writeString($iter507); + $xfer += $output->writeString($iter506); } } $output->writeListEnd(); @@ -16181,13 +16219,13 @@ class InsertEventRequestData { if (!is_array($this->filesAddedChecksum)) { throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); } - $xfer += $output->writeFieldBegin('filesAddedChecksum', TType::LST, 2); + $xfer += $output->writeFieldBegin('filesAddedChecksum', TType::LST, 3); { $output->writeListBegin(TType::STRING, count($this->filesAddedChecksum)); { - foreach ($this->filesAddedChecksum as $iter508) + foreach ($this->filesAddedChecksum as $iter507) { - $xfer += $output->writeString($iter508); + $xfer += $output->writeString($iter507); } } $output->writeListEnd(); @@ -16405,14 +16443,14 @@ class FireEventRequest { case 5: if ($ftype == TType::LST) { $this->partitionVals = array(); - $_size509 = 0; - $_etype512 = 0; - $xfer += $input->readListBegin($_etype512, $_size509); - for ($_i513 = 0; $_i513 < $_size509; ++$_i513) + $_size508 = 0; + $_etype511 = 0; + $xfer += $input->readListBegin($_etype511, $_size508); + for ($_i512 = 0; $_i512 < $_size508; ++$_i512) { - $elem514 = null; - $xfer += $input->readString($elem514); - $this->partitionVals []= $elem514; + $elem513 = null; + $xfer += $input->readString($elem513); + $this->partitionVals []= $elem513; } $xfer += $input->readListEnd(); } else { @@ -16463,9 +16501,9 @@ class FireEventRequest { { $output->writeListBegin(TType::STRING, count($this->partitionVals)); { - foreach ($this->partitionVals as $iter515) + foreach ($this->partitionVals as $iter514) { - $xfer += $output->writeString($iter515); + $xfer += $output->writeString($iter514); } } $output->writeListEnd(); @@ -16693,18 +16731,18 @@ class GetFileMetadataByExprResult { case 1: if ($ftype == TType::MAP) { $this->metadata = array(); - $_size516 = 0; - $_ktype517 = 0; - $_vtype518 = 0; - $xfer += $input->readMapBegin($_ktype517, $_vtype518, $_size516); - for ($_i520 = 0; $_i520 < $_size516; ++$_i520) + $_size515 = 0; + $_ktype516 = 0; + $_vtype517 = 0; + $xfer += $input->readMapBegin($_ktype516, $_vtype517, $_size515); + for ($_i519 = 0; $_i519 < $_size515; ++$_i519) { - $key521 = 0; - $val522 = new \metastore\MetadataPpdResult(); - $xfer += $input->readI64($key521); - $val522 = new \metastore\MetadataPpdResult(); - $xfer += $val522->read($input); - $this->metadata[$key521] = $val522; + $key520 = 0; + $val521 = new \metastore\MetadataPpdResult(); + $xfer += $input->readI64($key520); + $val521 = new \metastore\MetadataPpdResult(); + $xfer += $val521->read($input); + $this->metadata[$key520] = $val521; } $xfer += $input->readMapEnd(); } else { @@ -16739,10 +16777,10 @@ class GetFileMetadataByExprResult { { $output->writeMapBegin(TType::I64, TType::STRUCT, count($this->metadata)); { - foreach ($this->metadata as $kiter523 => $viter524) + foreach ($this->metadata as $kiter522 => $viter523) { - $xfer += $output->writeI64($kiter523); - $xfer += $viter524->write($output); + $xfer += $output->writeI64($kiter522); + $xfer += $viter523->write($output); } } $output->writeMapEnd(); @@ -16844,14 +16882,14 @@ class GetFileMetadataByExprRequest { case 1: if ($ftype == TType::LST) { $this->fileIds = array(); - $_size525 = 0; - $_etype528 = 0; - $xfer += $input->readListBegin($_etype528, $_size525); - for ($_i529 = 0; $_i529 < $_size525; ++$_i529) + $_size524 = 0; + $_etype527 = 0; + $xfer += $input->readListBegin($_etype527, $_size524); + for ($_i528 = 0; $_i528 < $_size524; ++$_i528) { - $elem530 = null; - $xfer += $input->readI64($elem530); - $this->fileIds []= $elem530; + $elem529 = null; + $xfer += $input->readI64($elem529); + $this->fileIds []= $elem529; } $xfer += $input->readListEnd(); } else { @@ -16900,9 +16938,9 @@ class GetFileMetadataByExprRequest { { $output->writeListBegin(TType::I64, count($this->fileIds)); { - foreach ($this->fileIds as $iter531) + foreach ($this->fileIds as $iter530) { - $xfer += $output->writeI64($iter531); + $xfer += $output->writeI64($iter530); } } $output->writeListEnd(); @@ -16996,17 +17034,17 @@ class GetFileMetadataResult { case 1: if ($ftype == TType::MAP) { $this->metadata = array(); - $_size532 = 0; - $_ktype533 = 0; - $_vtype534 = 0; - $xfer += $input->readMapBegin($_ktype533, $_vtype534, $_size532); - for ($_i536 = 0; $_i536 < $_size532; ++$_i536) + $_size531 = 0; + $_ktype532 = 0; + $_vtype533 = 0; + $xfer += $input->readMapBegin($_ktype532, $_vtype533, $_size531); + for ($_i535 = 0; $_i535 < $_size531; ++$_i535) { - $key537 = 0; - $val538 = ''; - $xfer += $input->readI64($key537); - $xfer += $input->readString($val538); - $this->metadata[$key537] = $val538; + $key536 = 0; + $val537 = ''; + $xfer += $input->readI64($key536); + $xfer += $input->readString($val537); + $this->metadata[$key536] = $val537; } $xfer += $input->readMapEnd(); } else { @@ -17041,10 +17079,10 @@ class GetFileMetadataResult { { $output->writeMapBegin(TType::I64, TType::STRING, count($this->metadata)); { - foreach ($this->metadata as $kiter539 => $viter540) + foreach ($this->metadata as $kiter538 => $viter539) { - $xfer += $output->writeI64($kiter539); - $xfer += $output->writeString($viter540); + $xfer += $output->writeI64($kiter538); + $xfer += $output->writeString($viter539); } } $output->writeMapEnd(); @@ -17113,14 +17151,14 @@ class GetFileMetadataRequest { case 1: if ($ftype == TType::LST) { $this->fileIds = array(); - $_size541 = 0; - $_etype544 = 0; - $xfer += $input->readListBegin($_etype544, $_size541); - for ($_i545 = 0; $_i545 < $_size541; ++$_i545) + $_size540 = 0; + $_etype543 = 0; + $xfer += $input->readListBegin($_etype543, $_size540); + for ($_i544 = 0; $_i544 < $_size540; ++$_i544) { - $elem546 = null; - $xfer += $input->readI64($elem546); - $this->fileIds []= $elem546; + $elem545 = null; + $xfer += $input->readI64($elem545); + $this->fileIds []= $elem545; } $xfer += $input->readListEnd(); } else { @@ -17148,9 +17186,9 @@ class GetFileMetadataRequest { { $output->writeListBegin(TType::I64, count($this->fileIds)); { - foreach ($this->fileIds as $iter547) + foreach ($this->fileIds as $iter546) { - $xfer += $output->writeI64($iter547); + $xfer += $output->writeI64($iter546); } } $output->writeListEnd(); @@ -17290,14 +17328,14 @@ class PutFileMetadataRequest { case 1: if ($ftype == TType::LST) { $this->fileIds = array(); - $_size548 = 0; - $_etype551 = 0; - $xfer += $input->readListBegin($_etype551, $_size548); - for ($_i552 = 0; $_i552 < $_size548; ++$_i552) + $_size547 = 0; + $_etype550 = 0; + $xfer += $input->readListBegin($_etype550, $_size547); + for ($_i551 = 0; $_i551 < $_size547; ++$_i551) { - $elem553 = null; - $xfer += $input->readI64($elem553); - $this->fileIds []= $elem553; + $elem552 = null; + $xfer += $input->readI64($elem552); + $this->fileIds []= $elem552; } $xfer += $input->readListEnd(); } else { @@ -17307,14 +17345,14 @@ class PutFileMetadataRequest { case 2: if ($ftype == TType::LST) { $this->metadata = array(); - $_size554 = 0; - $_etype557 = 0; - $xfer += $input->readListBegin($_etype557, $_size554); - for ($_i558 = 0; $_i558 < $_size554; ++$_i558) + $_size553 = 0; + $_etype556 = 0; + $xfer += $input->readListBegin($_etype556, $_size553); + for ($_i557 = 0; $_i557 < $_size553; ++$_i557) { - $elem559 = null; - $xfer += $input->readString($elem559); - $this->metadata []= $elem559; + $elem558 = null; + $xfer += $input->readString($elem558); + $this->metadata []= $elem558; } $xfer += $input->readListEnd(); } else { @@ -17349,9 +17387,9 @@ class PutFileMetadataRequest { { $output->writeListBegin(TType::I64, count($this->fileIds)); { - foreach ($this->fileIds as $iter560) + foreach ($this->fileIds as $iter559) { - $xfer += $output->writeI64($iter560); + $xfer += $output->writeI64($iter559); } } $output->writeListEnd(); @@ -17366,9 +17404,9 @@ class PutFileMetadataRequest { { $output->writeListBegin(TType::STRING, count($this->metadata)); { - foreach ($this->metadata as $iter561) + foreach ($this->metadata as $iter560) { - $xfer += $output->writeString($iter561); + $xfer += $output->writeString($iter560); } } $output->writeListEnd(); @@ -17487,14 +17525,14 @@ class ClearFileMetadataRequest { case 1: if ($ftype == TType::LST) { $this->fileIds = array(); - $_size562 = 0; - $_etype565 = 0; - $xfer += $input->readListBegin($_etype565, $_size562); - for ($_i566 = 0; $_i566 < $_size562; ++$_i566) + $_size561 = 0; + $_etype564 = 0; + $xfer += $input->readListBegin($_etype564, $_size561); + for ($_i565 = 0; $_i565 < $_size561; ++$_i565) { - $elem567 = null; - $xfer += $input->readI64($elem567); - $this->fileIds []= $elem567; + $elem566 = null; + $xfer += $input->readI64($elem566); + $this->fileIds []= $elem566; } $xfer += $input->readListEnd(); } else { @@ -17522,9 +17560,9 @@ class ClearFileMetadataRequest { { $output->writeListBegin(TType::I64, count($this->fileIds)); { - foreach ($this->fileIds as $iter568) + foreach ($this->fileIds as $iter567) { - $xfer += $output->writeI64($iter568); + $xfer += $output->writeI64($iter567); } } $output->writeListEnd(); @@ -18497,14 +18535,14 @@ class GetValidWriteIdsResult { case 4: if ($ftype == TType::LST) { $this->ids = array(); - $_size569 = 0; - $_etype572 = 0; - $xfer += $input->readListBegin($_etype572, $_size569); - for ($_i573 = 0; $_i573 < $_size569; ++$_i573) + $_size568 = 0; + $_etype571 = 0; + $xfer += $input->readListBegin($_etype571, $_size568); + for ($_i572 = 0; $_i572 < $_size568; ++$_i572) { - $elem574 = null; - $xfer += $input->readI64($elem574); - $this->ids []= $elem574; + $elem573 = null; + $xfer += $input->readI64($elem573); + $this->ids []= $elem573; } $xfer += $input->readListEnd(); } else { @@ -18547,9 +18585,9 @@ class GetValidWriteIdsResult { { $output->writeListBegin(TType::I64, count($this->ids)); { - foreach ($this->ids as $iter575) + foreach ($this->ids as $iter574) { - $xfer += $output->writeI64($iter575); + $xfer += $output->writeI64($iter574); } } $output->writeListEnd(); @@ -18614,15 +18652,15 @@ class GetAllFunctionsResponse { case 1: if ($ftype == TType::LST) { $this->functions = array(); - $_size576 = 0; - $_etype579 = 0; - $xfer += $input->readListBegin($_etype579, $_size576); - for ($_i580 = 0; $_i580 < $_size576; ++$_i580) + $_size575 = 0; + $_etype578 = 0; + $xfer += $input->readListBegin($_etype578, $_size575); + for ($_i579 = 0; $_i579 < $_size575; ++$_i579) { - $elem581 = null; - $elem581 = new \metastore\Function(); - $xfer += $elem581->read($input); - $this->functions []= $elem581; + $elem580 = null; + $elem580 = new \metastore\Function(); + $xfer += $elem580->read($input); + $this->functions []= $elem580; } $xfer += $input->readListEnd(); } else { @@ -18650,9 +18688,9 @@ class GetAllFunctionsResponse { { $output->writeListBegin(TType::STRUCT, count($this->functions)); { - foreach ($this->functions as $iter582) + foreach ($this->functions as $iter581) { - $xfer += $iter582->write($output); + $xfer += $iter581->write($output); } } $output->writeListEnd(); @@ -18716,14 +18754,14 @@ class ClientCapabilities { case 1: if ($ftype == TType::LST) { $this->values = array(); - $_size583 = 0; - $_etype586 = 0; - $xfer += $input->readListBegin($_etype586, $_size583); - for ($_i587 = 0; $_i587 < $_size583; ++$_i587) + $_size582 = 0; + $_etype585 = 0; + $xfer += $input->readListBegin($_etype585, $_size582); + for ($_i586 = 0; $_i586 < $_size582; ++$_i586) { - $elem588 = null; - $xfer += $input->readI32($elem588); - $this->values []= $elem588; + $elem587 = null; + $xfer += $input->readI32($elem587); + $this->values []= $elem587; } $xfer += $input->readListEnd(); } else { @@ -18751,9 +18789,9 @@ class ClientCapabilities { { $output->writeListBegin(TType::I32, count($this->values)); { - foreach ($this->values as $iter589) + foreach ($this->values as $iter588) { - $xfer += $output->writeI32($iter589); + $xfer += $output->writeI32($iter588); } } $output->writeListEnd(); @@ -19053,14 +19091,14 @@ class GetTablesRequest { case 2: if ($ftype == TType::LST) { $this->tblNames = array(); - $_size590 = 0; - $_etype593 = 0; - $xfer += $input->readListBegin($_etype593, $_size590); - for ($_i594 = 0; $_i594 < $_size590; ++$_i594) + $_size589 = 0; + $_etype592 = 0; + $xfer += $input->readListBegin($_etype592, $_size589); + for ($_i593 = 0; $_i593 < $_size589; ++$_i593) { - $elem595 = null; - $xfer += $input->readString($elem595); - $this->tblNames []= $elem595; + $elem594 = null; + $xfer += $input->readString($elem594); + $this->tblNames []= $elem594; } $xfer += $input->readListEnd(); } else { @@ -19101,9 +19139,9 @@ class GetTablesRequest { { $output->writeListBegin(TType::STRING, count($this->tblNames)); { - foreach ($this->tblNames as $iter596) + foreach ($this->tblNames as $iter595) { - $xfer += $output->writeString($iter596); + $xfer += $output->writeString($iter595); } } $output->writeListEnd(); @@ -19176,15 +19214,15 @@ class GetTablesResult { case 1: if ($ftype == TType::LST) { $this->tables = array(); - $_size597 = 0; - $_etype600 = 0; - $xfer += $input->readListBegin($_etype600, $_size597); - for ($_i601 = 0; $_i601 < $_size597; ++$_i601) + $_size596 = 0; + $_etype599 = 0; + $xfer += $input->readListBegin($_etype599, $_size596); + for ($_i600 = 0; $_i600 < $_size596; ++$_i600) { - $elem602 = null; - $elem602 = new \metastore\Table(); - $xfer += $elem602->read($input); - $this->tables []= $elem602; + $elem601 = null; + $elem601 = new \metastore\Table(); + $xfer += $elem601->read($input); + $this->tables []= $elem601; } $xfer += $input->readListEnd(); } else { @@ -19212,9 +19250,9 @@ class GetTablesResult { { $output->writeListBegin(TType::STRUCT, count($this->tables)); { - foreach ($this->tables as $iter603) + foreach ($this->tables as $iter602) { - $xfer += $iter603->write($output); + $xfer += $iter602->write($output); } } $output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/187eb760/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote index 3db3bad..c1c3393 100755 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote @@ -48,6 +48,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print(' void add_foreign_key(AddForeignKeyRequest req)') print(' void drop_table(string dbname, string name, bool deleteData)') print(' void drop_table_with_environment_context(string dbname, string name, bool deleteData, EnvironmentContext environment_context)') + print(' void truncate_table(string dbName, string tableName, partNames)') print(' get_tables(string db_name, string pattern)') print(' get_tables_by_type(string db_name, string pattern, string tableType)') print(' get_table_meta(string db_patterns, string tbl_patterns, tbl_types)') @@ -394,6 +395,12 @@ elif cmd == 'drop_table_with_environment_context': sys.exit(1) pp.pprint(client.drop_table_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),)) +elif cmd == 'truncate_table': + if len(args) != 3: + print('truncate_table requires 3 args') + sys.exit(1) + pp.pprint(client.truncate_table(args[0],args[1],eval(args[2]),)) + elif cmd == 'get_tables': if len(args) != 2: print('get_tables requires 2 args')
