You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2018/05/02 06:45:28 UTC
[04/14] hive git commit: HIVE-18988: Support bootstrap replication of
ACID tables (Sankar Hariappan, reviewed by Mahesh Kumar Behera, Thejas M Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
index 9f6cc0e..afea048 100644
--- a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -16496,6 +16496,222 @@ class CommitTxnRequest {
}
+class ReplTblWriteIdStateRequest {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $validWriteIdlist = null;
+ /**
+ * @var string
+ */
+ public $user = null;
+ /**
+ * @var string
+ */
+ public $hostName = null;
+ /**
+ * @var string
+ */
+ public $dbName = null;
+ /**
+ * @var string
+ */
+ public $tableName = null;
+ /**
+ * @var string[]
+ */
+ public $partNames = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'validWriteIdlist',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'user',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'hostName',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'tableName',
+ 'type' => TType::STRING,
+ ),
+ 6 => array(
+ 'var' => 'partNames',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['validWriteIdlist'])) {
+ $this->validWriteIdlist = $vals['validWriteIdlist'];
+ }
+ if (isset($vals['user'])) {
+ $this->user = $vals['user'];
+ }
+ if (isset($vals['hostName'])) {
+ $this->hostName = $vals['hostName'];
+ }
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['tableName'])) {
+ $this->tableName = $vals['tableName'];
+ }
+ if (isset($vals['partNames'])) {
+ $this->partNames = $vals['partNames'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ReplTblWriteIdStateRequest';
+ }
+
+ 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::STRING) {
+ $xfer += $input->readString($this->validWriteIdlist);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->user);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->hostName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->tableName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::LST) {
+ $this->partNames = array();
+ $_size523 = 0;
+ $_etype526 = 0;
+ $xfer += $input->readListBegin($_etype526, $_size523);
+ for ($_i527 = 0; $_i527 < $_size523; ++$_i527)
+ {
+ $elem528 = null;
+ $xfer += $input->readString($elem528);
+ $this->partNames []= $elem528;
+ }
+ $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('ReplTblWriteIdStateRequest');
+ if ($this->validWriteIdlist !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdlist', TType::STRING, 1);
+ $xfer += $output->writeString($this->validWriteIdlist);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->user !== null) {
+ $xfer += $output->writeFieldBegin('user', TType::STRING, 2);
+ $xfer += $output->writeString($this->user);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->hostName !== null) {
+ $xfer += $output->writeFieldBegin('hostName', TType::STRING, 3);
+ $xfer += $output->writeString($this->hostName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 4);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->tableName !== null) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 5);
+ $xfer += $output->writeString($this->tableName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->partNames !== null) {
+ if (!is_array($this->partNames)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('partNames', TType::LST, 6);
+ {
+ $output->writeListBegin(TType::STRING, count($this->partNames));
+ {
+ foreach ($this->partNames as $iter529)
+ {
+ $xfer += $output->writeString($iter529);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class GetValidWriteIdsRequest {
static $_TSPEC;
@@ -16557,14 +16773,14 @@ class GetValidWriteIdsRequest {
case 1:
if ($ftype == TType::LST) {
$this->fullTableNames = array();
- $_size523 = 0;
- $_etype526 = 0;
- $xfer += $input->readListBegin($_etype526, $_size523);
- for ($_i527 = 0; $_i527 < $_size523; ++$_i527)
+ $_size530 = 0;
+ $_etype533 = 0;
+ $xfer += $input->readListBegin($_etype533, $_size530);
+ for ($_i534 = 0; $_i534 < $_size530; ++$_i534)
{
- $elem528 = null;
- $xfer += $input->readString($elem528);
- $this->fullTableNames []= $elem528;
+ $elem535 = null;
+ $xfer += $input->readString($elem535);
+ $this->fullTableNames []= $elem535;
}
$xfer += $input->readListEnd();
} else {
@@ -16599,9 +16815,9 @@ class GetValidWriteIdsRequest {
{
$output->writeListBegin(TType::STRING, count($this->fullTableNames));
{
- foreach ($this->fullTableNames as $iter529)
+ foreach ($this->fullTableNames as $iter536)
{
- $xfer += $output->writeString($iter529);
+ $xfer += $output->writeString($iter536);
}
}
$output->writeListEnd();
@@ -16728,14 +16944,14 @@ class TableValidWriteIds {
case 3:
if ($ftype == TType::LST) {
$this->invalidWriteIds = array();
- $_size530 = 0;
- $_etype533 = 0;
- $xfer += $input->readListBegin($_etype533, $_size530);
- for ($_i534 = 0; $_i534 < $_size530; ++$_i534)
+ $_size537 = 0;
+ $_etype540 = 0;
+ $xfer += $input->readListBegin($_etype540, $_size537);
+ for ($_i541 = 0; $_i541 < $_size537; ++$_i541)
{
- $elem535 = null;
- $xfer += $input->readI64($elem535);
- $this->invalidWriteIds []= $elem535;
+ $elem542 = null;
+ $xfer += $input->readI64($elem542);
+ $this->invalidWriteIds []= $elem542;
}
$xfer += $input->readListEnd();
} else {
@@ -16787,9 +17003,9 @@ class TableValidWriteIds {
{
$output->writeListBegin(TType::I64, count($this->invalidWriteIds));
{
- foreach ($this->invalidWriteIds as $iter536)
+ foreach ($this->invalidWriteIds as $iter543)
{
- $xfer += $output->writeI64($iter536);
+ $xfer += $output->writeI64($iter543);
}
}
$output->writeListEnd();
@@ -16864,15 +17080,15 @@ class GetValidWriteIdsResponse {
case 1:
if ($ftype == TType::LST) {
$this->tblValidWriteIds = array();
- $_size537 = 0;
- $_etype540 = 0;
- $xfer += $input->readListBegin($_etype540, $_size537);
- for ($_i541 = 0; $_i541 < $_size537; ++$_i541)
+ $_size544 = 0;
+ $_etype547 = 0;
+ $xfer += $input->readListBegin($_etype547, $_size544);
+ for ($_i548 = 0; $_i548 < $_size544; ++$_i548)
{
- $elem542 = null;
- $elem542 = new \metastore\TableValidWriteIds();
- $xfer += $elem542->read($input);
- $this->tblValidWriteIds []= $elem542;
+ $elem549 = null;
+ $elem549 = new \metastore\TableValidWriteIds();
+ $xfer += $elem549->read($input);
+ $this->tblValidWriteIds []= $elem549;
}
$xfer += $input->readListEnd();
} else {
@@ -16900,9 +17116,9 @@ class GetValidWriteIdsResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->tblValidWriteIds));
{
- foreach ($this->tblValidWriteIds as $iter543)
+ foreach ($this->tblValidWriteIds as $iter550)
{
- $xfer += $iter543->write($output);
+ $xfer += $iter550->write($output);
}
}
$output->writeListEnd();
@@ -17029,14 +17245,14 @@ class AllocateTableWriteIdsRequest {
case 3:
if ($ftype == TType::LST) {
$this->txnIds = array();
- $_size544 = 0;
- $_etype547 = 0;
- $xfer += $input->readListBegin($_etype547, $_size544);
- for ($_i548 = 0; $_i548 < $_size544; ++$_i548)
+ $_size551 = 0;
+ $_etype554 = 0;
+ $xfer += $input->readListBegin($_etype554, $_size551);
+ for ($_i555 = 0; $_i555 < $_size551; ++$_i555)
{
- $elem549 = null;
- $xfer += $input->readI64($elem549);
- $this->txnIds []= $elem549;
+ $elem556 = null;
+ $xfer += $input->readI64($elem556);
+ $this->txnIds []= $elem556;
}
$xfer += $input->readListEnd();
} else {
@@ -17053,15 +17269,15 @@ class AllocateTableWriteIdsRequest {
case 5:
if ($ftype == TType::LST) {
$this->srcTxnToWriteIdList = array();
- $_size550 = 0;
- $_etype553 = 0;
- $xfer += $input->readListBegin($_etype553, $_size550);
- for ($_i554 = 0; $_i554 < $_size550; ++$_i554)
+ $_size557 = 0;
+ $_etype560 = 0;
+ $xfer += $input->readListBegin($_etype560, $_size557);
+ for ($_i561 = 0; $_i561 < $_size557; ++$_i561)
{
- $elem555 = null;
- $elem555 = new \metastore\TxnToWriteId();
- $xfer += $elem555->read($input);
- $this->srcTxnToWriteIdList []= $elem555;
+ $elem562 = null;
+ $elem562 = new \metastore\TxnToWriteId();
+ $xfer += $elem562->read($input);
+ $this->srcTxnToWriteIdList []= $elem562;
}
$xfer += $input->readListEnd();
} else {
@@ -17099,9 +17315,9 @@ class AllocateTableWriteIdsRequest {
{
$output->writeListBegin(TType::I64, count($this->txnIds));
{
- foreach ($this->txnIds as $iter556)
+ foreach ($this->txnIds as $iter563)
{
- $xfer += $output->writeI64($iter556);
+ $xfer += $output->writeI64($iter563);
}
}
$output->writeListEnd();
@@ -17121,9 +17337,9 @@ class AllocateTableWriteIdsRequest {
{
$output->writeListBegin(TType::STRUCT, count($this->srcTxnToWriteIdList));
{
- foreach ($this->srcTxnToWriteIdList as $iter557)
+ foreach ($this->srcTxnToWriteIdList as $iter564)
{
- $xfer += $iter557->write($output);
+ $xfer += $iter564->write($output);
}
}
$output->writeListEnd();
@@ -17286,15 +17502,15 @@ class AllocateTableWriteIdsResponse {
case 1:
if ($ftype == TType::LST) {
$this->txnToWriteIds = array();
- $_size558 = 0;
- $_etype561 = 0;
- $xfer += $input->readListBegin($_etype561, $_size558);
- for ($_i562 = 0; $_i562 < $_size558; ++$_i562)
+ $_size565 = 0;
+ $_etype568 = 0;
+ $xfer += $input->readListBegin($_etype568, $_size565);
+ for ($_i569 = 0; $_i569 < $_size565; ++$_i569)
{
- $elem563 = null;
- $elem563 = new \metastore\TxnToWriteId();
- $xfer += $elem563->read($input);
- $this->txnToWriteIds []= $elem563;
+ $elem570 = null;
+ $elem570 = new \metastore\TxnToWriteId();
+ $xfer += $elem570->read($input);
+ $this->txnToWriteIds []= $elem570;
}
$xfer += $input->readListEnd();
} else {
@@ -17322,9 +17538,9 @@ class AllocateTableWriteIdsResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->txnToWriteIds));
{
- foreach ($this->txnToWriteIds as $iter564)
+ foreach ($this->txnToWriteIds as $iter571)
{
- $xfer += $iter564->write($output);
+ $xfer += $iter571->write($output);
}
}
$output->writeListEnd();
@@ -17669,15 +17885,15 @@ class LockRequest {
case 1:
if ($ftype == TType::LST) {
$this->component = array();
- $_size565 = 0;
- $_etype568 = 0;
- $xfer += $input->readListBegin($_etype568, $_size565);
- for ($_i569 = 0; $_i569 < $_size565; ++$_i569)
+ $_size572 = 0;
+ $_etype575 = 0;
+ $xfer += $input->readListBegin($_etype575, $_size572);
+ for ($_i576 = 0; $_i576 < $_size572; ++$_i576)
{
- $elem570 = null;
- $elem570 = new \metastore\LockComponent();
- $xfer += $elem570->read($input);
- $this->component []= $elem570;
+ $elem577 = null;
+ $elem577 = new \metastore\LockComponent();
+ $xfer += $elem577->read($input);
+ $this->component []= $elem577;
}
$xfer += $input->readListEnd();
} else {
@@ -17733,9 +17949,9 @@ class LockRequest {
{
$output->writeListBegin(TType::STRUCT, count($this->component));
{
- foreach ($this->component as $iter571)
+ foreach ($this->component as $iter578)
{
- $xfer += $iter571->write($output);
+ $xfer += $iter578->write($output);
}
}
$output->writeListEnd();
@@ -18678,15 +18894,15 @@ class ShowLocksResponse {
case 1:
if ($ftype == TType::LST) {
$this->locks = array();
- $_size572 = 0;
- $_etype575 = 0;
- $xfer += $input->readListBegin($_etype575, $_size572);
- for ($_i576 = 0; $_i576 < $_size572; ++$_i576)
+ $_size579 = 0;
+ $_etype582 = 0;
+ $xfer += $input->readListBegin($_etype582, $_size579);
+ for ($_i583 = 0; $_i583 < $_size579; ++$_i583)
{
- $elem577 = null;
- $elem577 = new \metastore\ShowLocksResponseElement();
- $xfer += $elem577->read($input);
- $this->locks []= $elem577;
+ $elem584 = null;
+ $elem584 = new \metastore\ShowLocksResponseElement();
+ $xfer += $elem584->read($input);
+ $this->locks []= $elem584;
}
$xfer += $input->readListEnd();
} else {
@@ -18714,9 +18930,9 @@ class ShowLocksResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->locks));
{
- foreach ($this->locks as $iter578)
+ foreach ($this->locks as $iter585)
{
- $xfer += $iter578->write($output);
+ $xfer += $iter585->write($output);
}
}
$output->writeListEnd();
@@ -18991,17 +19207,17 @@ class HeartbeatTxnRangeResponse {
case 1:
if ($ftype == TType::SET) {
$this->aborted = array();
- $_size579 = 0;
- $_etype582 = 0;
- $xfer += $input->readSetBegin($_etype582, $_size579);
- for ($_i583 = 0; $_i583 < $_size579; ++$_i583)
+ $_size586 = 0;
+ $_etype589 = 0;
+ $xfer += $input->readSetBegin($_etype589, $_size586);
+ for ($_i590 = 0; $_i590 < $_size586; ++$_i590)
{
- $elem584 = null;
- $xfer += $input->readI64($elem584);
- if (is_scalar($elem584)) {
- $this->aborted[$elem584] = true;
+ $elem591 = null;
+ $xfer += $input->readI64($elem591);
+ if (is_scalar($elem591)) {
+ $this->aborted[$elem591] = true;
} else {
- $this->aborted []= $elem584;
+ $this->aborted []= $elem591;
}
}
$xfer += $input->readSetEnd();
@@ -19012,17 +19228,17 @@ class HeartbeatTxnRangeResponse {
case 2:
if ($ftype == TType::SET) {
$this->nosuch = array();
- $_size585 = 0;
- $_etype588 = 0;
- $xfer += $input->readSetBegin($_etype588, $_size585);
- for ($_i589 = 0; $_i589 < $_size585; ++$_i589)
+ $_size592 = 0;
+ $_etype595 = 0;
+ $xfer += $input->readSetBegin($_etype595, $_size592);
+ for ($_i596 = 0; $_i596 < $_size592; ++$_i596)
{
- $elem590 = null;
- $xfer += $input->readI64($elem590);
- if (is_scalar($elem590)) {
- $this->nosuch[$elem590] = true;
+ $elem597 = null;
+ $xfer += $input->readI64($elem597);
+ if (is_scalar($elem597)) {
+ $this->nosuch[$elem597] = true;
} else {
- $this->nosuch []= $elem590;
+ $this->nosuch []= $elem597;
}
}
$xfer += $input->readSetEnd();
@@ -19051,12 +19267,12 @@ class HeartbeatTxnRangeResponse {
{
$output->writeSetBegin(TType::I64, count($this->aborted));
{
- foreach ($this->aborted as $iter591 => $iter592)
+ foreach ($this->aborted as $iter598 => $iter599)
{
- if (is_scalar($iter592)) {
- $xfer += $output->writeI64($iter591);
+ if (is_scalar($iter599)) {
+ $xfer += $output->writeI64($iter598);
} else {
- $xfer += $output->writeI64($iter592);
+ $xfer += $output->writeI64($iter599);
}
}
}
@@ -19072,12 +19288,12 @@ class HeartbeatTxnRangeResponse {
{
$output->writeSetBegin(TType::I64, count($this->nosuch));
{
- foreach ($this->nosuch as $iter593 => $iter594)
+ foreach ($this->nosuch as $iter600 => $iter601)
{
- if (is_scalar($iter594)) {
- $xfer += $output->writeI64($iter593);
+ if (is_scalar($iter601)) {
+ $xfer += $output->writeI64($iter600);
} else {
- $xfer += $output->writeI64($iter594);
+ $xfer += $output->writeI64($iter601);
}
}
}
@@ -19236,17 +19452,17 @@ class CompactionRequest {
case 6:
if ($ftype == TType::MAP) {
$this->properties = array();
- $_size595 = 0;
- $_ktype596 = 0;
- $_vtype597 = 0;
- $xfer += $input->readMapBegin($_ktype596, $_vtype597, $_size595);
- for ($_i599 = 0; $_i599 < $_size595; ++$_i599)
+ $_size602 = 0;
+ $_ktype603 = 0;
+ $_vtype604 = 0;
+ $xfer += $input->readMapBegin($_ktype603, $_vtype604, $_size602);
+ for ($_i606 = 0; $_i606 < $_size602; ++$_i606)
{
- $key600 = '';
- $val601 = '';
- $xfer += $input->readString($key600);
- $xfer += $input->readString($val601);
- $this->properties[$key600] = $val601;
+ $key607 = '';
+ $val608 = '';
+ $xfer += $input->readString($key607);
+ $xfer += $input->readString($val608);
+ $this->properties[$key607] = $val608;
}
$xfer += $input->readMapEnd();
} else {
@@ -19299,10 +19515,10 @@ class CompactionRequest {
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->properties));
{
- foreach ($this->properties as $kiter602 => $viter603)
+ foreach ($this->properties as $kiter609 => $viter610)
{
- $xfer += $output->writeString($kiter602);
- $xfer += $output->writeString($viter603);
+ $xfer += $output->writeString($kiter609);
+ $xfer += $output->writeString($viter610);
}
}
$output->writeMapEnd();
@@ -19889,15 +20105,15 @@ class ShowCompactResponse {
case 1:
if ($ftype == TType::LST) {
$this->compacts = array();
- $_size604 = 0;
- $_etype607 = 0;
- $xfer += $input->readListBegin($_etype607, $_size604);
- for ($_i608 = 0; $_i608 < $_size604; ++$_i608)
+ $_size611 = 0;
+ $_etype614 = 0;
+ $xfer += $input->readListBegin($_etype614, $_size611);
+ for ($_i615 = 0; $_i615 < $_size611; ++$_i615)
{
- $elem609 = null;
- $elem609 = new \metastore\ShowCompactResponseElement();
- $xfer += $elem609->read($input);
- $this->compacts []= $elem609;
+ $elem616 = null;
+ $elem616 = new \metastore\ShowCompactResponseElement();
+ $xfer += $elem616->read($input);
+ $this->compacts []= $elem616;
}
$xfer += $input->readListEnd();
} else {
@@ -19925,9 +20141,9 @@ class ShowCompactResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->compacts));
{
- foreach ($this->compacts as $iter610)
+ foreach ($this->compacts as $iter617)
{
- $xfer += $iter610->write($output);
+ $xfer += $iter617->write($output);
}
}
$output->writeListEnd();
@@ -20074,14 +20290,14 @@ class AddDynamicPartitions {
case 5:
if ($ftype == TType::LST) {
$this->partitionnames = array();
- $_size611 = 0;
- $_etype614 = 0;
- $xfer += $input->readListBegin($_etype614, $_size611);
- for ($_i615 = 0; $_i615 < $_size611; ++$_i615)
+ $_size618 = 0;
+ $_etype621 = 0;
+ $xfer += $input->readListBegin($_etype621, $_size618);
+ for ($_i622 = 0; $_i622 < $_size618; ++$_i622)
{
- $elem616 = null;
- $xfer += $input->readString($elem616);
- $this->partitionnames []= $elem616;
+ $elem623 = null;
+ $xfer += $input->readString($elem623);
+ $this->partitionnames []= $elem623;
}
$xfer += $input->readListEnd();
} else {
@@ -20136,9 +20352,9 @@ class AddDynamicPartitions {
{
$output->writeListBegin(TType::STRING, count($this->partitionnames));
{
- foreach ($this->partitionnames as $iter617)
+ foreach ($this->partitionnames as $iter624)
{
- $xfer += $output->writeString($iter617);
+ $xfer += $output->writeString($iter624);
}
}
$output->writeListEnd();
@@ -20462,17 +20678,17 @@ class CreationMetadata {
case 4:
if ($ftype == TType::SET) {
$this->tablesUsed = array();
- $_size618 = 0;
- $_etype621 = 0;
- $xfer += $input->readSetBegin($_etype621, $_size618);
- for ($_i622 = 0; $_i622 < $_size618; ++$_i622)
+ $_size625 = 0;
+ $_etype628 = 0;
+ $xfer += $input->readSetBegin($_etype628, $_size625);
+ for ($_i629 = 0; $_i629 < $_size625; ++$_i629)
{
- $elem623 = null;
- $xfer += $input->readString($elem623);
- if (is_scalar($elem623)) {
- $this->tablesUsed[$elem623] = true;
+ $elem630 = null;
+ $xfer += $input->readString($elem630);
+ if (is_scalar($elem630)) {
+ $this->tablesUsed[$elem630] = true;
} else {
- $this->tablesUsed []= $elem623;
+ $this->tablesUsed []= $elem630;
}
}
$xfer += $input->readSetEnd();
@@ -20523,12 +20739,12 @@ class CreationMetadata {
{
$output->writeSetBegin(TType::STRING, count($this->tablesUsed));
{
- foreach ($this->tablesUsed as $iter624 => $iter625)
+ foreach ($this->tablesUsed as $iter631 => $iter632)
{
- if (is_scalar($iter625)) {
- $xfer += $output->writeString($iter624);
+ if (is_scalar($iter632)) {
+ $xfer += $output->writeString($iter631);
} else {
- $xfer += $output->writeString($iter625);
+ $xfer += $output->writeString($iter632);
}
}
}
@@ -20933,15 +21149,15 @@ class NotificationEventResponse {
case 1:
if ($ftype == TType::LST) {
$this->events = array();
- $_size626 = 0;
- $_etype629 = 0;
- $xfer += $input->readListBegin($_etype629, $_size626);
- for ($_i630 = 0; $_i630 < $_size626; ++$_i630)
+ $_size633 = 0;
+ $_etype636 = 0;
+ $xfer += $input->readListBegin($_etype636, $_size633);
+ for ($_i637 = 0; $_i637 < $_size633; ++$_i637)
{
- $elem631 = null;
- $elem631 = new \metastore\NotificationEvent();
- $xfer += $elem631->read($input);
- $this->events []= $elem631;
+ $elem638 = null;
+ $elem638 = new \metastore\NotificationEvent();
+ $xfer += $elem638->read($input);
+ $this->events []= $elem638;
}
$xfer += $input->readListEnd();
} else {
@@ -20969,9 +21185,9 @@ class NotificationEventResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->events));
{
- foreach ($this->events as $iter632)
+ foreach ($this->events as $iter639)
{
- $xfer += $iter632->write($output);
+ $xfer += $iter639->write($output);
}
}
$output->writeListEnd();
@@ -21339,14 +21555,14 @@ class InsertEventRequestData {
case 2:
if ($ftype == TType::LST) {
$this->filesAdded = array();
- $_size633 = 0;
- $_etype636 = 0;
- $xfer += $input->readListBegin($_etype636, $_size633);
- for ($_i637 = 0; $_i637 < $_size633; ++$_i637)
+ $_size640 = 0;
+ $_etype643 = 0;
+ $xfer += $input->readListBegin($_etype643, $_size640);
+ for ($_i644 = 0; $_i644 < $_size640; ++$_i644)
{
- $elem638 = null;
- $xfer += $input->readString($elem638);
- $this->filesAdded []= $elem638;
+ $elem645 = null;
+ $xfer += $input->readString($elem645);
+ $this->filesAdded []= $elem645;
}
$xfer += $input->readListEnd();
} else {
@@ -21356,14 +21572,14 @@ class InsertEventRequestData {
case 3:
if ($ftype == TType::LST) {
$this->filesAddedChecksum = array();
- $_size639 = 0;
- $_etype642 = 0;
- $xfer += $input->readListBegin($_etype642, $_size639);
- for ($_i643 = 0; $_i643 < $_size639; ++$_i643)
+ $_size646 = 0;
+ $_etype649 = 0;
+ $xfer += $input->readListBegin($_etype649, $_size646);
+ for ($_i650 = 0; $_i650 < $_size646; ++$_i650)
{
- $elem644 = null;
- $xfer += $input->readString($elem644);
- $this->filesAddedChecksum []= $elem644;
+ $elem651 = null;
+ $xfer += $input->readString($elem651);
+ $this->filesAddedChecksum []= $elem651;
}
$xfer += $input->readListEnd();
} else {
@@ -21396,9 +21612,9 @@ class InsertEventRequestData {
{
$output->writeListBegin(TType::STRING, count($this->filesAdded));
{
- foreach ($this->filesAdded as $iter645)
+ foreach ($this->filesAdded as $iter652)
{
- $xfer += $output->writeString($iter645);
+ $xfer += $output->writeString($iter652);
}
}
$output->writeListEnd();
@@ -21413,9 +21629,9 @@ class InsertEventRequestData {
{
$output->writeListBegin(TType::STRING, count($this->filesAddedChecksum));
{
- foreach ($this->filesAddedChecksum as $iter646)
+ foreach ($this->filesAddedChecksum as $iter653)
{
- $xfer += $output->writeString($iter646);
+ $xfer += $output->writeString($iter653);
}
}
$output->writeListEnd();
@@ -21644,14 +21860,14 @@ class FireEventRequest {
case 5:
if ($ftype == TType::LST) {
$this->partitionVals = array();
- $_size647 = 0;
- $_etype650 = 0;
- $xfer += $input->readListBegin($_etype650, $_size647);
- for ($_i651 = 0; $_i651 < $_size647; ++$_i651)
+ $_size654 = 0;
+ $_etype657 = 0;
+ $xfer += $input->readListBegin($_etype657, $_size654);
+ for ($_i658 = 0; $_i658 < $_size654; ++$_i658)
{
- $elem652 = null;
- $xfer += $input->readString($elem652);
- $this->partitionVals []= $elem652;
+ $elem659 = null;
+ $xfer += $input->readString($elem659);
+ $this->partitionVals []= $elem659;
}
$xfer += $input->readListEnd();
} else {
@@ -21709,9 +21925,9 @@ class FireEventRequest {
{
$output->writeListBegin(TType::STRING, count($this->partitionVals));
{
- foreach ($this->partitionVals as $iter653)
+ foreach ($this->partitionVals as $iter660)
{
- $xfer += $output->writeString($iter653);
+ $xfer += $output->writeString($iter660);
}
}
$output->writeListEnd();
@@ -21944,18 +22160,18 @@ class GetFileMetadataByExprResult {
case 1:
if ($ftype == TType::MAP) {
$this->metadata = array();
- $_size654 = 0;
- $_ktype655 = 0;
- $_vtype656 = 0;
- $xfer += $input->readMapBegin($_ktype655, $_vtype656, $_size654);
- for ($_i658 = 0; $_i658 < $_size654; ++$_i658)
+ $_size661 = 0;
+ $_ktype662 = 0;
+ $_vtype663 = 0;
+ $xfer += $input->readMapBegin($_ktype662, $_vtype663, $_size661);
+ for ($_i665 = 0; $_i665 < $_size661; ++$_i665)
{
- $key659 = 0;
- $val660 = new \metastore\MetadataPpdResult();
- $xfer += $input->readI64($key659);
- $val660 = new \metastore\MetadataPpdResult();
- $xfer += $val660->read($input);
- $this->metadata[$key659] = $val660;
+ $key666 = 0;
+ $val667 = new \metastore\MetadataPpdResult();
+ $xfer += $input->readI64($key666);
+ $val667 = new \metastore\MetadataPpdResult();
+ $xfer += $val667->read($input);
+ $this->metadata[$key666] = $val667;
}
$xfer += $input->readMapEnd();
} else {
@@ -21990,10 +22206,10 @@ class GetFileMetadataByExprResult {
{
$output->writeMapBegin(TType::I64, TType::STRUCT, count($this->metadata));
{
- foreach ($this->metadata as $kiter661 => $viter662)
+ foreach ($this->metadata as $kiter668 => $viter669)
{
- $xfer += $output->writeI64($kiter661);
- $xfer += $viter662->write($output);
+ $xfer += $output->writeI64($kiter668);
+ $xfer += $viter669->write($output);
}
}
$output->writeMapEnd();
@@ -22095,14 +22311,14 @@ class GetFileMetadataByExprRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size663 = 0;
- $_etype666 = 0;
- $xfer += $input->readListBegin($_etype666, $_size663);
- for ($_i667 = 0; $_i667 < $_size663; ++$_i667)
+ $_size670 = 0;
+ $_etype673 = 0;
+ $xfer += $input->readListBegin($_etype673, $_size670);
+ for ($_i674 = 0; $_i674 < $_size670; ++$_i674)
{
- $elem668 = null;
- $xfer += $input->readI64($elem668);
- $this->fileIds []= $elem668;
+ $elem675 = null;
+ $xfer += $input->readI64($elem675);
+ $this->fileIds []= $elem675;
}
$xfer += $input->readListEnd();
} else {
@@ -22151,9 +22367,9 @@ class GetFileMetadataByExprRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter669)
+ foreach ($this->fileIds as $iter676)
{
- $xfer += $output->writeI64($iter669);
+ $xfer += $output->writeI64($iter676);
}
}
$output->writeListEnd();
@@ -22247,17 +22463,17 @@ class GetFileMetadataResult {
case 1:
if ($ftype == TType::MAP) {
$this->metadata = array();
- $_size670 = 0;
- $_ktype671 = 0;
- $_vtype672 = 0;
- $xfer += $input->readMapBegin($_ktype671, $_vtype672, $_size670);
- for ($_i674 = 0; $_i674 < $_size670; ++$_i674)
+ $_size677 = 0;
+ $_ktype678 = 0;
+ $_vtype679 = 0;
+ $xfer += $input->readMapBegin($_ktype678, $_vtype679, $_size677);
+ for ($_i681 = 0; $_i681 < $_size677; ++$_i681)
{
- $key675 = 0;
- $val676 = '';
- $xfer += $input->readI64($key675);
- $xfer += $input->readString($val676);
- $this->metadata[$key675] = $val676;
+ $key682 = 0;
+ $val683 = '';
+ $xfer += $input->readI64($key682);
+ $xfer += $input->readString($val683);
+ $this->metadata[$key682] = $val683;
}
$xfer += $input->readMapEnd();
} else {
@@ -22292,10 +22508,10 @@ class GetFileMetadataResult {
{
$output->writeMapBegin(TType::I64, TType::STRING, count($this->metadata));
{
- foreach ($this->metadata as $kiter677 => $viter678)
+ foreach ($this->metadata as $kiter684 => $viter685)
{
- $xfer += $output->writeI64($kiter677);
- $xfer += $output->writeString($viter678);
+ $xfer += $output->writeI64($kiter684);
+ $xfer += $output->writeString($viter685);
}
}
$output->writeMapEnd();
@@ -22364,14 +22580,14 @@ class GetFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size679 = 0;
- $_etype682 = 0;
- $xfer += $input->readListBegin($_etype682, $_size679);
- for ($_i683 = 0; $_i683 < $_size679; ++$_i683)
+ $_size686 = 0;
+ $_etype689 = 0;
+ $xfer += $input->readListBegin($_etype689, $_size686);
+ for ($_i690 = 0; $_i690 < $_size686; ++$_i690)
{
- $elem684 = null;
- $xfer += $input->readI64($elem684);
- $this->fileIds []= $elem684;
+ $elem691 = null;
+ $xfer += $input->readI64($elem691);
+ $this->fileIds []= $elem691;
}
$xfer += $input->readListEnd();
} else {
@@ -22399,9 +22615,9 @@ class GetFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter685)
+ foreach ($this->fileIds as $iter692)
{
- $xfer += $output->writeI64($iter685);
+ $xfer += $output->writeI64($iter692);
}
}
$output->writeListEnd();
@@ -22541,14 +22757,14 @@ class PutFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size686 = 0;
- $_etype689 = 0;
- $xfer += $input->readListBegin($_etype689, $_size686);
- for ($_i690 = 0; $_i690 < $_size686; ++$_i690)
+ $_size693 = 0;
+ $_etype696 = 0;
+ $xfer += $input->readListBegin($_etype696, $_size693);
+ for ($_i697 = 0; $_i697 < $_size693; ++$_i697)
{
- $elem691 = null;
- $xfer += $input->readI64($elem691);
- $this->fileIds []= $elem691;
+ $elem698 = null;
+ $xfer += $input->readI64($elem698);
+ $this->fileIds []= $elem698;
}
$xfer += $input->readListEnd();
} else {
@@ -22558,14 +22774,14 @@ class PutFileMetadataRequest {
case 2:
if ($ftype == TType::LST) {
$this->metadata = array();
- $_size692 = 0;
- $_etype695 = 0;
- $xfer += $input->readListBegin($_etype695, $_size692);
- for ($_i696 = 0; $_i696 < $_size692; ++$_i696)
+ $_size699 = 0;
+ $_etype702 = 0;
+ $xfer += $input->readListBegin($_etype702, $_size699);
+ for ($_i703 = 0; $_i703 < $_size699; ++$_i703)
{
- $elem697 = null;
- $xfer += $input->readString($elem697);
- $this->metadata []= $elem697;
+ $elem704 = null;
+ $xfer += $input->readString($elem704);
+ $this->metadata []= $elem704;
}
$xfer += $input->readListEnd();
} else {
@@ -22600,9 +22816,9 @@ class PutFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter698)
+ foreach ($this->fileIds as $iter705)
{
- $xfer += $output->writeI64($iter698);
+ $xfer += $output->writeI64($iter705);
}
}
$output->writeListEnd();
@@ -22617,9 +22833,9 @@ class PutFileMetadataRequest {
{
$output->writeListBegin(TType::STRING, count($this->metadata));
{
- foreach ($this->metadata as $iter699)
+ foreach ($this->metadata as $iter706)
{
- $xfer += $output->writeString($iter699);
+ $xfer += $output->writeString($iter706);
}
}
$output->writeListEnd();
@@ -22738,14 +22954,14 @@ class ClearFileMetadataRequest {
case 1:
if ($ftype == TType::LST) {
$this->fileIds = array();
- $_size700 = 0;
- $_etype703 = 0;
- $xfer += $input->readListBegin($_etype703, $_size700);
- for ($_i704 = 0; $_i704 < $_size700; ++$_i704)
+ $_size707 = 0;
+ $_etype710 = 0;
+ $xfer += $input->readListBegin($_etype710, $_size707);
+ for ($_i711 = 0; $_i711 < $_size707; ++$_i711)
{
- $elem705 = null;
- $xfer += $input->readI64($elem705);
- $this->fileIds []= $elem705;
+ $elem712 = null;
+ $xfer += $input->readI64($elem712);
+ $this->fileIds []= $elem712;
}
$xfer += $input->readListEnd();
} else {
@@ -22773,9 +22989,9 @@ class ClearFileMetadataRequest {
{
$output->writeListBegin(TType::I64, count($this->fileIds));
{
- foreach ($this->fileIds as $iter706)
+ foreach ($this->fileIds as $iter713)
{
- $xfer += $output->writeI64($iter706);
+ $xfer += $output->writeI64($iter713);
}
}
$output->writeListEnd();
@@ -23059,15 +23275,15 @@ class GetAllFunctionsResponse {
case 1:
if ($ftype == TType::LST) {
$this->functions = array();
- $_size707 = 0;
- $_etype710 = 0;
- $xfer += $input->readListBegin($_etype710, $_size707);
- for ($_i711 = 0; $_i711 < $_size707; ++$_i711)
+ $_size714 = 0;
+ $_etype717 = 0;
+ $xfer += $input->readListBegin($_etype717, $_size714);
+ for ($_i718 = 0; $_i718 < $_size714; ++$_i718)
{
- $elem712 = null;
- $elem712 = new \metastore\Function();
- $xfer += $elem712->read($input);
- $this->functions []= $elem712;
+ $elem719 = null;
+ $elem719 = new \metastore\Function();
+ $xfer += $elem719->read($input);
+ $this->functions []= $elem719;
}
$xfer += $input->readListEnd();
} else {
@@ -23095,9 +23311,9 @@ class GetAllFunctionsResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->functions));
{
- foreach ($this->functions as $iter713)
+ foreach ($this->functions as $iter720)
{
- $xfer += $iter713->write($output);
+ $xfer += $iter720->write($output);
}
}
$output->writeListEnd();
@@ -23161,14 +23377,14 @@ class ClientCapabilities {
case 1:
if ($ftype == TType::LST) {
$this->values = array();
- $_size714 = 0;
- $_etype717 = 0;
- $xfer += $input->readListBegin($_etype717, $_size714);
- for ($_i718 = 0; $_i718 < $_size714; ++$_i718)
+ $_size721 = 0;
+ $_etype724 = 0;
+ $xfer += $input->readListBegin($_etype724, $_size721);
+ for ($_i725 = 0; $_i725 < $_size721; ++$_i725)
{
- $elem719 = null;
- $xfer += $input->readI32($elem719);
- $this->values []= $elem719;
+ $elem726 = null;
+ $xfer += $input->readI32($elem726);
+ $this->values []= $elem726;
}
$xfer += $input->readListEnd();
} else {
@@ -23196,9 +23412,9 @@ class ClientCapabilities {
{
$output->writeListBegin(TType::I32, count($this->values));
{
- foreach ($this->values as $iter720)
+ foreach ($this->values as $iter727)
{
- $xfer += $output->writeI32($iter720);
+ $xfer += $output->writeI32($iter727);
}
}
$output->writeListEnd();
@@ -23532,14 +23748,14 @@ class GetTablesRequest {
case 2:
if ($ftype == TType::LST) {
$this->tblNames = array();
- $_size721 = 0;
- $_etype724 = 0;
- $xfer += $input->readListBegin($_etype724, $_size721);
- for ($_i725 = 0; $_i725 < $_size721; ++$_i725)
+ $_size728 = 0;
+ $_etype731 = 0;
+ $xfer += $input->readListBegin($_etype731, $_size728);
+ for ($_i732 = 0; $_i732 < $_size728; ++$_i732)
{
- $elem726 = null;
- $xfer += $input->readString($elem726);
- $this->tblNames []= $elem726;
+ $elem733 = null;
+ $xfer += $input->readString($elem733);
+ $this->tblNames []= $elem733;
}
$xfer += $input->readListEnd();
} else {
@@ -23587,9 +23803,9 @@ class GetTablesRequest {
{
$output->writeListBegin(TType::STRING, count($this->tblNames));
{
- foreach ($this->tblNames as $iter727)
+ foreach ($this->tblNames as $iter734)
{
- $xfer += $output->writeString($iter727);
+ $xfer += $output->writeString($iter734);
}
}
$output->writeListEnd();
@@ -23667,15 +23883,15 @@ class GetTablesResult {
case 1:
if ($ftype == TType::LST) {
$this->tables = array();
- $_size728 = 0;
- $_etype731 = 0;
- $xfer += $input->readListBegin($_etype731, $_size728);
- for ($_i732 = 0; $_i732 < $_size728; ++$_i732)
+ $_size735 = 0;
+ $_etype738 = 0;
+ $xfer += $input->readListBegin($_etype738, $_size735);
+ for ($_i739 = 0; $_i739 < $_size735; ++$_i739)
{
- $elem733 = null;
- $elem733 = new \metastore\Table();
- $xfer += $elem733->read($input);
- $this->tables []= $elem733;
+ $elem740 = null;
+ $elem740 = new \metastore\Table();
+ $xfer += $elem740->read($input);
+ $this->tables []= $elem740;
}
$xfer += $input->readListEnd();
} else {
@@ -23703,9 +23919,9 @@ class GetTablesResult {
{
$output->writeListBegin(TType::STRUCT, count($this->tables));
{
- foreach ($this->tables as $iter734)
+ foreach ($this->tables as $iter741)
{
- $xfer += $iter734->write($output);
+ $xfer += $iter741->write($output);
}
}
$output->writeListEnd();
@@ -24117,17 +24333,17 @@ class Materialization {
case 1:
if ($ftype == TType::SET) {
$this->tablesUsed = array();
- $_size735 = 0;
- $_etype738 = 0;
- $xfer += $input->readSetBegin($_etype738, $_size735);
- for ($_i739 = 0; $_i739 < $_size735; ++$_i739)
+ $_size742 = 0;
+ $_etype745 = 0;
+ $xfer += $input->readSetBegin($_etype745, $_size742);
+ for ($_i746 = 0; $_i746 < $_size742; ++$_i746)
{
- $elem740 = null;
- $xfer += $input->readString($elem740);
- if (is_scalar($elem740)) {
- $this->tablesUsed[$elem740] = true;
+ $elem747 = null;
+ $xfer += $input->readString($elem747);
+ if (is_scalar($elem747)) {
+ $this->tablesUsed[$elem747] = true;
} else {
- $this->tablesUsed []= $elem740;
+ $this->tablesUsed []= $elem747;
}
}
$xfer += $input->readSetEnd();
@@ -24177,12 +24393,12 @@ class Materialization {
{
$output->writeSetBegin(TType::STRING, count($this->tablesUsed));
{
- foreach ($this->tablesUsed as $iter741 => $iter742)
+ foreach ($this->tablesUsed as $iter748 => $iter749)
{
- if (is_scalar($iter742)) {
- $xfer += $output->writeString($iter741);
+ if (is_scalar($iter749)) {
+ $xfer += $output->writeString($iter748);
} else {
- $xfer += $output->writeString($iter742);
+ $xfer += $output->writeString($iter749);
}
}
}
@@ -25454,15 +25670,15 @@ class WMFullResourcePlan {
case 2:
if ($ftype == TType::LST) {
$this->pools = array();
- $_size743 = 0;
- $_etype746 = 0;
- $xfer += $input->readListBegin($_etype746, $_size743);
- for ($_i747 = 0; $_i747 < $_size743; ++$_i747)
+ $_size750 = 0;
+ $_etype753 = 0;
+ $xfer += $input->readListBegin($_etype753, $_size750);
+ for ($_i754 = 0; $_i754 < $_size750; ++$_i754)
{
- $elem748 = null;
- $elem748 = new \metastore\WMPool();
- $xfer += $elem748->read($input);
- $this->pools []= $elem748;
+ $elem755 = null;
+ $elem755 = new \metastore\WMPool();
+ $xfer += $elem755->read($input);
+ $this->pools []= $elem755;
}
$xfer += $input->readListEnd();
} else {
@@ -25472,15 +25688,15 @@ class WMFullResourcePlan {
case 3:
if ($ftype == TType::LST) {
$this->mappings = array();
- $_size749 = 0;
- $_etype752 = 0;
- $xfer += $input->readListBegin($_etype752, $_size749);
- for ($_i753 = 0; $_i753 < $_size749; ++$_i753)
+ $_size756 = 0;
+ $_etype759 = 0;
+ $xfer += $input->readListBegin($_etype759, $_size756);
+ for ($_i760 = 0; $_i760 < $_size756; ++$_i760)
{
- $elem754 = null;
- $elem754 = new \metastore\WMMapping();
- $xfer += $elem754->read($input);
- $this->mappings []= $elem754;
+ $elem761 = null;
+ $elem761 = new \metastore\WMMapping();
+ $xfer += $elem761->read($input);
+ $this->mappings []= $elem761;
}
$xfer += $input->readListEnd();
} else {
@@ -25490,15 +25706,15 @@ class WMFullResourcePlan {
case 4:
if ($ftype == TType::LST) {
$this->triggers = array();
- $_size755 = 0;
- $_etype758 = 0;
- $xfer += $input->readListBegin($_etype758, $_size755);
- for ($_i759 = 0; $_i759 < $_size755; ++$_i759)
+ $_size762 = 0;
+ $_etype765 = 0;
+ $xfer += $input->readListBegin($_etype765, $_size762);
+ for ($_i766 = 0; $_i766 < $_size762; ++$_i766)
{
- $elem760 = null;
- $elem760 = new \metastore\WMTrigger();
- $xfer += $elem760->read($input);
- $this->triggers []= $elem760;
+ $elem767 = null;
+ $elem767 = new \metastore\WMTrigger();
+ $xfer += $elem767->read($input);
+ $this->triggers []= $elem767;
}
$xfer += $input->readListEnd();
} else {
@@ -25508,15 +25724,15 @@ class WMFullResourcePlan {
case 5:
if ($ftype == TType::LST) {
$this->poolTriggers = array();
- $_size761 = 0;
- $_etype764 = 0;
- $xfer += $input->readListBegin($_etype764, $_size761);
- for ($_i765 = 0; $_i765 < $_size761; ++$_i765)
+ $_size768 = 0;
+ $_etype771 = 0;
+ $xfer += $input->readListBegin($_etype771, $_size768);
+ for ($_i772 = 0; $_i772 < $_size768; ++$_i772)
{
- $elem766 = null;
- $elem766 = new \metastore\WMPoolTrigger();
- $xfer += $elem766->read($input);
- $this->poolTriggers []= $elem766;
+ $elem773 = null;
+ $elem773 = new \metastore\WMPoolTrigger();
+ $xfer += $elem773->read($input);
+ $this->poolTriggers []= $elem773;
}
$xfer += $input->readListEnd();
} else {
@@ -25552,9 +25768,9 @@ class WMFullResourcePlan {
{
$output->writeListBegin(TType::STRUCT, count($this->pools));
{
- foreach ($this->pools as $iter767)
+ foreach ($this->pools as $iter774)
{
- $xfer += $iter767->write($output);
+ $xfer += $iter774->write($output);
}
}
$output->writeListEnd();
@@ -25569,9 +25785,9 @@ class WMFullResourcePlan {
{
$output->writeListBegin(TType::STRUCT, count($this->mappings));
{
- foreach ($this->mappings as $iter768)
+ foreach ($this->mappings as $iter775)
{
- $xfer += $iter768->write($output);
+ $xfer += $iter775->write($output);
}
}
$output->writeListEnd();
@@ -25586,9 +25802,9 @@ class WMFullResourcePlan {
{
$output->writeListBegin(TType::STRUCT, count($this->triggers));
{
- foreach ($this->triggers as $iter769)
+ foreach ($this->triggers as $iter776)
{
- $xfer += $iter769->write($output);
+ $xfer += $iter776->write($output);
}
}
$output->writeListEnd();
@@ -25603,9 +25819,9 @@ class WMFullResourcePlan {
{
$output->writeListBegin(TType::STRUCT, count($this->poolTriggers));
{
- foreach ($this->poolTriggers as $iter770)
+ foreach ($this->poolTriggers as $iter777)
{
- $xfer += $iter770->write($output);
+ $xfer += $iter777->write($output);
}
}
$output->writeListEnd();
@@ -26158,15 +26374,15 @@ class WMGetAllResourcePlanResponse {
case 1:
if ($ftype == TType::LST) {
$this->resourcePlans = array();
- $_size771 = 0;
- $_etype774 = 0;
- $xfer += $input->readListBegin($_etype774, $_size771);
- for ($_i775 = 0; $_i775 < $_size771; ++$_i775)
+ $_size778 = 0;
+ $_etype781 = 0;
+ $xfer += $input->readListBegin($_etype781, $_size778);
+ for ($_i782 = 0; $_i782 < $_size778; ++$_i782)
{
- $elem776 = null;
- $elem776 = new \metastore\WMResourcePlan();
- $xfer += $elem776->read($input);
- $this->resourcePlans []= $elem776;
+ $elem783 = null;
+ $elem783 = new \metastore\WMResourcePlan();
+ $xfer += $elem783->read($input);
+ $this->resourcePlans []= $elem783;
}
$xfer += $input->readListEnd();
} else {
@@ -26194,9 +26410,9 @@ class WMGetAllResourcePlanResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->resourcePlans));
{
- foreach ($this->resourcePlans as $iter777)
+ foreach ($this->resourcePlans as $iter784)
{
- $xfer += $iter777->write($output);
+ $xfer += $iter784->write($output);
}
}
$output->writeListEnd();
@@ -26602,14 +26818,14 @@ class WMValidateResourcePlanResponse {
case 1:
if ($ftype == TType::LST) {
$this->errors = array();
- $_size778 = 0;
- $_etype781 = 0;
- $xfer += $input->readListBegin($_etype781, $_size778);
- for ($_i782 = 0; $_i782 < $_size778; ++$_i782)
+ $_size785 = 0;
+ $_etype788 = 0;
+ $xfer += $input->readListBegin($_etype788, $_size785);
+ for ($_i789 = 0; $_i789 < $_size785; ++$_i789)
{
- $elem783 = null;
- $xfer += $input->readString($elem783);
- $this->errors []= $elem783;
+ $elem790 = null;
+ $xfer += $input->readString($elem790);
+ $this->errors []= $elem790;
}
$xfer += $input->readListEnd();
} else {
@@ -26619,14 +26835,14 @@ class WMValidateResourcePlanResponse {
case 2:
if ($ftype == TType::LST) {
$this->warnings = array();
- $_size784 = 0;
- $_etype787 = 0;
- $xfer += $input->readListBegin($_etype787, $_size784);
- for ($_i788 = 0; $_i788 < $_size784; ++$_i788)
+ $_size791 = 0;
+ $_etype794 = 0;
+ $xfer += $input->readListBegin($_etype794, $_size791);
+ for ($_i795 = 0; $_i795 < $_size791; ++$_i795)
{
- $elem789 = null;
- $xfer += $input->readString($elem789);
- $this->warnings []= $elem789;
+ $elem796 = null;
+ $xfer += $input->readString($elem796);
+ $this->warnings []= $elem796;
}
$xfer += $input->readListEnd();
} else {
@@ -26654,9 +26870,9 @@ class WMValidateResourcePlanResponse {
{
$output->writeListBegin(TType::STRING, count($this->errors));
{
- foreach ($this->errors as $iter790)
+ foreach ($this->errors as $iter797)
{
- $xfer += $output->writeString($iter790);
+ $xfer += $output->writeString($iter797);
}
}
$output->writeListEnd();
@@ -26671,9 +26887,9 @@ class WMValidateResourcePlanResponse {
{
$output->writeListBegin(TType::STRING, count($this->warnings));
{
- foreach ($this->warnings as $iter791)
+ foreach ($this->warnings as $iter798)
{
- $xfer += $output->writeString($iter791);
+ $xfer += $output->writeString($iter798);
}
}
$output->writeListEnd();
@@ -27346,15 +27562,15 @@ class WMGetTriggersForResourePlanResponse {
case 1:
if ($ftype == TType::LST) {
$this->triggers = array();
- $_size792 = 0;
- $_etype795 = 0;
- $xfer += $input->readListBegin($_etype795, $_size792);
- for ($_i796 = 0; $_i796 < $_size792; ++$_i796)
+ $_size799 = 0;
+ $_etype802 = 0;
+ $xfer += $input->readListBegin($_etype802, $_size799);
+ for ($_i803 = 0; $_i803 < $_size799; ++$_i803)
{
- $elem797 = null;
- $elem797 = new \metastore\WMTrigger();
- $xfer += $elem797->read($input);
- $this->triggers []= $elem797;
+ $elem804 = null;
+ $elem804 = new \metastore\WMTrigger();
+ $xfer += $elem804->read($input);
+ $this->triggers []= $elem804;
}
$xfer += $input->readListEnd();
} else {
@@ -27382,9 +27598,9 @@ class WMGetTriggersForResourePlanResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->triggers));
{
- foreach ($this->triggers as $iter798)
+ foreach ($this->triggers as $iter805)
{
- $xfer += $iter798->write($output);
+ $xfer += $iter805->write($output);
}
}
$output->writeListEnd();
@@ -28968,15 +29184,15 @@ class SchemaVersion {
case 4:
if ($ftype == TType::LST) {
$this->cols = array();
- $_size799 = 0;
- $_etype802 = 0;
- $xfer += $input->readListBegin($_etype802, $_size799);
- for ($_i803 = 0; $_i803 < $_size799; ++$_i803)
+ $_size806 = 0;
+ $_etype809 = 0;
+ $xfer += $input->readListBegin($_etype809, $_size806);
+ for ($_i810 = 0; $_i810 < $_size806; ++$_i810)
{
- $elem804 = null;
- $elem804 = new \metastore\FieldSchema();
- $xfer += $elem804->read($input);
- $this->cols []= $elem804;
+ $elem811 = null;
+ $elem811 = new \metastore\FieldSchema();
+ $xfer += $elem811->read($input);
+ $this->cols []= $elem811;
}
$xfer += $input->readListEnd();
} else {
@@ -29065,9 +29281,9 @@ class SchemaVersion {
{
$output->writeListBegin(TType::STRUCT, count($this->cols));
{
- foreach ($this->cols as $iter805)
+ foreach ($this->cols as $iter812)
{
- $xfer += $iter805->write($output);
+ $xfer += $iter812->write($output);
}
}
$output->writeListEnd();
@@ -29389,15 +29605,15 @@ class FindSchemasByColsResp {
case 1:
if ($ftype == TType::LST) {
$this->schemaVersions = array();
- $_size806 = 0;
- $_etype809 = 0;
- $xfer += $input->readListBegin($_etype809, $_size806);
- for ($_i810 = 0; $_i810 < $_size806; ++$_i810)
+ $_size813 = 0;
+ $_etype816 = 0;
+ $xfer += $input->readListBegin($_etype816, $_size813);
+ for ($_i817 = 0; $_i817 < $_size813; ++$_i817)
{
- $elem811 = null;
- $elem811 = new \metastore\SchemaVersionDescriptor();
- $xfer += $elem811->read($input);
- $this->schemaVersions []= $elem811;
+ $elem818 = null;
+ $elem818 = new \metastore\SchemaVersionDescriptor();
+ $xfer += $elem818->read($input);
+ $this->schemaVersions []= $elem818;
}
$xfer += $input->readListEnd();
} else {
@@ -29425,9 +29641,9 @@ class FindSchemasByColsResp {
{
$output->writeListBegin(TType::STRUCT, count($this->schemaVersions));
{
- foreach ($this->schemaVersions as $iter812)
+ foreach ($this->schemaVersions as $iter819)
{
- $xfer += $iter812->write($output);
+ $xfer += $iter819->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/e8651cb9/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
index a231e9c..c6c7b74 100755
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
@@ -169,6 +169,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print(' void abort_txn(AbortTxnRequest rqst)')
print(' void abort_txns(AbortTxnsRequest rqst)')
print(' void commit_txn(CommitTxnRequest rqst)')
+ print(' void repl_tbl_writeid_state(ReplTblWriteIdStateRequest rqst)')
print(' GetValidWriteIdsResponse get_valid_write_ids(GetValidWriteIdsRequest rqst)')
print(' AllocateTableWriteIdsResponse allocate_table_write_ids(AllocateTableWriteIdsRequest rqst)')
print(' LockResponse lock(LockRequest rqst)')
@@ -1167,6 +1168,12 @@ elif cmd == 'commit_txn':
sys.exit(1)
pp.pprint(client.commit_txn(eval(args[0]),))
+elif cmd == 'repl_tbl_writeid_state':
+ if len(args) != 1:
+ print('repl_tbl_writeid_state requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.repl_tbl_writeid_state(eval(args[0]),))
+
elif cmd == 'get_valid_write_ids':
if len(args) != 1:
print('get_valid_write_ids requires 1 args')