You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2016/05/09 22:31:40 UTC
[03/10] hive git commit: HIVE-12634 : Add command to kill an ACID
transacton (Wei Zheng, reviewed by Eugene Koifman)
http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/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 f985954..c9e44f9 100644
--- a/metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -12197,6 +12197,107 @@ class AbortTxnRequest {
}
+class AbortTxnsRequest {
+ static $_TSPEC;
+
+ /**
+ * @var int[]
+ */
+ public $txn_ids = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'txn_ids',
+ 'type' => TType::LST,
+ 'etype' => TType::I64,
+ 'elem' => array(
+ 'type' => TType::I64,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['txn_ids'])) {
+ $this->txn_ids = $vals['txn_ids'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'AbortTxnsRequest';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::LST) {
+ $this->txn_ids = array();
+ $_size414 = 0;
+ $_etype417 = 0;
+ $xfer += $input->readListBegin($_etype417, $_size414);
+ for ($_i418 = 0; $_i418 < $_size414; ++$_i418)
+ {
+ $elem419 = null;
+ $xfer += $input->readI64($elem419);
+ $this->txn_ids []= $elem419;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('AbortTxnsRequest');
+ if ($this->txn_ids !== null) {
+ if (!is_array($this->txn_ids)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('txn_ids', TType::LST, 1);
+ {
+ $output->writeListBegin(TType::I64, count($this->txn_ids));
+ {
+ foreach ($this->txn_ids as $iter420)
+ {
+ $xfer += $output->writeI64($iter420);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class CommitTxnRequest {
static $_TSPEC;
@@ -12534,15 +12635,15 @@ class LockRequest {
case 1:
if ($ftype == TType::LST) {
$this->component = array();
- $_size414 = 0;
- $_etype417 = 0;
- $xfer += $input->readListBegin($_etype417, $_size414);
- for ($_i418 = 0; $_i418 < $_size414; ++$_i418)
+ $_size421 = 0;
+ $_etype424 = 0;
+ $xfer += $input->readListBegin($_etype424, $_size421);
+ for ($_i425 = 0; $_i425 < $_size421; ++$_i425)
{
- $elem419 = null;
- $elem419 = new \metastore\LockComponent();
- $xfer += $elem419->read($input);
- $this->component []= $elem419;
+ $elem426 = null;
+ $elem426 = new \metastore\LockComponent();
+ $xfer += $elem426->read($input);
+ $this->component []= $elem426;
}
$xfer += $input->readListEnd();
} else {
@@ -12598,9 +12699,9 @@ class LockRequest {
{
$output->writeListBegin(TType::STRUCT, count($this->component));
{
- foreach ($this->component as $iter420)
+ foreach ($this->component as $iter427)
{
- $xfer += $iter420->write($output);
+ $xfer += $iter427->write($output);
}
}
$output->writeListEnd();
@@ -13543,15 +13644,15 @@ class ShowLocksResponse {
case 1:
if ($ftype == TType::LST) {
$this->locks = array();
- $_size421 = 0;
- $_etype424 = 0;
- $xfer += $input->readListBegin($_etype424, $_size421);
- for ($_i425 = 0; $_i425 < $_size421; ++$_i425)
+ $_size428 = 0;
+ $_etype431 = 0;
+ $xfer += $input->readListBegin($_etype431, $_size428);
+ for ($_i432 = 0; $_i432 < $_size428; ++$_i432)
{
- $elem426 = null;
- $elem426 = new \metastore\ShowLocksResponseElement();
- $xfer += $elem426->read($input);
- $this->locks []= $elem426;
+ $elem433 = null;
+ $elem433 = new \metastore\ShowLocksResponseElement();
+ $xfer += $elem433->read($input);
+ $this->locks []= $elem433;
}
$xfer += $input->readListEnd();
} else {
@@ -13579,9 +13680,9 @@ class ShowLocksResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->locks));
{
- foreach ($this->locks as $iter427)
+ foreach ($this->locks as $iter434)
{
- $xfer += $iter427->write($output);
+ $xfer += $iter434->write($output);
}
}
$output->writeListEnd();
@@ -13856,17 +13957,17 @@ class HeartbeatTxnRangeResponse {
case 1:
if ($ftype == TType::SET) {
$this->aborted = array();
- $_size428 = 0;
- $_etype431 = 0;
- $xfer += $input->readSetBegin($_etype431, $_size428);
- for ($_i432 = 0; $_i432 < $_size428; ++$_i432)
+ $_size435 = 0;
+ $_etype438 = 0;
+ $xfer += $input->readSetBegin($_etype438, $_size435);
+ for ($_i439 = 0; $_i439 < $_size435; ++$_i439)
{
- $elem433 = null;
- $xfer += $input->readI64($elem433);
- if (is_scalar($elem433)) {
- $this->aborted[$elem433] = true;
+ $elem440 = null;
+ $xfer += $input->readI64($elem440);
+ if (is_scalar($elem440)) {
+ $this->aborted[$elem440] = true;
} else {
- $this->aborted []= $elem433;
+ $this->aborted []= $elem440;
}
}
$xfer += $input->readSetEnd();
@@ -13877,17 +13978,17 @@ class HeartbeatTxnRangeResponse {
case 2:
if ($ftype == TType::SET) {
$this->nosuch = array();
- $_size434 = 0;
- $_etype437 = 0;
- $xfer += $input->readSetBegin($_etype437, $_size434);
- for ($_i438 = 0; $_i438 < $_size434; ++$_i438)
+ $_size441 = 0;
+ $_etype444 = 0;
+ $xfer += $input->readSetBegin($_etype444, $_size441);
+ for ($_i445 = 0; $_i445 < $_size441; ++$_i445)
{
- $elem439 = null;
- $xfer += $input->readI64($elem439);
- if (is_scalar($elem439)) {
- $this->nosuch[$elem439] = true;
+ $elem446 = null;
+ $xfer += $input->readI64($elem446);
+ if (is_scalar($elem446)) {
+ $this->nosuch[$elem446] = true;
} else {
- $this->nosuch []= $elem439;
+ $this->nosuch []= $elem446;
}
}
$xfer += $input->readSetEnd();
@@ -13916,12 +14017,12 @@ class HeartbeatTxnRangeResponse {
{
$output->writeSetBegin(TType::I64, count($this->aborted));
{
- foreach ($this->aborted as $iter440 => $iter441)
+ foreach ($this->aborted as $iter447 => $iter448)
{
- if (is_scalar($iter441)) {
- $xfer += $output->writeI64($iter440);
+ if (is_scalar($iter448)) {
+ $xfer += $output->writeI64($iter447);
} else {
- $xfer += $output->writeI64($iter441);
+ $xfer += $output->writeI64($iter448);
}
}
}
@@ -13937,12 +14038,12 @@ class HeartbeatTxnRangeResponse {
{
$output->writeSetBegin(TType::I64, count($this->nosuch));
{
- foreach ($this->nosuch as $iter442 => $iter443)
+ foreach ($this->nosuch as $iter449 => $iter450)
{
- if (is_scalar($iter443)) {
- $xfer += $output->writeI64($iter442);
+ if (is_scalar($iter450)) {
+ $xfer += $output->writeI64($iter449);
} else {
- $xfer += $output->writeI64($iter443);
+ $xfer += $output->writeI64($iter450);
}
}
}
@@ -14553,15 +14654,15 @@ class ShowCompactResponse {
case 1:
if ($ftype == TType::LST) {
$this->compacts = array();
- $_size444 = 0;
- $_etype447 = 0;
- $xfer += $input->readListBegin($_etype447, $_size444);
- for ($_i448 = 0; $_i448 < $_size444; ++$_i448)
+ $_size451 = 0;
+ $_etype454 = 0;
+ $xfer += $input->readListBegin($_etype454, $_size451);
+ for ($_i455 = 0; $_i455 < $_size451; ++$_i455)
{
- $elem449 = null;
- $elem449 = new \metastore\ShowCompactResponseElement();
- $xfer += $elem449->read($input);
- $this->compacts []= $elem449;
+ $elem456 = null;
+ $elem456 = new \metastore\ShowCompactResponseElement();
+ $xfer += $elem456->read($input);
+ $this->compacts []= $elem456;
}
$xfer += $input->readListEnd();
} else {
@@ -14589,9 +14690,9 @@ class ShowCompactResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->compacts));
{
- foreach ($this->compacts as $iter450)
+ foreach ($this->compacts as $iter457)
{
- $xfer += $iter450->write($output);
+ $xfer += $iter457->write($output);
}
}
$output->writeListEnd();
@@ -14709,14 +14810,14 @@ class AddDynamicPartitions {
case 4:
if ($ftype == TType::LST) {
$this->partitionnames = array();
- $_size451 = 0;
- $_etype454 = 0;
- $xfer += $input->readListBegin($_etype454, $_size451);
- for ($_i455 = 0; $_i455 < $_size451; ++$_i455)
+ $_size458 = 0;
+ $_etype461 = 0;
+ $xfer += $input->readListBegin($_etype461, $_size458);
+ for ($_i462 = 0; $_i462 < $_size458; ++$_i462)
{
- $elem456 = null;
- $xfer += $input->readString($elem456);
- $this->partitionnames []= $elem456;
+ $elem463 = null;
+ $xfer += $input->readString($elem463);
+ $this->partitionnames []= $elem463;
}
$xfer += $input->readListEnd();
} else {
@@ -14759,9 +14860,9 @@ class AddDynamicPartitions {
{
$output->writeListBegin(TType::STRING, count($this->partitionnames));
{
- foreach ($this->partitionnames as $iter457)
+ foreach ($this->partitionnames as $iter464)
{
- $xfer += $output->writeString($iter457);
+ $xfer += $output->writeString($iter464);
}
}
$output->writeListEnd();
@@ -15114,15 +15215,15 @@ class NotificationEventResponse {
case 1:
if ($ftype == TType::LST) {
$this->events = array();
- $_size458 = 0;
- $_etype461 = 0;
- $xfer += $input->readListBegin($_etype461, $_size458);
- for ($_i462 = 0; $_i462 < $_size458; ++$_i462)
+ $_size465 = 0;
+ $_etype468 = 0;
+ $xfer += $input->readListBegin($_etype468, $_size465);
+ for ($_i469 = 0; $_i469 < $_size465; ++$_i469)
{
- $elem463 = null;
- $elem463 = new \metastore\NotificationEvent();
- $xfer += $elem463->read($input);
- $this->events []= $elem463;
+ $elem470 = null;
+ $elem470 = new \metastore\NotificationEvent();
+ $xfer += $elem470->read($input);
+ $this->events []= $elem470;
}
$xfer += $input->readListEnd();
} else {
@@ -15150,9 +15251,9 @@ class NotificationEventResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->events));
{
- foreach ($this->events as $iter464)
+ foreach ($this->events as $iter471)
{
- $xfer += $iter464->write($output);
+ $xfer += $iter471->write($output);
}
}
$output->writeListEnd();
@@ -15291,14 +15392,14 @@ class InsertEventRequestData {
case 1:
if ($ftype == TType::LST) {
$this->filesAdded = array();
- $_size465 = 0;
- $_etype468 = 0;
- $xfer += $input->readListBegin($_etype468, $_size465);
- for ($_i469 = 0; $_i469 < $_size465; ++$_i469)
+ $_size472 = 0;
+ $_etype475 = 0;
+ $xfer += $input->readListBegin($_etype475, $_size472);
+ for ($_i476 = 0; $_i476 < $_size472; ++$_i476)
{
- $elem470 = null;
- $xfer += $input->readString($elem470);
- $this->filesAdded []= $elem470;
+ $elem477 = null;
+ $xfer += $input->readString($elem477);
+ $this->filesAdded []= $elem477;
}
$xfer += $input->readListEnd();
} else {
@@ -15326,9 +15427,9 @@ class InsertEventRequestData {
{
$output->writeListBegin(TType::STRING, count($this->filesAdded));
{
- foreach ($this->filesAdded as $iter471)
+ foreach ($this->filesAdded as $iter478)
{
- $xfer += $output->writeString($iter471);
+ $xfer += $output->writeString($iter478);
}
}
$output->writeListEnd();
@@ -15546,14 +15647,14 @@ class FireEventRequest {
case 5:
if ($ftype == TType::LST) {
$this->partitionVals = array();
- $_size472 = 0;
- $_etype475 = 0;
- $xfer += $input->readListBegin($_etype475, $_size472);
- for ($_i476 = 0; $_i476 < $_size472; ++$_i476)
+ $_size479 = 0;
+ $_etype482 = 0;
+ $xfer += $input->readListBegin($_etype482, $_size479);
+ for ($_i483 = 0; $_i483 < $_size479; ++$_i483)
{
- $elem477 = null;
- $xfer += $input->readString($elem477);
- $this->partitionVals []= $elem477;
+ $elem484 = null;
+ $xfer += $input->readString($elem484);
+ $this->partitionVals []= $elem484;
}
$xfer += $input->readListEnd();
} else {
@@ -15604,9 +15705,9 @@ class FireEventRequest {
{
$output->writeListBegin(TType::STRING, count($this->partitionVals));
{
- foreach ($this->partitionVals as $iter478)
+ foreach ($this->partitionVals as $iter485)
{
- $xfer += $output->writeString($iter478);
+ $xfer += $output->writeString($iter485);
}
}
$output->writeListEnd();
@@ -15834,18 +15935,18 @@ class GetFileMetadataByExprResult {
case 1:
if ($ftype == TType::MAP) {
$this->metadata = array();
- $_size479 = 0;
- $_ktype480 = 0;
- $_vtype481 = 0;
- $xfer += $input->readMapBegin($_ktype480, $_vtype481, $_size479);
- for ($_i483 = 0; $_i483 < $_size479; ++$_i483)
+ $_size486 = 0;
+ $_ktype487 = 0;
+ $_vtype488 = 0;
+ $xfer += $input->readMapBegin($_ktype487, $_vtype488, $_size486);
+ for ($_i490 = 0; $_i490 < $_size486; ++$_i490)
{
- $key484 = 0;
- $val485 = new \metastore\MetadataPpdResult();
- $xfer += $input->readI64($key484);
- $val485 = new \metastore\MetadataPpdResult();
- $xfer += $val485->read($input);
- $this->metadata[$key484] = $val485;
+ $key491 = 0;
+ $val492 = new \metastore\MetadataPpdResult();
+ $xfer += $input->readI64($key491);
+ $val492 = new \metastore\MetadataPpdResult();
+ $xfer += $val492->read($input);
+ $this->metadata[$key491] = $val492;
}
$xfer += $input->readMapEnd();
} else {
@@ -15880,10 +15981,10 @@ class GetFileMetadataByExprResult {
{
$output->writeMapBegin(TType::I64, TType::STRUCT, count($this->metadata));
{
- foreach ($this->metadata as $kiter486 => $viter487)
+ foreach ($this->metadata as $kiter493 => $viter494)
{
- $xfer += $output->writeI64($kiter486);
- $xfer += $viter487->write($output);
+ $xfer += $output->writeI64($kiter493);
+ $xfer += $viter494->write($output);
}
}
$output->writeMapEnd();
@@ -15985,14 +16086,14 @@ class GetFileMetadataByExprRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size488 = 0;
- $_etype491 = 0;
- $xfer += $input->readListBegin($_etype491, $_size488);
- for ($_i492 = 0; $_i492 < $_size488; ++$_i492)
+ $_size495 = 0;
+ $_etype498 = 0;
+ $xfer += $input->readListBegin($_etype498, $_size495);
+ for ($_i499 = 0; $_i499 < $_size495; ++$_i499)
{
- $elem493 = null;
- $xfer += $input->readI64($elem493);
- $this->fileIds []= $elem493;
+ $elem500 = null;
+ $xfer += $input->readI64($elem500);
+ $this->fileIds []= $elem500;
}
$xfer += $input->readListEnd();
} else {
@@ -16041,9 +16142,9 @@ class GetFileMetadataByExprRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter494)
+ foreach ($this->fileIds as $iter501)
{
- $xfer += $output->writeI64($iter494);
+ $xfer += $output->writeI64($iter501);
}
}
$output->writeListEnd();
@@ -16137,17 +16238,17 @@ class GetFileMetadataResult {
case 1:
if ($ftype == TType::MAP) {
$this->metadata = array();
- $_size495 = 0;
- $_ktype496 = 0;
- $_vtype497 = 0;
- $xfer += $input->readMapBegin($_ktype496, $_vtype497, $_size495);
- for ($_i499 = 0; $_i499 < $_size495; ++$_i499)
+ $_size502 = 0;
+ $_ktype503 = 0;
+ $_vtype504 = 0;
+ $xfer += $input->readMapBegin($_ktype503, $_vtype504, $_size502);
+ for ($_i506 = 0; $_i506 < $_size502; ++$_i506)
{
- $key500 = 0;
- $val501 = '';
- $xfer += $input->readI64($key500);
- $xfer += $input->readString($val501);
- $this->metadata[$key500] = $val501;
+ $key507 = 0;
+ $val508 = '';
+ $xfer += $input->readI64($key507);
+ $xfer += $input->readString($val508);
+ $this->metadata[$key507] = $val508;
}
$xfer += $input->readMapEnd();
} else {
@@ -16182,10 +16283,10 @@ class GetFileMetadataResult {
{
$output->writeMapBegin(TType::I64, TType::STRING, count($this->metadata));
{
- foreach ($this->metadata as $kiter502 => $viter503)
+ foreach ($this->metadata as $kiter509 => $viter510)
{
- $xfer += $output->writeI64($kiter502);
- $xfer += $output->writeString($viter503);
+ $xfer += $output->writeI64($kiter509);
+ $xfer += $output->writeString($viter510);
}
}
$output->writeMapEnd();
@@ -16254,14 +16355,14 @@ class GetFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size504 = 0;
- $_etype507 = 0;
- $xfer += $input->readListBegin($_etype507, $_size504);
- for ($_i508 = 0; $_i508 < $_size504; ++$_i508)
+ $_size511 = 0;
+ $_etype514 = 0;
+ $xfer += $input->readListBegin($_etype514, $_size511);
+ for ($_i515 = 0; $_i515 < $_size511; ++$_i515)
{
- $elem509 = null;
- $xfer += $input->readI64($elem509);
- $this->fileIds []= $elem509;
+ $elem516 = null;
+ $xfer += $input->readI64($elem516);
+ $this->fileIds []= $elem516;
}
$xfer += $input->readListEnd();
} else {
@@ -16289,9 +16390,9 @@ class GetFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter510)
+ foreach ($this->fileIds as $iter517)
{
- $xfer += $output->writeI64($iter510);
+ $xfer += $output->writeI64($iter517);
}
}
$output->writeListEnd();
@@ -16431,14 +16532,14 @@ class PutFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size511 = 0;
- $_etype514 = 0;
- $xfer += $input->readListBegin($_etype514, $_size511);
- for ($_i515 = 0; $_i515 < $_size511; ++$_i515)
+ $_size518 = 0;
+ $_etype521 = 0;
+ $xfer += $input->readListBegin($_etype521, $_size518);
+ for ($_i522 = 0; $_i522 < $_size518; ++$_i522)
{
- $elem516 = null;
- $xfer += $input->readI64($elem516);
- $this->fileIds []= $elem516;
+ $elem523 = null;
+ $xfer += $input->readI64($elem523);
+ $this->fileIds []= $elem523;
}
$xfer += $input->readListEnd();
} else {
@@ -16448,14 +16549,14 @@ class PutFileMetadataRequest {
case 2:
if ($ftype == TType::LST) {
$this->metadata = array();
- $_size517 = 0;
- $_etype520 = 0;
- $xfer += $input->readListBegin($_etype520, $_size517);
- for ($_i521 = 0; $_i521 < $_size517; ++$_i521)
+ $_size524 = 0;
+ $_etype527 = 0;
+ $xfer += $input->readListBegin($_etype527, $_size524);
+ for ($_i528 = 0; $_i528 < $_size524; ++$_i528)
{
- $elem522 = null;
- $xfer += $input->readString($elem522);
- $this->metadata []= $elem522;
+ $elem529 = null;
+ $xfer += $input->readString($elem529);
+ $this->metadata []= $elem529;
}
$xfer += $input->readListEnd();
} else {
@@ -16490,9 +16591,9 @@ class PutFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter523)
+ foreach ($this->fileIds as $iter530)
{
- $xfer += $output->writeI64($iter523);
+ $xfer += $output->writeI64($iter530);
}
}
$output->writeListEnd();
@@ -16507,9 +16608,9 @@ class PutFileMetadataRequest {
{
$output->writeListBegin(TType::STRING, count($this->metadata));
{
- foreach ($this->metadata as $iter524)
+ foreach ($this->metadata as $iter531)
{
- $xfer += $output->writeString($iter524);
+ $xfer += $output->writeString($iter531);
}
}
$output->writeListEnd();
@@ -16628,14 +16729,14 @@ class ClearFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size525 = 0;
- $_etype528 = 0;
- $xfer += $input->readListBegin($_etype528, $_size525);
- for ($_i529 = 0; $_i529 < $_size525; ++$_i529)
+ $_size532 = 0;
+ $_etype535 = 0;
+ $xfer += $input->readListBegin($_etype535, $_size532);
+ for ($_i536 = 0; $_i536 < $_size532; ++$_i536)
{
- $elem530 = null;
- $xfer += $input->readI64($elem530);
- $this->fileIds []= $elem530;
+ $elem537 = null;
+ $xfer += $input->readI64($elem537);
+ $this->fileIds []= $elem537;
}
$xfer += $input->readListEnd();
} else {
@@ -16663,9 +16764,9 @@ class ClearFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter531)
+ foreach ($this->fileIds as $iter538)
{
- $xfer += $output->writeI64($iter531);
+ $xfer += $output->writeI64($iter538);
}
}
$output->writeListEnd();
@@ -16949,15 +17050,15 @@ class GetAllFunctionsResponse {
case 1:
if ($ftype == TType::LST) {
$this->functions = array();
- $_size532 = 0;
- $_etype535 = 0;
- $xfer += $input->readListBegin($_etype535, $_size532);
- for ($_i536 = 0; $_i536 < $_size532; ++$_i536)
+ $_size539 = 0;
+ $_etype542 = 0;
+ $xfer += $input->readListBegin($_etype542, $_size539);
+ for ($_i543 = 0; $_i543 < $_size539; ++$_i543)
{
- $elem537 = null;
- $elem537 = new \metastore\Function();
- $xfer += $elem537->read($input);
- $this->functions []= $elem537;
+ $elem544 = null;
+ $elem544 = new \metastore\Function();
+ $xfer += $elem544->read($input);
+ $this->functions []= $elem544;
}
$xfer += $input->readListEnd();
} else {
@@ -16985,9 +17086,9 @@ class GetAllFunctionsResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->functions));
{
- foreach ($this->functions as $iter538)
+ foreach ($this->functions as $iter545)
{
- $xfer += $iter538->write($output);
+ $xfer += $iter545->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/6c4c6369/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 e124cd0..6dfe353 100755
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
@@ -151,6 +151,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print(' GetOpenTxnsInfoResponse get_open_txns_info()')
print(' OpenTxnsResponse open_txns(OpenTxnRequest rqst)')
print(' void abort_txn(AbortTxnRequest rqst)')
+ print(' void abort_txns(AbortTxnsRequest rqst)')
print(' void commit_txn(CommitTxnRequest rqst)')
print(' LockResponse lock(LockRequest rqst)')
print(' LockResponse check_lock(CheckLockRequest rqst)')
@@ -1001,6 +1002,12 @@ elif cmd == 'abort_txn':
sys.exit(1)
pp.pprint(client.abort_txn(eval(args[0]),))
+elif cmd == 'abort_txns':
+ if len(args) != 1:
+ print('abort_txns requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.abort_txns(eval(args[0]),))
+
elif cmd == 'commit_txn':
if len(args) != 1:
print('commit_txn requires 1 args')