You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/07/18 18:52:40 UTC
[44/48] hive git commit: HIVE-19416 : merge master into branch
(Sergey Shelukhin) 0718
http://git-wip-us.apache.org/repos/asf/hive/blob/37a1907b/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php
----------------------------------------------------------------------
diff --cc standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php
index 5a22e4e,ae12471..292cf51
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/Types.php
@@@ -27273,15 -26323,15 +27193,15 @@@ class WMFullResourcePlan
case 2:
if ($ftype == TType::LST) {
$this->pools = array();
- $_size778 = 0;
- $_etype781 = 0;
- $xfer += $input->readListBegin($_etype781, $_size778);
- for ($_i782 = 0; $_i782 < $_size778; ++$_i782)
- $_size763 = 0;
- $_etype766 = 0;
- $xfer += $input->readListBegin($_etype766, $_size763);
- for ($_i767 = 0; $_i767 < $_size763; ++$_i767)
++ $_size770 = 0;
++ $_etype773 = 0;
++ $xfer += $input->readListBegin($_etype773, $_size770);
++ for ($_i774 = 0; $_i774 < $_size770; ++$_i774)
{
- $elem783 = null;
- $elem783 = new \metastore\WMPool();
- $xfer += $elem783->read($input);
- $this->pools []= $elem783;
- $elem768 = null;
- $elem768 = new \metastore\WMPool();
- $xfer += $elem768->read($input);
- $this->pools []= $elem768;
++ $elem775 = null;
++ $elem775 = new \metastore\WMPool();
++ $xfer += $elem775->read($input);
++ $this->pools []= $elem775;
}
$xfer += $input->readListEnd();
} else {
@@@ -27291,15 -26341,15 +27211,15 @@@
case 3:
if ($ftype == TType::LST) {
$this->mappings = array();
- $_size784 = 0;
- $_etype787 = 0;
- $xfer += $input->readListBegin($_etype787, $_size784);
- for ($_i788 = 0; $_i788 < $_size784; ++$_i788)
- $_size769 = 0;
- $_etype772 = 0;
- $xfer += $input->readListBegin($_etype772, $_size769);
- for ($_i773 = 0; $_i773 < $_size769; ++$_i773)
++ $_size776 = 0;
++ $_etype779 = 0;
++ $xfer += $input->readListBegin($_etype779, $_size776);
++ for ($_i780 = 0; $_i780 < $_size776; ++$_i780)
{
- $elem789 = null;
- $elem789 = new \metastore\WMMapping();
- $xfer += $elem789->read($input);
- $this->mappings []= $elem789;
- $elem774 = null;
- $elem774 = new \metastore\WMMapping();
- $xfer += $elem774->read($input);
- $this->mappings []= $elem774;
++ $elem781 = null;
++ $elem781 = new \metastore\WMMapping();
++ $xfer += $elem781->read($input);
++ $this->mappings []= $elem781;
}
$xfer += $input->readListEnd();
} else {
@@@ -27309,15 -26359,15 +27229,15 @@@
case 4:
if ($ftype == TType::LST) {
$this->triggers = array();
- $_size790 = 0;
- $_etype793 = 0;
- $xfer += $input->readListBegin($_etype793, $_size790);
- for ($_i794 = 0; $_i794 < $_size790; ++$_i794)
- $_size775 = 0;
- $_etype778 = 0;
- $xfer += $input->readListBegin($_etype778, $_size775);
- for ($_i779 = 0; $_i779 < $_size775; ++$_i779)
++ $_size782 = 0;
++ $_etype785 = 0;
++ $xfer += $input->readListBegin($_etype785, $_size782);
++ for ($_i786 = 0; $_i786 < $_size782; ++$_i786)
{
- $elem795 = null;
- $elem795 = new \metastore\WMTrigger();
- $xfer += $elem795->read($input);
- $this->triggers []= $elem795;
- $elem780 = null;
- $elem780 = new \metastore\WMTrigger();
- $xfer += $elem780->read($input);
- $this->triggers []= $elem780;
++ $elem787 = null;
++ $elem787 = new \metastore\WMTrigger();
++ $xfer += $elem787->read($input);
++ $this->triggers []= $elem787;
}
$xfer += $input->readListEnd();
} else {
@@@ -27327,15 -26377,15 +27247,15 @@@
case 5:
if ($ftype == TType::LST) {
$this->poolTriggers = array();
- $_size796 = 0;
- $_etype799 = 0;
- $xfer += $input->readListBegin($_etype799, $_size796);
- for ($_i800 = 0; $_i800 < $_size796; ++$_i800)
- $_size781 = 0;
- $_etype784 = 0;
- $xfer += $input->readListBegin($_etype784, $_size781);
- for ($_i785 = 0; $_i785 < $_size781; ++$_i785)
++ $_size788 = 0;
++ $_etype791 = 0;
++ $xfer += $input->readListBegin($_etype791, $_size788);
++ for ($_i792 = 0; $_i792 < $_size788; ++$_i792)
{
- $elem801 = null;
- $elem801 = new \metastore\WMPoolTrigger();
- $xfer += $elem801->read($input);
- $this->poolTriggers []= $elem801;
- $elem786 = null;
- $elem786 = new \metastore\WMPoolTrigger();
- $xfer += $elem786->read($input);
- $this->poolTriggers []= $elem786;
++ $elem793 = null;
++ $elem793 = new \metastore\WMPoolTrigger();
++ $xfer += $elem793->read($input);
++ $this->poolTriggers []= $elem793;
}
$xfer += $input->readListEnd();
} else {
@@@ -27371,9 -26421,9 +27291,9 @@@
{
$output->writeListBegin(TType::STRUCT, count($this->pools));
{
- foreach ($this->pools as $iter802)
- foreach ($this->pools as $iter787)
++ foreach ($this->pools as $iter794)
{
- $xfer += $iter802->write($output);
- $xfer += $iter787->write($output);
++ $xfer += $iter794->write($output);
}
}
$output->writeListEnd();
@@@ -27388,9 -26438,9 +27308,9 @@@
{
$output->writeListBegin(TType::STRUCT, count($this->mappings));
{
- foreach ($this->mappings as $iter803)
- foreach ($this->mappings as $iter788)
++ foreach ($this->mappings as $iter795)
{
- $xfer += $iter803->write($output);
- $xfer += $iter788->write($output);
++ $xfer += $iter795->write($output);
}
}
$output->writeListEnd();
@@@ -27405,9 -26455,9 +27325,9 @@@
{
$output->writeListBegin(TType::STRUCT, count($this->triggers));
{
- foreach ($this->triggers as $iter804)
- foreach ($this->triggers as $iter789)
++ foreach ($this->triggers as $iter796)
{
- $xfer += $iter804->write($output);
- $xfer += $iter789->write($output);
++ $xfer += $iter796->write($output);
}
}
$output->writeListEnd();
@@@ -27422,9 -26472,9 +27342,9 @@@
{
$output->writeListBegin(TType::STRUCT, count($this->poolTriggers));
{
- foreach ($this->poolTriggers as $iter805)
- foreach ($this->poolTriggers as $iter790)
++ foreach ($this->poolTriggers as $iter797)
{
- $xfer += $iter805->write($output);
- $xfer += $iter790->write($output);
++ $xfer += $iter797->write($output);
}
}
$output->writeListEnd();
@@@ -27977,15 -27027,15 +27897,15 @@@ class WMGetAllResourcePlanResponse
case 1:
if ($ftype == TType::LST) {
$this->resourcePlans = array();
- $_size806 = 0;
- $_etype809 = 0;
- $xfer += $input->readListBegin($_etype809, $_size806);
- for ($_i810 = 0; $_i810 < $_size806; ++$_i810)
- $_size791 = 0;
- $_etype794 = 0;
- $xfer += $input->readListBegin($_etype794, $_size791);
- for ($_i795 = 0; $_i795 < $_size791; ++$_i795)
++ $_size798 = 0;
++ $_etype801 = 0;
++ $xfer += $input->readListBegin($_etype801, $_size798);
++ for ($_i802 = 0; $_i802 < $_size798; ++$_i802)
{
- $elem811 = null;
- $elem811 = new \metastore\WMResourcePlan();
- $xfer += $elem811->read($input);
- $this->resourcePlans []= $elem811;
- $elem796 = null;
- $elem796 = new \metastore\WMResourcePlan();
- $xfer += $elem796->read($input);
- $this->resourcePlans []= $elem796;
++ $elem803 = null;
++ $elem803 = new \metastore\WMResourcePlan();
++ $xfer += $elem803->read($input);
++ $this->resourcePlans []= $elem803;
}
$xfer += $input->readListEnd();
} else {
@@@ -28013,9 -27063,9 +27933,9 @@@
{
$output->writeListBegin(TType::STRUCT, count($this->resourcePlans));
{
- foreach ($this->resourcePlans as $iter812)
- foreach ($this->resourcePlans as $iter797)
++ foreach ($this->resourcePlans as $iter804)
{
- $xfer += $iter812->write($output);
- $xfer += $iter797->write($output);
++ $xfer += $iter804->write($output);
}
}
$output->writeListEnd();
@@@ -28421,14 -27471,14 +28341,14 @@@ class WMValidateResourcePlanResponse
case 1:
if ($ftype == TType::LST) {
$this->errors = array();
- $_size813 = 0;
- $_etype816 = 0;
- $xfer += $input->readListBegin($_etype816, $_size813);
- for ($_i817 = 0; $_i817 < $_size813; ++$_i817)
- $_size798 = 0;
- $_etype801 = 0;
- $xfer += $input->readListBegin($_etype801, $_size798);
- for ($_i802 = 0; $_i802 < $_size798; ++$_i802)
++ $_size805 = 0;
++ $_etype808 = 0;
++ $xfer += $input->readListBegin($_etype808, $_size805);
++ for ($_i809 = 0; $_i809 < $_size805; ++$_i809)
{
- $elem818 = null;
- $xfer += $input->readString($elem818);
- $this->errors []= $elem818;
- $elem803 = null;
- $xfer += $input->readString($elem803);
- $this->errors []= $elem803;
++ $elem810 = null;
++ $xfer += $input->readString($elem810);
++ $this->errors []= $elem810;
}
$xfer += $input->readListEnd();
} else {
@@@ -28438,14 -27488,14 +28358,14 @@@
case 2:
if ($ftype == TType::LST) {
$this->warnings = array();
- $_size819 = 0;
- $_etype822 = 0;
- $xfer += $input->readListBegin($_etype822, $_size819);
- for ($_i823 = 0; $_i823 < $_size819; ++$_i823)
- $_size804 = 0;
- $_etype807 = 0;
- $xfer += $input->readListBegin($_etype807, $_size804);
- for ($_i808 = 0; $_i808 < $_size804; ++$_i808)
++ $_size811 = 0;
++ $_etype814 = 0;
++ $xfer += $input->readListBegin($_etype814, $_size811);
++ for ($_i815 = 0; $_i815 < $_size811; ++$_i815)
{
- $elem824 = null;
- $xfer += $input->readString($elem824);
- $this->warnings []= $elem824;
- $elem809 = null;
- $xfer += $input->readString($elem809);
- $this->warnings []= $elem809;
++ $elem816 = null;
++ $xfer += $input->readString($elem816);
++ $this->warnings []= $elem816;
}
$xfer += $input->readListEnd();
} else {
@@@ -28473,9 -27523,9 +28393,9 @@@
{
$output->writeListBegin(TType::STRING, count($this->errors));
{
- foreach ($this->errors as $iter825)
- foreach ($this->errors as $iter810)
++ foreach ($this->errors as $iter817)
{
- $xfer += $output->writeString($iter825);
- $xfer += $output->writeString($iter810);
++ $xfer += $output->writeString($iter817);
}
}
$output->writeListEnd();
@@@ -28490,9 -27540,9 +28410,9 @@@
{
$output->writeListBegin(TType::STRING, count($this->warnings));
{
- foreach ($this->warnings as $iter826)
- foreach ($this->warnings as $iter811)
++ foreach ($this->warnings as $iter818)
{
- $xfer += $output->writeString($iter826);
- $xfer += $output->writeString($iter811);
++ $xfer += $output->writeString($iter818);
}
}
$output->writeListEnd();
@@@ -29165,15 -28215,15 +29085,15 @@@ class WMGetTriggersForResourePlanRespon
case 1:
if ($ftype == TType::LST) {
$this->triggers = array();
- $_size827 = 0;
- $_etype830 = 0;
- $xfer += $input->readListBegin($_etype830, $_size827);
- for ($_i831 = 0; $_i831 < $_size827; ++$_i831)
- $_size812 = 0;
- $_etype815 = 0;
- $xfer += $input->readListBegin($_etype815, $_size812);
- for ($_i816 = 0; $_i816 < $_size812; ++$_i816)
++ $_size819 = 0;
++ $_etype822 = 0;
++ $xfer += $input->readListBegin($_etype822, $_size819);
++ for ($_i823 = 0; $_i823 < $_size819; ++$_i823)
{
- $elem832 = null;
- $elem832 = new \metastore\WMTrigger();
- $xfer += $elem832->read($input);
- $this->triggers []= $elem832;
- $elem817 = null;
- $elem817 = new \metastore\WMTrigger();
- $xfer += $elem817->read($input);
- $this->triggers []= $elem817;
++ $elem824 = null;
++ $elem824 = new \metastore\WMTrigger();
++ $xfer += $elem824->read($input);
++ $this->triggers []= $elem824;
}
$xfer += $input->readListEnd();
} else {
@@@ -29201,9 -28251,9 +29121,9 @@@
{
$output->writeListBegin(TType::STRUCT, count($this->triggers));
{
- foreach ($this->triggers as $iter833)
- foreach ($this->triggers as $iter818)
++ foreach ($this->triggers as $iter825)
{
- $xfer += $iter833->write($output);
- $xfer += $iter818->write($output);
++ $xfer += $iter825->write($output);
}
}
$output->writeListEnd();
@@@ -30787,15 -29837,15 +30707,15 @@@ class SchemaVersion
case 4:
if ($ftype == TType::LST) {
$this->cols = array();
- $_size834 = 0;
- $_etype837 = 0;
- $xfer += $input->readListBegin($_etype837, $_size834);
- for ($_i838 = 0; $_i838 < $_size834; ++$_i838)
- $_size819 = 0;
- $_etype822 = 0;
- $xfer += $input->readListBegin($_etype822, $_size819);
- for ($_i823 = 0; $_i823 < $_size819; ++$_i823)
++ $_size826 = 0;
++ $_etype829 = 0;
++ $xfer += $input->readListBegin($_etype829, $_size826);
++ for ($_i830 = 0; $_i830 < $_size826; ++$_i830)
{
- $elem839 = null;
- $elem839 = new \metastore\FieldSchema();
- $xfer += $elem839->read($input);
- $this->cols []= $elem839;
- $elem824 = null;
- $elem824 = new \metastore\FieldSchema();
- $xfer += $elem824->read($input);
- $this->cols []= $elem824;
++ $elem831 = null;
++ $elem831 = new \metastore\FieldSchema();
++ $xfer += $elem831->read($input);
++ $this->cols []= $elem831;
}
$xfer += $input->readListEnd();
} else {
@@@ -30884,9 -29934,9 +30804,9 @@@
{
$output->writeListBegin(TType::STRUCT, count($this->cols));
{
- foreach ($this->cols as $iter840)
- foreach ($this->cols as $iter825)
++ foreach ($this->cols as $iter832)
{
- $xfer += $iter840->write($output);
- $xfer += $iter825->write($output);
++ $xfer += $iter832->write($output);
}
}
$output->writeListEnd();
@@@ -31208,15 -30258,15 +31128,15 @@@ class FindSchemasByColsResp
case 1:
if ($ftype == TType::LST) {
$this->schemaVersions = array();
- $_size841 = 0;
- $_etype844 = 0;
- $xfer += $input->readListBegin($_etype844, $_size841);
- for ($_i845 = 0; $_i845 < $_size841; ++$_i845)
- $_size826 = 0;
- $_etype829 = 0;
- $xfer += $input->readListBegin($_etype829, $_size826);
- for ($_i830 = 0; $_i830 < $_size826; ++$_i830)
++ $_size833 = 0;
++ $_etype836 = 0;
++ $xfer += $input->readListBegin($_etype836, $_size833);
++ for ($_i837 = 0; $_i837 < $_size833; ++$_i837)
{
- $elem846 = null;
- $elem846 = new \metastore\SchemaVersionDescriptor();
- $xfer += $elem846->read($input);
- $this->schemaVersions []= $elem846;
- $elem831 = null;
- $elem831 = new \metastore\SchemaVersionDescriptor();
- $xfer += $elem831->read($input);
- $this->schemaVersions []= $elem831;
++ $elem838 = null;
++ $elem838 = new \metastore\SchemaVersionDescriptor();
++ $xfer += $elem838->read($input);
++ $this->schemaVersions []= $elem838;
}
$xfer += $input->readListEnd();
} else {
@@@ -31244,9 -30294,9 +31164,9 @@@
{
$output->writeListBegin(TType::STRUCT, count($this->schemaVersions));
{
- foreach ($this->schemaVersions as $iter847)
- foreach ($this->schemaVersions as $iter832)
++ foreach ($this->schemaVersions as $iter839)
{
- $xfer += $iter847->write($output);
- $xfer += $iter832->write($output);
++ $xfer += $iter839->write($output);
}
}
$output->writeListEnd();
@@@ -31760,621 -30810,6 +31680,621 @@@ class GetRuntimeStatsRequest
}
+class AlterPartitionsRequest {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $catName = null;
+ /**
+ * @var string
+ */
+ public $dbName = null;
+ /**
+ * @var string
+ */
+ public $tableName = null;
+ /**
+ * @var \metastore\Partition[]
+ */
+ public $partitions = null;
+ /**
+ * @var \metastore\EnvironmentContext
+ */
+ public $environmentContext = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var int
+ */
+ public $writeId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'catName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'tableName',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'partitions',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Partition',
+ ),
+ ),
+ 5 => array(
+ 'var' => 'environmentContext',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\EnvironmentContext',
+ ),
+ 6 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 7 => array(
+ 'var' => 'writeId',
+ 'type' => TType::I64,
+ ),
+ 8 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['catName'])) {
+ $this->catName = $vals['catName'];
+ }
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['tableName'])) {
+ $this->tableName = $vals['tableName'];
+ }
+ if (isset($vals['partitions'])) {
+ $this->partitions = $vals['partitions'];
+ }
+ if (isset($vals['environmentContext'])) {
+ $this->environmentContext = $vals['environmentContext'];
+ }
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['writeId'])) {
+ $this->writeId = $vals['writeId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'AlterPartitionsRequest';
+ }
+
+ 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->catName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->tableName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->partitions = array();
- $_size848 = 0;
- $_etype851 = 0;
- $xfer += $input->readListBegin($_etype851, $_size848);
- for ($_i852 = 0; $_i852 < $_size848; ++$_i852)
++ $_size840 = 0;
++ $_etype843 = 0;
++ $xfer += $input->readListBegin($_etype843, $_size840);
++ for ($_i844 = 0; $_i844 < $_size840; ++$_i844)
+ {
- $elem853 = null;
- $elem853 = new \metastore\Partition();
- $xfer += $elem853->read($input);
- $this->partitions []= $elem853;
++ $elem845 = null;
++ $elem845 = new \metastore\Partition();
++ $xfer += $elem845->read($input);
++ $this->partitions []= $elem845;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRUCT) {
+ $this->environmentContext = new \metastore\EnvironmentContext();
+ $xfer += $this->environmentContext->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->writeId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } 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('AlterPartitionsRequest');
+ if ($this->catName !== null) {
+ $xfer += $output->writeFieldBegin('catName', TType::STRING, 1);
+ $xfer += $output->writeString($this->catName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 2);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->tableName !== null) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 3);
+ $xfer += $output->writeString($this->tableName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->partitions !== null) {
+ if (!is_array($this->partitions)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('partitions', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->partitions));
+ {
- foreach ($this->partitions as $iter854)
++ foreach ($this->partitions as $iter846)
+ {
- $xfer += $iter854->write($output);
++ $xfer += $iter846->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->environmentContext !== null) {
+ if (!is_object($this->environmentContext)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('environmentContext', TType::STRUCT, 5);
+ $xfer += $this->environmentContext->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 6);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->writeId !== null) {
+ $xfer += $output->writeFieldBegin('writeId', TType::I64, 7);
+ $xfer += $output->writeI64($this->writeId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 8);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class AlterPartitionsResponse {
+ static $_TSPEC;
+
+
+ public function __construct() {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ );
+ }
+ }
+
+ public function getName() {
+ return 'AlterPartitionsResponse';
+ }
+
+ 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)
+ {
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('AlterPartitionsResponse');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class AlterTableRequest {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $catName = null;
+ /**
+ * @var string
+ */
+ public $dbName = null;
+ /**
+ * @var string
+ */
+ public $tableName = null;
+ /**
+ * @var \metastore\Table
+ */
+ public $table = null;
+ /**
+ * @var \metastore\EnvironmentContext
+ */
+ public $environmentContext = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var int
+ */
+ public $writeId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'catName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'tableName',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'table',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Table',
+ ),
+ 5 => array(
+ 'var' => 'environmentContext',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\EnvironmentContext',
+ ),
+ 6 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 7 => array(
+ 'var' => 'writeId',
+ 'type' => TType::I64,
+ ),
+ 8 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['catName'])) {
+ $this->catName = $vals['catName'];
+ }
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['tableName'])) {
+ $this->tableName = $vals['tableName'];
+ }
+ if (isset($vals['table'])) {
+ $this->table = $vals['table'];
+ }
+ if (isset($vals['environmentContext'])) {
+ $this->environmentContext = $vals['environmentContext'];
+ }
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['writeId'])) {
+ $this->writeId = $vals['writeId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'AlterTableRequest';
+ }
+
+ 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->catName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->tableName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->table = new \metastore\Table();
+ $xfer += $this->table->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::STRUCT) {
+ $this->environmentContext = new \metastore\EnvironmentContext();
+ $xfer += $this->environmentContext->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->writeId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } 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('AlterTableRequest');
+ if ($this->catName !== null) {
+ $xfer += $output->writeFieldBegin('catName', TType::STRING, 1);
+ $xfer += $output->writeString($this->catName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 2);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->tableName !== null) {
+ $xfer += $output->writeFieldBegin('tableName', TType::STRING, 3);
+ $xfer += $output->writeString($this->tableName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->table !== null) {
+ if (!is_object($this->table)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('table', TType::STRUCT, 4);
+ $xfer += $this->table->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->environmentContext !== null) {
+ if (!is_object($this->environmentContext)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('environmentContext', TType::STRUCT, 5);
+ $xfer += $this->environmentContext->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 6);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->writeId !== null) {
+ $xfer += $output->writeFieldBegin('writeId', TType::I64, 7);
+ $xfer += $output->writeI64($this->writeId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 8);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class AlterTableResponse {
+ static $_TSPEC;
+
+
+ public function __construct() {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ );
+ }
+ }
+
+ public function getName() {
+ return 'AlterTableResponse';
+ }
+
+ 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)
+ {
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('AlterTableResponse');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class MetaException extends TException {
static $_TSPEC;
http://git-wip-us.apache.org/repos/asf/hive/blob/37a1907b/standalone-metastore/metastore-common/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
----------------------------------------------------------------------