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/14 01:53:32 UTC
[10/20] hive git commit: HIVE-19820 : add ACID stats support to
background stats updater and fix bunch of edge cases found in SU tests
(Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/1c9947f3/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php b/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
index 187aceb..7e13e19 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
@@ -270,6 +270,12 @@ interface ThriftHiveMetastoreIf extends \FacebookServiceIf {
*/
public function truncate_table($dbName, $tableName, array $partNames);
/**
+ * @param \metastore\TruncateTableRequest $req
+ * @return \metastore\TruncateTableResponse
+ * @throws \metastore\MetaException
+ */
+ public function truncate_table_req(\metastore\TruncateTableRequest $req);
+ /**
* @param string $db_name
* @param string $pattern
* @return string[]
@@ -389,6 +395,13 @@ interface ThriftHiveMetastoreIf extends \FacebookServiceIf {
*/
public function alter_table_with_cascade($dbname, $tbl_name, \metastore\Table $new_tbl, $cascade);
/**
+ * @param \metastore\AlterTableRequest $req
+ * @return \metastore\AlterTableResponse
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
+ public function alter_table_req(\metastore\AlterTableRequest $req);
+ /**
* @param \metastore\Partition $new_part
* @return \metastore\Partition
* @throws \metastore\InvalidObjectException
@@ -728,7 +741,7 @@ interface ThriftHiveMetastoreIf extends \FacebookServiceIf {
* @throws \metastore\InvalidOperationException
* @throws \metastore\MetaException
*/
- public function alter_partitions_with_environment_context_req(\metastore\AlterPartitionsRequest $req);
+ public function alter_partitions_req(\metastore\AlterPartitionsRequest $req);
/**
* @param string $db_name
* @param string $tbl_name
@@ -861,6 +874,24 @@ interface ThriftHiveMetastoreIf extends \FacebookServiceIf {
*/
public function update_partition_column_statistics(\metastore\ColumnStatistics $stats_obj);
/**
+ * @param \metastore\SetPartitionsStatsRequest $req
+ * @return \metastore\SetPartitionsStatsResponse
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidInputException
+ */
+ public function update_table_column_statistics_req(\metastore\SetPartitionsStatsRequest $req);
+ /**
+ * @param \metastore\SetPartitionsStatsRequest $req
+ * @return \metastore\SetPartitionsStatsResponse
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidInputException
+ */
+ public function update_partition_column_statistics_req(\metastore\SetPartitionsStatsRequest $req);
+ /**
* @param string $db_name
* @param string $tbl_name
* @param string $col_name
@@ -3504,6 +3535,60 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas
return;
}
+ public function truncate_table_req(\metastore\TruncateTableRequest $req)
+ {
+ $this->send_truncate_table_req($req);
+ return $this->recv_truncate_table_req();
+ }
+
+ public function send_truncate_table_req(\metastore\TruncateTableRequest $req)
+ {
+ $args = new \metastore\ThriftHiveMetastore_truncate_table_req_args();
+ $args->req = $req;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'truncate_table_req', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('truncate_table_req', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_truncate_table_req()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_truncate_table_req_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_truncate_table_req_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ throw new \Exception("truncate_table_req failed: unknown result");
+ }
+
public function get_tables($db_name, $pattern)
{
$this->send_get_tables($db_name, $pattern);
@@ -4359,6 +4444,63 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas
return;
}
+ public function alter_table_req(\metastore\AlterTableRequest $req)
+ {
+ $this->send_alter_table_req($req);
+ return $this->recv_alter_table_req();
+ }
+
+ public function send_alter_table_req(\metastore\AlterTableRequest $req)
+ {
+ $args = new \metastore\ThriftHiveMetastore_alter_table_req_args();
+ $args->req = $req;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'alter_table_req', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('alter_table_req', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_alter_table_req()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_alter_table_req_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_alter_table_req_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ if ($result->o2 !== null) {
+ throw $result->o2;
+ }
+ throw new \Exception("alter_table_req failed: unknown result");
+ }
+
public function add_partition(\metastore\Partition $new_part)
{
$this->send_add_partition($new_part);
@@ -6463,34 +6605,34 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas
return;
}
- public function alter_partitions_with_environment_context_req(\metastore\AlterPartitionsRequest $req)
+ public function alter_partitions_req(\metastore\AlterPartitionsRequest $req)
{
- $this->send_alter_partitions_with_environment_context_req($req);
- return $this->recv_alter_partitions_with_environment_context_req();
+ $this->send_alter_partitions_req($req);
+ return $this->recv_alter_partitions_req();
}
- public function send_alter_partitions_with_environment_context_req(\metastore\AlterPartitionsRequest $req)
+ public function send_alter_partitions_req(\metastore\AlterPartitionsRequest $req)
{
- $args = new \metastore\ThriftHiveMetastore_alter_partitions_with_environment_context_req_args();
+ $args = new \metastore\ThriftHiveMetastore_alter_partitions_req_args();
$args->req = $req;
$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
if ($bin_accel)
{
- thrift_protocol_write_binary($this->output_, 'alter_partitions_with_environment_context_req', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ thrift_protocol_write_binary($this->output_, 'alter_partitions_req', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
}
else
{
- $this->output_->writeMessageBegin('alter_partitions_with_environment_context_req', TMessageType::CALL, $this->seqid_);
+ $this->output_->writeMessageBegin('alter_partitions_req', TMessageType::CALL, $this->seqid_);
$args->write($this->output_);
$this->output_->writeMessageEnd();
$this->output_->getTransport()->flush();
}
}
- public function recv_alter_partitions_with_environment_context_req()
+ public function recv_alter_partitions_req()
{
$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
- if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_alter_partitions_with_environment_context_req_result', $this->input_->isStrictRead());
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_alter_partitions_req_result', $this->input_->isStrictRead());
else
{
$rseqid = 0;
@@ -6504,7 +6646,7 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas
$this->input_->readMessageEnd();
throw $x;
}
- $result = new \metastore\ThriftHiveMetastore_alter_partitions_with_environment_context_req_result();
+ $result = new \metastore\ThriftHiveMetastore_alter_partitions_req_result();
$result->read($this->input_);
$this->input_->readMessageEnd();
}
@@ -6517,7 +6659,7 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas
if ($result->o2 !== null) {
throw $result->o2;
}
- throw new \Exception("alter_partitions_with_environment_context_req failed: unknown result");
+ throw new \Exception("alter_partitions_req failed: unknown result");
}
public function alter_partition_with_environment_context($db_name, $tbl_name, \metastore\Partition $new_part, \metastore\EnvironmentContext $environment_context)
@@ -7461,6 +7603,132 @@ class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metas
throw new \Exception("update_partition_column_statistics failed: unknown result");
}
+ public function update_table_column_statistics_req(\metastore\SetPartitionsStatsRequest $req)
+ {
+ $this->send_update_table_column_statistics_req($req);
+ return $this->recv_update_table_column_statistics_req();
+ }
+
+ public function send_update_table_column_statistics_req(\metastore\SetPartitionsStatsRequest $req)
+ {
+ $args = new \metastore\ThriftHiveMetastore_update_table_column_statistics_req_args();
+ $args->req = $req;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'update_table_column_statistics_req', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('update_table_column_statistics_req', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_update_table_column_statistics_req()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_update_table_column_statistics_req_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_update_table_column_statistics_req_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ if ($result->o2 !== null) {
+ throw $result->o2;
+ }
+ if ($result->o3 !== null) {
+ throw $result->o3;
+ }
+ if ($result->o4 !== null) {
+ throw $result->o4;
+ }
+ throw new \Exception("update_table_column_statistics_req failed: unknown result");
+ }
+
+ public function update_partition_column_statistics_req(\metastore\SetPartitionsStatsRequest $req)
+ {
+ $this->send_update_partition_column_statistics_req($req);
+ return $this->recv_update_partition_column_statistics_req();
+ }
+
+ public function send_update_partition_column_statistics_req(\metastore\SetPartitionsStatsRequest $req)
+ {
+ $args = new \metastore\ThriftHiveMetastore_update_partition_column_statistics_req_args();
+ $args->req = $req;
+ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'update_partition_column_statistics_req', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('update_partition_column_statistics_req', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_update_partition_column_statistics_req()
+ {
+ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_update_partition_column_statistics_req_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_update_partition_column_statistics_req_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ if ($result->o2 !== null) {
+ throw $result->o2;
+ }
+ if ($result->o3 !== null) {
+ throw $result->o3;
+ }
+ if ($result->o4 !== null) {
+ throw $result->o4;
+ }
+ throw new \Exception("update_partition_column_statistics_req failed: unknown result");
+ }
+
public function get_table_column_statistics($db_name, $tbl_name, $col_name)
{
$this->send_get_table_column_statistics($db_name, $tbl_name, $col_name);
@@ -15560,14 +15828,14 @@ class ThriftHiveMetastore_get_databases_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size848 = 0;
- $_etype851 = 0;
- $xfer += $input->readListBegin($_etype851, $_size848);
- for ($_i852 = 0; $_i852 < $_size848; ++$_i852)
+ $_size855 = 0;
+ $_etype858 = 0;
+ $xfer += $input->readListBegin($_etype858, $_size855);
+ for ($_i859 = 0; $_i859 < $_size855; ++$_i859)
{
- $elem853 = null;
- $xfer += $input->readString($elem853);
- $this->success []= $elem853;
+ $elem860 = null;
+ $xfer += $input->readString($elem860);
+ $this->success []= $elem860;
}
$xfer += $input->readListEnd();
} else {
@@ -15603,9 +15871,9 @@ class ThriftHiveMetastore_get_databases_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter854)
+ foreach ($this->success as $iter861)
{
- $xfer += $output->writeString($iter854);
+ $xfer += $output->writeString($iter861);
}
}
$output->writeListEnd();
@@ -15736,14 +16004,14 @@ class ThriftHiveMetastore_get_all_databases_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size855 = 0;
- $_etype858 = 0;
- $xfer += $input->readListBegin($_etype858, $_size855);
- for ($_i859 = 0; $_i859 < $_size855; ++$_i859)
+ $_size862 = 0;
+ $_etype865 = 0;
+ $xfer += $input->readListBegin($_etype865, $_size862);
+ for ($_i866 = 0; $_i866 < $_size862; ++$_i866)
{
- $elem860 = null;
- $xfer += $input->readString($elem860);
- $this->success []= $elem860;
+ $elem867 = null;
+ $xfer += $input->readString($elem867);
+ $this->success []= $elem867;
}
$xfer += $input->readListEnd();
} else {
@@ -15779,9 +16047,9 @@ class ThriftHiveMetastore_get_all_databases_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter861)
+ foreach ($this->success as $iter868)
{
- $xfer += $output->writeString($iter861);
+ $xfer += $output->writeString($iter868);
}
}
$output->writeListEnd();
@@ -16782,18 +17050,18 @@ class ThriftHiveMetastore_get_type_all_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size862 = 0;
- $_ktype863 = 0;
- $_vtype864 = 0;
- $xfer += $input->readMapBegin($_ktype863, $_vtype864, $_size862);
- for ($_i866 = 0; $_i866 < $_size862; ++$_i866)
+ $_size869 = 0;
+ $_ktype870 = 0;
+ $_vtype871 = 0;
+ $xfer += $input->readMapBegin($_ktype870, $_vtype871, $_size869);
+ for ($_i873 = 0; $_i873 < $_size869; ++$_i873)
{
- $key867 = '';
- $val868 = new \metastore\Type();
- $xfer += $input->readString($key867);
- $val868 = new \metastore\Type();
- $xfer += $val868->read($input);
- $this->success[$key867] = $val868;
+ $key874 = '';
+ $val875 = new \metastore\Type();
+ $xfer += $input->readString($key874);
+ $val875 = new \metastore\Type();
+ $xfer += $val875->read($input);
+ $this->success[$key874] = $val875;
}
$xfer += $input->readMapEnd();
} else {
@@ -16829,10 +17097,10 @@ class ThriftHiveMetastore_get_type_all_result {
{
$output->writeMapBegin(TType::STRING, TType::STRUCT, count($this->success));
{
- foreach ($this->success as $kiter869 => $viter870)
+ foreach ($this->success as $kiter876 => $viter877)
{
- $xfer += $output->writeString($kiter869);
- $xfer += $viter870->write($output);
+ $xfer += $output->writeString($kiter876);
+ $xfer += $viter877->write($output);
}
}
$output->writeMapEnd();
@@ -17036,15 +17304,15 @@ class ThriftHiveMetastore_get_fields_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size871 = 0;
- $_etype874 = 0;
- $xfer += $input->readListBegin($_etype874, $_size871);
- for ($_i875 = 0; $_i875 < $_size871; ++$_i875)
+ $_size878 = 0;
+ $_etype881 = 0;
+ $xfer += $input->readListBegin($_etype881, $_size878);
+ for ($_i882 = 0; $_i882 < $_size878; ++$_i882)
{
- $elem876 = null;
- $elem876 = new \metastore\FieldSchema();
- $xfer += $elem876->read($input);
- $this->success []= $elem876;
+ $elem883 = null;
+ $elem883 = new \metastore\FieldSchema();
+ $xfer += $elem883->read($input);
+ $this->success []= $elem883;
}
$xfer += $input->readListEnd();
} else {
@@ -17096,9 +17364,9 @@ class ThriftHiveMetastore_get_fields_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter877)
+ foreach ($this->success as $iter884)
{
- $xfer += $iter877->write($output);
+ $xfer += $iter884->write($output);
}
}
$output->writeListEnd();
@@ -17340,15 +17608,15 @@ class ThriftHiveMetastore_get_fields_with_environment_context_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size878 = 0;
- $_etype881 = 0;
- $xfer += $input->readListBegin($_etype881, $_size878);
- for ($_i882 = 0; $_i882 < $_size878; ++$_i882)
+ $_size885 = 0;
+ $_etype888 = 0;
+ $xfer += $input->readListBegin($_etype888, $_size885);
+ for ($_i889 = 0; $_i889 < $_size885; ++$_i889)
{
- $elem883 = null;
- $elem883 = new \metastore\FieldSchema();
- $xfer += $elem883->read($input);
- $this->success []= $elem883;
+ $elem890 = null;
+ $elem890 = new \metastore\FieldSchema();
+ $xfer += $elem890->read($input);
+ $this->success []= $elem890;
}
$xfer += $input->readListEnd();
} else {
@@ -17400,9 +17668,9 @@ class ThriftHiveMetastore_get_fields_with_environment_context_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter884)
+ foreach ($this->success as $iter891)
{
- $xfer += $iter884->write($output);
+ $xfer += $iter891->write($output);
}
}
$output->writeListEnd();
@@ -17616,15 +17884,15 @@ class ThriftHiveMetastore_get_schema_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size885 = 0;
- $_etype888 = 0;
- $xfer += $input->readListBegin($_etype888, $_size885);
- for ($_i889 = 0; $_i889 < $_size885; ++$_i889)
+ $_size892 = 0;
+ $_etype895 = 0;
+ $xfer += $input->readListBegin($_etype895, $_size892);
+ for ($_i896 = 0; $_i896 < $_size892; ++$_i896)
{
- $elem890 = null;
- $elem890 = new \metastore\FieldSchema();
- $xfer += $elem890->read($input);
- $this->success []= $elem890;
+ $elem897 = null;
+ $elem897 = new \metastore\FieldSchema();
+ $xfer += $elem897->read($input);
+ $this->success []= $elem897;
}
$xfer += $input->readListEnd();
} else {
@@ -17676,9 +17944,9 @@ class ThriftHiveMetastore_get_schema_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter891)
+ foreach ($this->success as $iter898)
{
- $xfer += $iter891->write($output);
+ $xfer += $iter898->write($output);
}
}
$output->writeListEnd();
@@ -17920,15 +18188,15 @@ class ThriftHiveMetastore_get_schema_with_environment_context_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size892 = 0;
- $_etype895 = 0;
- $xfer += $input->readListBegin($_etype895, $_size892);
- for ($_i896 = 0; $_i896 < $_size892; ++$_i896)
+ $_size899 = 0;
+ $_etype902 = 0;
+ $xfer += $input->readListBegin($_etype902, $_size899);
+ for ($_i903 = 0; $_i903 < $_size899; ++$_i903)
{
- $elem897 = null;
- $elem897 = new \metastore\FieldSchema();
- $xfer += $elem897->read($input);
- $this->success []= $elem897;
+ $elem904 = null;
+ $elem904 = new \metastore\FieldSchema();
+ $xfer += $elem904->read($input);
+ $this->success []= $elem904;
}
$xfer += $input->readListEnd();
} else {
@@ -17980,9 +18248,9 @@ class ThriftHiveMetastore_get_schema_with_environment_context_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter898)
+ foreach ($this->success as $iter905)
{
- $xfer += $iter898->write($output);
+ $xfer += $iter905->write($output);
}
}
$output->writeListEnd();
@@ -18654,15 +18922,15 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
case 2:
if ($ftype == TType::LST) {
$this->primaryKeys = array();
- $_size899 = 0;
- $_etype902 = 0;
- $xfer += $input->readListBegin($_etype902, $_size899);
- for ($_i903 = 0; $_i903 < $_size899; ++$_i903)
+ $_size906 = 0;
+ $_etype909 = 0;
+ $xfer += $input->readListBegin($_etype909, $_size906);
+ for ($_i910 = 0; $_i910 < $_size906; ++$_i910)
{
- $elem904 = null;
- $elem904 = new \metastore\SQLPrimaryKey();
- $xfer += $elem904->read($input);
- $this->primaryKeys []= $elem904;
+ $elem911 = null;
+ $elem911 = new \metastore\SQLPrimaryKey();
+ $xfer += $elem911->read($input);
+ $this->primaryKeys []= $elem911;
}
$xfer += $input->readListEnd();
} else {
@@ -18672,15 +18940,15 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
case 3:
if ($ftype == TType::LST) {
$this->foreignKeys = array();
- $_size905 = 0;
- $_etype908 = 0;
- $xfer += $input->readListBegin($_etype908, $_size905);
- for ($_i909 = 0; $_i909 < $_size905; ++$_i909)
+ $_size912 = 0;
+ $_etype915 = 0;
+ $xfer += $input->readListBegin($_etype915, $_size912);
+ for ($_i916 = 0; $_i916 < $_size912; ++$_i916)
{
- $elem910 = null;
- $elem910 = new \metastore\SQLForeignKey();
- $xfer += $elem910->read($input);
- $this->foreignKeys []= $elem910;
+ $elem917 = null;
+ $elem917 = new \metastore\SQLForeignKey();
+ $xfer += $elem917->read($input);
+ $this->foreignKeys []= $elem917;
}
$xfer += $input->readListEnd();
} else {
@@ -18690,15 +18958,15 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
case 4:
if ($ftype == TType::LST) {
$this->uniqueConstraints = array();
- $_size911 = 0;
- $_etype914 = 0;
- $xfer += $input->readListBegin($_etype914, $_size911);
- for ($_i915 = 0; $_i915 < $_size911; ++$_i915)
+ $_size918 = 0;
+ $_etype921 = 0;
+ $xfer += $input->readListBegin($_etype921, $_size918);
+ for ($_i922 = 0; $_i922 < $_size918; ++$_i922)
{
- $elem916 = null;
- $elem916 = new \metastore\SQLUniqueConstraint();
- $xfer += $elem916->read($input);
- $this->uniqueConstraints []= $elem916;
+ $elem923 = null;
+ $elem923 = new \metastore\SQLUniqueConstraint();
+ $xfer += $elem923->read($input);
+ $this->uniqueConstraints []= $elem923;
}
$xfer += $input->readListEnd();
} else {
@@ -18708,15 +18976,15 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
case 5:
if ($ftype == TType::LST) {
$this->notNullConstraints = array();
- $_size917 = 0;
- $_etype920 = 0;
- $xfer += $input->readListBegin($_etype920, $_size917);
- for ($_i921 = 0; $_i921 < $_size917; ++$_i921)
+ $_size924 = 0;
+ $_etype927 = 0;
+ $xfer += $input->readListBegin($_etype927, $_size924);
+ for ($_i928 = 0; $_i928 < $_size924; ++$_i928)
{
- $elem922 = null;
- $elem922 = new \metastore\SQLNotNullConstraint();
- $xfer += $elem922->read($input);
- $this->notNullConstraints []= $elem922;
+ $elem929 = null;
+ $elem929 = new \metastore\SQLNotNullConstraint();
+ $xfer += $elem929->read($input);
+ $this->notNullConstraints []= $elem929;
}
$xfer += $input->readListEnd();
} else {
@@ -18726,15 +18994,15 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
case 6:
if ($ftype == TType::LST) {
$this->defaultConstraints = array();
- $_size923 = 0;
- $_etype926 = 0;
- $xfer += $input->readListBegin($_etype926, $_size923);
- for ($_i927 = 0; $_i927 < $_size923; ++$_i927)
+ $_size930 = 0;
+ $_etype933 = 0;
+ $xfer += $input->readListBegin($_etype933, $_size930);
+ for ($_i934 = 0; $_i934 < $_size930; ++$_i934)
{
- $elem928 = null;
- $elem928 = new \metastore\SQLDefaultConstraint();
- $xfer += $elem928->read($input);
- $this->defaultConstraints []= $elem928;
+ $elem935 = null;
+ $elem935 = new \metastore\SQLDefaultConstraint();
+ $xfer += $elem935->read($input);
+ $this->defaultConstraints []= $elem935;
}
$xfer += $input->readListEnd();
} else {
@@ -18744,15 +19012,15 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
case 7:
if ($ftype == TType::LST) {
$this->checkConstraints = array();
- $_size929 = 0;
- $_etype932 = 0;
- $xfer += $input->readListBegin($_etype932, $_size929);
- for ($_i933 = 0; $_i933 < $_size929; ++$_i933)
+ $_size936 = 0;
+ $_etype939 = 0;
+ $xfer += $input->readListBegin($_etype939, $_size936);
+ for ($_i940 = 0; $_i940 < $_size936; ++$_i940)
{
- $elem934 = null;
- $elem934 = new \metastore\SQLCheckConstraint();
- $xfer += $elem934->read($input);
- $this->checkConstraints []= $elem934;
+ $elem941 = null;
+ $elem941 = new \metastore\SQLCheckConstraint();
+ $xfer += $elem941->read($input);
+ $this->checkConstraints []= $elem941;
}
$xfer += $input->readListEnd();
} else {
@@ -18788,9 +19056,9 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
{
$output->writeListBegin(TType::STRUCT, count($this->primaryKeys));
{
- foreach ($this->primaryKeys as $iter935)
+ foreach ($this->primaryKeys as $iter942)
{
- $xfer += $iter935->write($output);
+ $xfer += $iter942->write($output);
}
}
$output->writeListEnd();
@@ -18805,9 +19073,9 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
{
$output->writeListBegin(TType::STRUCT, count($this->foreignKeys));
{
- foreach ($this->foreignKeys as $iter936)
+ foreach ($this->foreignKeys as $iter943)
{
- $xfer += $iter936->write($output);
+ $xfer += $iter943->write($output);
}
}
$output->writeListEnd();
@@ -18822,9 +19090,9 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
{
$output->writeListBegin(TType::STRUCT, count($this->uniqueConstraints));
{
- foreach ($this->uniqueConstraints as $iter937)
+ foreach ($this->uniqueConstraints as $iter944)
{
- $xfer += $iter937->write($output);
+ $xfer += $iter944->write($output);
}
}
$output->writeListEnd();
@@ -18839,9 +19107,9 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
{
$output->writeListBegin(TType::STRUCT, count($this->notNullConstraints));
{
- foreach ($this->notNullConstraints as $iter938)
+ foreach ($this->notNullConstraints as $iter945)
{
- $xfer += $iter938->write($output);
+ $xfer += $iter945->write($output);
}
}
$output->writeListEnd();
@@ -18856,9 +19124,9 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
{
$output->writeListBegin(TType::STRUCT, count($this->defaultConstraints));
{
- foreach ($this->defaultConstraints as $iter939)
+ foreach ($this->defaultConstraints as $iter946)
{
- $xfer += $iter939->write($output);
+ $xfer += $iter946->write($output);
}
}
$output->writeListEnd();
@@ -18873,9 +19141,9 @@ class ThriftHiveMetastore_create_table_with_constraints_args {
{
$output->writeListBegin(TType::STRUCT, count($this->checkConstraints));
{
- foreach ($this->checkConstraints as $iter940)
+ foreach ($this->checkConstraints as $iter947)
{
- $xfer += $iter940->write($output);
+ $xfer += $iter947->write($output);
}
}
$output->writeListEnd();
@@ -20875,14 +21143,14 @@ class ThriftHiveMetastore_truncate_table_args {
case 3:
if ($ftype == TType::LST) {
$this->partNames = array();
- $_size941 = 0;
- $_etype944 = 0;
- $xfer += $input->readListBegin($_etype944, $_size941);
- for ($_i945 = 0; $_i945 < $_size941; ++$_i945)
+ $_size948 = 0;
+ $_etype951 = 0;
+ $xfer += $input->readListBegin($_etype951, $_size948);
+ for ($_i952 = 0; $_i952 < $_size948; ++$_i952)
{
- $elem946 = null;
- $xfer += $input->readString($elem946);
- $this->partNames []= $elem946;
+ $elem953 = null;
+ $xfer += $input->readString($elem953);
+ $this->partNames []= $elem953;
}
$xfer += $input->readListEnd();
} else {
@@ -20920,9 +21188,9 @@ class ThriftHiveMetastore_truncate_table_args {
{
$output->writeListBegin(TType::STRING, count($this->partNames));
{
- foreach ($this->partNames as $iter947)
+ foreach ($this->partNames as $iter954)
{
- $xfer += $output->writeString($iter947);
+ $xfer += $output->writeString($iter954);
}
}
$output->writeListEnd();
@@ -21013,6 +21281,191 @@ class ThriftHiveMetastore_truncate_table_result {
}
+class ThriftHiveMetastore_truncate_table_req_args {
+ static $_TSPEC;
+
+ /**
+ * @var \metastore\TruncateTableRequest
+ */
+ public $req = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'req',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\TruncateTableRequest',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['req'])) {
+ $this->req = $vals['req'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_truncate_table_req_args';
+ }
+
+ 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::STRUCT) {
+ $this->req = new \metastore\TruncateTableRequest();
+ $xfer += $this->req->read($input);
+ } 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('ThriftHiveMetastore_truncate_table_req_args');
+ if ($this->req !== null) {
+ if (!is_object($this->req)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('req', TType::STRUCT, 1);
+ $xfer += $this->req->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_truncate_table_req_result {
+ static $_TSPEC;
+
+ /**
+ * @var \metastore\TruncateTableResponse
+ */
+ public $success = null;
+ /**
+ * @var \metastore\MetaException
+ */
+ public $o1 = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\TruncateTableResponse',
+ ),
+ 1 => array(
+ 'var' => 'o1',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\MetaException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['o1'])) {
+ $this->o1 = $vals['o1'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_truncate_table_req_result';
+ }
+
+ 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 0:
+ if ($ftype == TType::STRUCT) {
+ $this->success = new \metastore\TruncateTableResponse();
+ $xfer += $this->success->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->o1 = new \metastore\MetaException();
+ $xfer += $this->o1->read($input);
+ } 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('ThriftHiveMetastore_truncate_table_req_result');
+ if ($this->success !== null) {
+ if (!is_object($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $this->success->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o1 !== null) {
+ $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1);
+ $xfer += $this->o1->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class ThriftHiveMetastore_get_tables_args {
static $_TSPEC;
@@ -21173,14 +21626,14 @@ class ThriftHiveMetastore_get_tables_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size948 = 0;
- $_etype951 = 0;
- $xfer += $input->readListBegin($_etype951, $_size948);
- for ($_i952 = 0; $_i952 < $_size948; ++$_i952)
+ $_size955 = 0;
+ $_etype958 = 0;
+ $xfer += $input->readListBegin($_etype958, $_size955);
+ for ($_i959 = 0; $_i959 < $_size955; ++$_i959)
{
- $elem953 = null;
- $xfer += $input->readString($elem953);
- $this->success []= $elem953;
+ $elem960 = null;
+ $xfer += $input->readString($elem960);
+ $this->success []= $elem960;
}
$xfer += $input->readListEnd();
} else {
@@ -21216,9 +21669,9 @@ class ThriftHiveMetastore_get_tables_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter954)
+ foreach ($this->success as $iter961)
{
- $xfer += $output->writeString($iter954);
+ $xfer += $output->writeString($iter961);
}
}
$output->writeListEnd();
@@ -21420,14 +21873,14 @@ class ThriftHiveMetastore_get_tables_by_type_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size955 = 0;
- $_etype958 = 0;
- $xfer += $input->readListBegin($_etype958, $_size955);
- for ($_i959 = 0; $_i959 < $_size955; ++$_i959)
+ $_size962 = 0;
+ $_etype965 = 0;
+ $xfer += $input->readListBegin($_etype965, $_size962);
+ for ($_i966 = 0; $_i966 < $_size962; ++$_i966)
{
- $elem960 = null;
- $xfer += $input->readString($elem960);
- $this->success []= $elem960;
+ $elem967 = null;
+ $xfer += $input->readString($elem967);
+ $this->success []= $elem967;
}
$xfer += $input->readListEnd();
} else {
@@ -21463,9 +21916,9 @@ class ThriftHiveMetastore_get_tables_by_type_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter961)
+ foreach ($this->success as $iter968)
{
- $xfer += $output->writeString($iter961);
+ $xfer += $output->writeString($iter968);
}
}
$output->writeListEnd();
@@ -21621,14 +22074,14 @@ class ThriftHiveMetastore_get_materialized_views_for_rewriting_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size962 = 0;
- $_etype965 = 0;
- $xfer += $input->readListBegin($_etype965, $_size962);
- for ($_i966 = 0; $_i966 < $_size962; ++$_i966)
+ $_size969 = 0;
+ $_etype972 = 0;
+ $xfer += $input->readListBegin($_etype972, $_size969);
+ for ($_i973 = 0; $_i973 < $_size969; ++$_i973)
{
- $elem967 = null;
- $xfer += $input->readString($elem967);
- $this->success []= $elem967;
+ $elem974 = null;
+ $xfer += $input->readString($elem974);
+ $this->success []= $elem974;
}
$xfer += $input->readListEnd();
} else {
@@ -21664,9 +22117,9 @@ class ThriftHiveMetastore_get_materialized_views_for_rewriting_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter968)
+ foreach ($this->success as $iter975)
{
- $xfer += $output->writeString($iter968);
+ $xfer += $output->writeString($iter975);
}
}
$output->writeListEnd();
@@ -21771,14 +22224,14 @@ class ThriftHiveMetastore_get_table_meta_args {
case 3:
if ($ftype == TType::LST) {
$this->tbl_types = array();
- $_size969 = 0;
- $_etype972 = 0;
- $xfer += $input->readListBegin($_etype972, $_size969);
- for ($_i973 = 0; $_i973 < $_size969; ++$_i973)
+ $_size976 = 0;
+ $_etype979 = 0;
+ $xfer += $input->readListBegin($_etype979, $_size976);
+ for ($_i980 = 0; $_i980 < $_size976; ++$_i980)
{
- $elem974 = null;
- $xfer += $input->readString($elem974);
- $this->tbl_types []= $elem974;
+ $elem981 = null;
+ $xfer += $input->readString($elem981);
+ $this->tbl_types []= $elem981;
}
$xfer += $input->readListEnd();
} else {
@@ -21816,9 +22269,9 @@ class ThriftHiveMetastore_get_table_meta_args {
{
$output->writeListBegin(TType::STRING, count($this->tbl_types));
{
- foreach ($this->tbl_types as $iter975)
+ foreach ($this->tbl_types as $iter982)
{
- $xfer += $output->writeString($iter975);
+ $xfer += $output->writeString($iter982);
}
}
$output->writeListEnd();
@@ -21895,15 +22348,15 @@ class ThriftHiveMetastore_get_table_meta_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size976 = 0;
- $_etype979 = 0;
- $xfer += $input->readListBegin($_etype979, $_size976);
- for ($_i980 = 0; $_i980 < $_size976; ++$_i980)
+ $_size983 = 0;
+ $_etype986 = 0;
+ $xfer += $input->readListBegin($_etype986, $_size983);
+ for ($_i987 = 0; $_i987 < $_size983; ++$_i987)
{
- $elem981 = null;
- $elem981 = new \metastore\TableMeta();
- $xfer += $elem981->read($input);
- $this->success []= $elem981;
+ $elem988 = null;
+ $elem988 = new \metastore\TableMeta();
+ $xfer += $elem988->read($input);
+ $this->success []= $elem988;
}
$xfer += $input->readListEnd();
} else {
@@ -21939,9 +22392,9 @@ class ThriftHiveMetastore_get_table_meta_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter982)
+ foreach ($this->success as $iter989)
{
- $xfer += $iter982->write($output);
+ $xfer += $iter989->write($output);
}
}
$output->writeListEnd();
@@ -22097,14 +22550,14 @@ class ThriftHiveMetastore_get_all_tables_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size983 = 0;
- $_etype986 = 0;
- $xfer += $input->readListBegin($_etype986, $_size983);
- for ($_i987 = 0; $_i987 < $_size983; ++$_i987)
+ $_size990 = 0;
+ $_etype993 = 0;
+ $xfer += $input->readListBegin($_etype993, $_size990);
+ for ($_i994 = 0; $_i994 < $_size990; ++$_i994)
{
- $elem988 = null;
- $xfer += $input->readString($elem988);
- $this->success []= $elem988;
+ $elem995 = null;
+ $xfer += $input->readString($elem995);
+ $this->success []= $elem995;
}
$xfer += $input->readListEnd();
} else {
@@ -22140,9 +22593,9 @@ class ThriftHiveMetastore_get_all_tables_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter989)
+ foreach ($this->success as $iter996)
{
- $xfer += $output->writeString($iter989);
+ $xfer += $output->writeString($iter996);
}
}
$output->writeListEnd();
@@ -22457,14 +22910,14 @@ class ThriftHiveMetastore_get_table_objects_by_name_args {
case 2:
if ($ftype == TType::LST) {
$this->tbl_names = array();
- $_size990 = 0;
- $_etype993 = 0;
- $xfer += $input->readListBegin($_etype993, $_size990);
- for ($_i994 = 0; $_i994 < $_size990; ++$_i994)
+ $_size997 = 0;
+ $_etype1000 = 0;
+ $xfer += $input->readListBegin($_etype1000, $_size997);
+ for ($_i1001 = 0; $_i1001 < $_size997; ++$_i1001)
{
- $elem995 = null;
- $xfer += $input->readString($elem995);
- $this->tbl_names []= $elem995;
+ $elem1002 = null;
+ $xfer += $input->readString($elem1002);
+ $this->tbl_names []= $elem1002;
}
$xfer += $input->readListEnd();
} else {
@@ -22497,9 +22950,9 @@ class ThriftHiveMetastore_get_table_objects_by_name_args {
{
$output->writeListBegin(TType::STRING, count($this->tbl_names));
{
- foreach ($this->tbl_names as $iter996)
+ foreach ($this->tbl_names as $iter1003)
{
- $xfer += $output->writeString($iter996);
+ $xfer += $output->writeString($iter1003);
}
}
$output->writeListEnd();
@@ -22564,15 +23017,15 @@ class ThriftHiveMetastore_get_table_objects_by_name_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size997 = 0;
- $_etype1000 = 0;
- $xfer += $input->readListBegin($_etype1000, $_size997);
- for ($_i1001 = 0; $_i1001 < $_size997; ++$_i1001)
+ $_size1004 = 0;
+ $_etype1007 = 0;
+ $xfer += $input->readListBegin($_etype1007, $_size1004);
+ for ($_i1008 = 0; $_i1008 < $_size1004; ++$_i1008)
{
- $elem1002 = null;
- $elem1002 = new \metastore\Table();
- $xfer += $elem1002->read($input);
- $this->success []= $elem1002;
+ $elem1009 = null;
+ $elem1009 = new \metastore\Table();
+ $xfer += $elem1009->read($input);
+ $this->success []= $elem1009;
}
$xfer += $input->readListEnd();
} else {
@@ -22600,9 +23053,9 @@ class ThriftHiveMetastore_get_table_objects_by_name_result {
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter1003)
+ foreach ($this->success as $iter1010)
{
- $xfer += $iter1003->write($output);
+ $xfer += $iter1010->write($output);
}
}
$output->writeListEnd();
@@ -23129,14 +23582,14 @@ class ThriftHiveMetastore_get_materialization_invalidation_info_args {
case 2:
if ($ftype == TType::LST) {
$this->tbl_names = array();
- $_size1004 = 0;
- $_etype1007 = 0;
- $xfer += $input->readListBegin($_etype1007, $_size1004);
- for ($_i1008 = 0; $_i1008 < $_size1004; ++$_i1008)
+ $_size1011 = 0;
+ $_etype1014 = 0;
+ $xfer += $input->readListBegin($_etype1014, $_size1011);
+ for ($_i1015 = 0; $_i1015 < $_size1011; ++$_i1015)
{
- $elem1009 = null;
- $xfer += $input->readString($elem1009);
- $this->tbl_names []= $elem1009;
+ $elem1016 = null;
+ $xfer += $input->readString($elem1016);
+ $this->tbl_names []= $elem1016;
}
$xfer += $input->readListEnd();
} else {
@@ -23169,9 +23622,9 @@ class ThriftHiveMetastore_get_materialization_invalidation_info_args {
{
$output->writeListBegin(TType::STRING, count($this->tbl_names));
{
- foreach ($this->tbl_names as $iter1010)
+ foreach ($this->tbl_names as $iter1017)
{
- $xfer += $output->writeString($iter1010);
+ $xfer += $output->writeString($iter1017);
}
}
$output->writeListEnd();
@@ -23276,18 +23729,18 @@ class ThriftHiveMetastore_get_materialization_invalidation_info_result {
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size1011 = 0;
- $_ktype1012 = 0;
- $_vtype1013 = 0;
- $xfer += $input->readMapBegin($_ktype1012, $_vtype1013, $_size1011);
- for ($_i1015 = 0; $_i1015 < $_size1011; ++$_i1015)
+ $_size1018 = 0;
+ $_ktype1019 = 0;
+ $_vtype1020 = 0;
+ $xfer += $input->readMapBegin($_ktype1019, $_vtype1020, $_size1018);
+ for ($_i1022 = 0; $_i1022 < $_size1018; ++$_i1022)
{
- $key1016 = '';
- $val1017 = new \metastore\Materialization();
- $xfer += $input->readString($key1016);
- $val1017 = new \metastore\Materialization();
- $xfer += $val1017->read($input);
- $this->success[$key1016] = $val1017;
+ $key1023 = '';
+ $val1024 = new \metastore\Materialization();
+ $xfer += $input->readString($key1023);
+ $val1024 = new \metastore\Materialization();
+ $xfer += $val1024->read($input);
+ $this->success[$key1023] = $val1024;
}
$xfer += $input->readMapEnd();
} else {
@@ -23339,10 +23792,10 @@ class ThriftHiveMetastore_get_materialization_invalidation_info_result {
{
$output->writeMapBegin(TType::STRING, TType::STRUCT, count($this->success));
{
- foreach ($this->success as $kiter1018 => $viter1019)
+ foreach ($this->success as $kiter1025 => $viter1026)
{
- $xfer += $output->writeString($kiter1018);
- $xfer += $viter1019->write($output);
+ $xfer += $output->writeString($kiter1025);
+ $xfer += $viter1026->write($output);
}
}
$output->writeMapEnd();
@@ -23854,14 +24307,14 @@ class ThriftHiveMetastore_get_table_names_by_filter_result {
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size1020 = 0;
- $_etype1023 = 0;
- $xfer += $input->readListBegin($_etype1023, $_size1020);
- for ($_i1024 = 0; $_i1024 < $_size1020; ++$_i1024)
+ $_size1027 = 0;
+ $_etype1030 = 0;
+ $xfer += $input->readListBegin($_etype1030, $_size1027);
+ for ($_i1031 = 0; $_i1031 < $_size1027; ++$_i1031)
{
- $elem1025 = null;
- $xfer += $input->readString($elem1025);
- $this->success []= $elem1025;
+ $elem1032 = null;
+ $xfer += $input->readString($elem1032);
+ $this->success []= $elem1032;
}
$xfer += $input->readListEnd();
} else {
@@ -23913,9 +24366,9 @@ class ThriftHiveMetastore_get_table_names_by_filter_result {
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter1026)
+ foreach ($this->success as $iter1033)
{
- $xfer += $output->writeString($iter1026);
+ $xfer += $output->writeString($iter1033);
}
}
$output->writeListEnd();
@@ -24679,33 +25132,33 @@ class ThriftHiveMetastore_alter_table_with_cascade_result {
}
-class ThriftHiveMetastore_add_partition_args {
+class ThriftHiveMetastore_alter_table_req_args {
static $_TSPEC;
/**
- * @var \metastore\Partition
+ * @var \metastore\AlterTableRequest
*/
- public $new_part = null;
+ public $req = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
self::$_TSPEC = array(
1 => array(
- 'var' => 'new_part',
+ 'var' => 'req',
'type' => TType::STRUCT,
- 'class' => '\metastore\Partition',
+ 'class' => '\metastore\AlterTableRequest',
),
);
}
if (is_array($vals)) {
- if (isset($vals['new_part'])) {
- $this->new_part = $vals['new_part'];
+ if (isset($vals['req'])) {
+ $this->req = $vals['req'];
}
}
}
public function getName() {
- return 'ThriftHiveMetastore_add_partition_args';
+ return 'ThriftHiveMetastore_alter_table_req_args';
}
public function read($input)
@@ -24725,8 +25178,8 @@ class ThriftHiveMetastore_add_partition_args {
{
case 1:
if ($ftype == TType::STRUCT) {
- $this->new_part = new \metastore\Partition();
- $xfer += $this->new_part->read($input);
+ $this->req = new \metastore\AlterTableRequest();
+ $xfer += $this->req->read($input);
} else {
$xfer += $input->skip($ftype);
}
@@ -24743,13 +25196,13 @@ class ThriftHiveMetastore_add_partition_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('ThriftHiveMetastore_add_partition_args');
- if ($this->new_part !== null) {
- if (!is_object($this->new_part)) {
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_alter_table_req_args');
+ if ($this->req !== null) {
+ if (!is_object($this->req)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
}
- $xfer += $output->writeFieldBegin('new_part', TType::STRUCT, 1);
- $xfer += $this->new_part->write($output);
+ $xfer += $output->writeFieldBegin('req', TType::STRUCT, 1);
+ $xfer += $this->req->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
@@ -24759,25 +25212,21 @@ class ThriftHiveMetastore_add_partition_args {
}
-class ThriftHiveMetastore_add_partition_result {
+class ThriftHiveMetastore_alter_table_req_result {
static $_TSPEC;
/**
- * @var \metastore\Partition
+ * @var \metastore\AlterTableResponse
*/
public $success = null;
/**
- * @var \metastore\InvalidObjectException
+ * @var \metastore\InvalidOperationException
*/
public $o1 = null;
/**
- * @var \metastore\AlreadyExistsException
- */
- public $o2 = null;
- /**
* @var \metastore\MetaException
*/
- public $o3 = null;
+ public $o2 = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -24785,21 +25234,16 @@ class ThriftHiveMetastore_add_partition_result {
0 => array(
'var' => 'success',
'type' => TType::STRUCT,
- 'class' => '\metastore\Partition',
+ 'class' => '\metastore\AlterTableResponse',
),
1 => array(
'var' => 'o1',
'type' => TType::STRUCT,
- 'class' => '\metastore\InvalidObjectException',
+ 'class' => '\metastore\InvalidOperationException',
),
2 => array(
'var' => 'o2',
'type' => TType::STRUCT,
- 'class' => '\metastore\AlreadyExistsException',
- ),
- 3 => array(
- 'var' => 'o3',
- 'type' => TType::STRUCT,
'class' => '\metastore\MetaException',
),
);
@@ -24814,14 +25258,11 @@ class ThriftHiveMetastore_add_partition_result {
if (isset($vals['o2'])) {
$this->o2 = $vals['o2'];
}
- if (isset($vals['o3'])) {
- $this->o3 = $vals['o3'];
- }
}
}
public function getName() {
- return 'ThriftHiveMetastore_add_partition_result';
+ return 'ThriftHiveMetastore_alter_table_req_result';
}
public function read($input)
@@ -24841,7 +25282,7 @@ class ThriftHiveMetastore_add_partition_result {
{
case 0:
if ($ftype == TType::STRUCT) {
- $this->success = new \metastore\Partition();
+ $this->success = new \metastore\AlterTableResponse();
$xfer += $this->success->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -24849,7 +25290,7 @@ class ThriftHiveMetastore_add_partition_result {
break;
case 1:
if ($ftype == TType::STRUCT) {
- $this->o1 = new \metastore\InvalidObjectException();
+ $this->o1 = new \metastore\InvalidOperationException();
$xfer += $this->o1->read($input);
} else {
$xfer += $input->skip($ftype);
@@ -24857,20 +25298,12 @@ class ThriftHiveMetastore_add_partition_result {
break;
case 2:
if ($ftype == TType::STRUCT) {
- $this->o2 = new \metastore\AlreadyExistsException();
+ $this->o2 = new \metastore\MetaException();
$xfer += $this->o2->read($input);
} else {
$xfer += $input->skip($ftype);
}
break;
- case 3:
- if ($ftype == TType::STRUCT) {
- $this->o3 = new \metastore\MetaException();
- $xfer += $this->o3->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
default:
$xfer += $input->skip($ftype);
break;
@@ -24883,7 +25316,7 @@ class ThriftHiveMetastore_add_partition_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('ThriftHiveMetastore_add_partition_result');
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_alter_table_req_result');
if ($this->success !== null) {
if (!is_object($this->success)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
@@ -24902,11 +25335,6 @@ class ThriftHiveMetastore_add_partition_result {
$xfer += $this->o2->write($output);
$xfer += $output->writeFieldEnd();
}
- if ($this->o3 !== null) {
- $xfer += $output->writeFieldBegin('o3', TType::STRUCT, 3);
- $xfer += $this->o3->write($output);
- $xfer += $output->writeFieldEnd();
- }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -24914,17 +25342,13 @@ class ThriftHiveMetastore_add_partition_result {
}
-class ThriftHiveMetastore_add_partition_with_environment_context_args {
+class ThriftHiveMetastore_add_partition_args {
static $_TSPEC;
/**
* @var \metastore\Partition
*/
public $new_part = null;
- /**
- * @var \metastore\EnvironmentContext
- */
- public $environment_context = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -24934,25 +25358,17 @@ class ThriftHiveMetastore_add_partition_with_environment_context_args {
'type' => TType::STRUCT,
'class' => '\metastore\Partition',
),
- 2 => array(
- 'var' => 'environment_context',
- 'type' => TType::STRUCT,
- 'class' => '\metastore\EnvironmentContext',
- ),
);
}
if (is_array($vals)) {
if (isset($vals['new_part'])) {
$this->new_part = $vals['new_part'];
}
- if (isset($vals['environment_context'])) {
- $this->environment_context = $vals['environment_context'];
- }
}
}
public function getName() {
- return 'ThriftHiveMetastore_add_partition_with_environment_context_args';
+ return 'ThriftHiveMetastore_add_partition_args';
}
public function read($input)
@@ -24978,14 +25394,6 @@ class ThriftHiveMetastore_add_partition_with_environment_context_args {
$xfer += $input->skip($ftype);
}
break;
- case 2:
- if ($ftype == TType::STRUCT) {
- $this->environment_context = new \metastore\EnvironmentContext();
- $xfer += $this->environment_context->read($input);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
default:
$xfer += $input->skip($ftype);
break;
@@ -24998,7 +25406,7 @@ class ThriftHiveMetastore_add_partition_with_environment_context_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('ThriftHiveMetastore_add_partition_with_environment_context_args');
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_add_partition_args');
if ($this->new_part !== null) {
if (!is_object($this->new_part)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
@@ -25007,14 +25415,6 @@ class ThriftHiveMetastore_add_partition_with_environment_context_args {
$xfer += $this->new_part->write($output);
$xfer += $output->writeFieldEnd();
}
- if ($this->environment_context !== null) {
- if (!is_object($this->environment_context)) {
- throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
- }
- $xfer += $output->writeFieldBegin('environment_context', TType::STRUCT, 2);
- $xfer += $this->environment_context->write($output);
- $xfer += $output->writeFieldEnd();
- }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -25022,7 +25422,7 @@ class ThriftHiveMetastore_add_partition_with_environment_context_args {
}
-class ThriftHiveMetastore_add_partition_with_environment_context_result {
+class ThriftHiveMetastore_add_partition_result {
static $_TSPEC;
/**
@@ -25084,7 +25484,7 @@ class ThriftHiveMetastore_add_partition_with_environment_context_result {
}
public function getName() {
- return 'ThriftHiveMetastore_add_partition_with_environment_context_result';
+ return 'ThriftHiveMetastore_add_partition_result';
}
public function read($input)
@@ -25146,7 +25546,7 @@ class ThriftHiveMetastore_add_partition_with_environment_context_result {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('ThriftHiveMetastore_add_partition_with_environment_context_result');
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_add_partition_result');
if ($this->success !== null) {
if (!is_object($this->success)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
@@ -25177,37 +25577,45 @@ class ThriftHiveMetastore_add_partition_with_environment_context_result {
}
-class ThriftHiveMetastore_add_partitions_args {
+class ThriftHiveMetastore_add_partition_with_environment_context_args {
static $_TSPEC;
/**
- * @var \metastore\Partition[]
+ * @var \metastore\Partition
*/
- public $new_parts = null;
+ public $new_part = null;
+ /**
+ * @var \metastore\EnvironmentContext
+ */
+ public $environment_context = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
self::$_TSPEC = array(
1 => array(
- 'var' => 'new_parts',
- 'type' => TType::LST,
- 'etype' => TType::STRUCT,
- 'elem' => array(
- 'type' => TType::STRUCT,
- 'class' => '\metastore\Partition',
- ),
+ 'var' => 'new_part',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Partition',
+ ),
+ 2 => array(
+ 'var' => 'environment_context',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\EnvironmentContext',
),
);
}
if (is_array($vals)) {
- if (isset($vals['new_parts'])) {
- $this->new_parts = $vals['new_parts'];
+ if (isset($vals['new_part'])) {
+ $this->new_part = $vals['new_part'];
+ }
+ if (isset($vals['environment_context'])) {
+ $this->environment_context = $vals['environment_context'];
}
}
}
public function getName() {
- return 'ThriftHiveMetastore_add_partitions_args';
+ return 'ThriftHiveMetastore_add_partition_with_environment_context_args';
}
public function read($input)
@@ -25226,19 +25634,17 @@ class ThriftHiveMetastore_add_partitions_args {
switch ($fid)
{
case 1:
- if ($ftype == TType::LST) {
- $this->new_parts = array();
- $_size1027 = 0;
- $_etype1030 = 0;
- $xfer += $input->readListBegin($_etype1030, $_size1027);
- for ($_i1031 = 0; $_i1031 < $_size1027; ++$_i1031)
- {
- $elem1032 = null;
- $elem1032 = new \metastore\Partition();
- $xfer += $elem1032->read($input);
- $this->new_parts []= $elem1032;
- }
- $xfer += $input->readListEnd();
+ if ($ftype == TType::STRUCT) {
+ $this->new_part = new \metastore\Partition();
+ $xfer += $this->new_part->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->environment_context = new \metastore\EnvironmentContext();
+ $xfer += $this->environment_context->read($input);
} else {
$xfer += $input->skip($ftype);
}
@@ -25255,22 +25661,21 @@ class ThriftHiveMetastore_add_partitions_args {
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('ThriftHiveMetastore_add_partitions_args');
- if ($this->new_parts !== null) {
- if (!is_array($this->new_parts)) {
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_add_partition_with_environment_context_args');
+ if ($this->new_part !== null) {
+ if (!is_object($this->new_part)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
}
- $xfer += $output->writeFieldBegin('new_parts', TType::LST, 1);
- {
- $output->writeListBegin(TType::STRUCT, count($this->new_parts));
- {
- foreach ($this->new_parts as $iter1033)
- {
- $xfer += $iter1033->write($output);
- }
- }
- $output->writeListEnd();
+ $xfer += $output->writeFieldBegin('new_part', TType::STRUCT, 1);
+ $xfer += $this->new_part->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->environment_context !== null) {
+ if (!is_object($this->environment_context)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
}
+ $xfer += $output->writeFieldBegin('environment_context', TType::STRUCT, 2);
+ $xfer += $this->environment_context->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
@@ -25280,11 +25685,11 @@ class ThriftHiveMetastore_add_partitions_args {
}
-class ThriftHiveMetastore_add_partitions_result {
+class ThriftHiveMetastore_add_partition_with_environment_context_result {
static $_TSPEC;
/**
- * @var int
+ * @var \metastore\Partition
*/
public $success = null;
/**
@@ -25305,7 +25710,265 @@ class ThriftHiveMetastore_add_partitions_result {
self::$_TSPEC = array(
0 => array(
'var' => 'success',
- 'type' => TType::I32,
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Partition',
+ ),
+ 1 => array(
+ 'var' => 'o1',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\InvalidObjectException',
+ ),
+ 2 => array(
+ 'var' => 'o2',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\AlreadyExistsException',
+ ),
+ 3 => array(
+ 'var' => 'o3',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\MetaException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['o1'])) {
+ $this->o1 = $vals['o1'];
+ }
+ if (isset($vals['o2'])) {
+ $this->o2 = $vals['o2'];
+ }
+ if (isset($vals['o3'])) {
+ $this->o3 = $vals['o3'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_add_partition_with_environment_context_result';
+ }
+
+ 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 0:
+ if ($ftype == TType::STRUCT) {
+ $this->success = new \metastore\Partition();
+ $xfer += $this->success->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->o1 = new \metastore\InvalidObjectException();
+ $xfer += $this->o1->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->o2 = new \metastore\AlreadyExistsException();
+ $xfer += $this->o2->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->o3 = new \metastore\MetaException();
+ $xfer += $this->o3->read($input);
+ } 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('ThriftHiveMetastore_add_partition_with_environment_context_result');
+ if ($this->success !== null) {
+ if (!is_object($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $this->success->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o1 !== null) {
+ $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1);
+ $xfer += $this->o1->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o2 !== null) {
+ $xfer += $output->writeFieldBegin('o2', TType::STRUCT, 2);
+ $xfer += $this->o2->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o3 !== null) {
+ $xfer += $output->writeFieldBegin('o3', TType::STRUCT, 3);
+ $xfer += $this->o3->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_add_partitions_args {
+ static $_TSPEC;
+
+ /**
+ * @var \metastore\Partition[]
+ */
+ public $new_parts = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'new_parts',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Partition',
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['new_parts'])) {
+ $this->new_parts = $vals['new_parts'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_add_partitions_args';
+ }
+
+ 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->new_parts = array();
+ $_size1034 = 0;
+ $_etype1037 = 0;
+ $xfer += $input->readListBegin($_etype1037, $_size1034);
+ for ($_i1038 = 0; $_i1038 < $_size1034; ++$_i1038)
+ {
+ $elem1039 = null;
+ $elem1039 = new \metastore\Partition();
+ $xfer += $elem1039->read($input);
+ $this->new_parts []= $elem1039;
+ }
+ $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('ThriftHiveMetastore_add_partitions_args');
+ if ($this->new_parts !== null) {
+ if (!is_array($this->new_parts)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('new_parts', TType::LST, 1);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->new_parts));
+ {
+ foreach ($this->new_parts as $iter1040)
+ {
+ $xfer += $iter1040->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_add_partitions_result {
+ static $_TSPEC;
+
+ /**
+ * @var int
+ */
+ public $success = null;
+ /**
+ * @var \metastore\InvalidObjectException
+ */
+ public $o1 = null;
+ /**
+ * @var \metastore\AlreadyExistsException
+ */
+ public $o2 = null;
+ /**
+ * @var \metastore\MetaException
+ */
+ public $o3 = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::I32,
),
1 => array(
'var' => 'o1',
@@ -25481,15 +26144,15 @@ class ThriftHiveMetastore_add_partitions_pspec_args {
case 1:
if ($ftype == TType::LST) {
$this->new_parts = array();
- $_size1034 = 0;
- $_etype1037 = 0;
- $xfer += $input->readListBegin($_etype1037, $_size1034);
- for ($_i1038 = 0; $_i1038 < $_size1034; ++$_i1038)
+ $_size1041 = 0;
+ $_etype1044 = 0;
+ $xfer += $input->readListBegin($_etype1044, $_size1041);
+ for ($_i1045 = 0; $_i1045 < $_size1041; ++$_i1045)
{
- $elem1039 = null;
- $elem1039 = new \metastore\PartitionSpec();
- $xfer += $elem1039->read($input);
- $this->new_parts []= $elem1039;
+ $elem1046 = null;
+ $elem1046 = new \metastore\PartitionSpec();
+ $xfer += $elem1046->read($input);
+ $this->new_parts []= $elem1046;
}
$xfer += $input->readListEnd();
} else {
@@ -25517,9 +26180,9 @@ class ThriftHiveMetastore_add_partitions_pspec_args {
{
$output->writeListBegin(TType::STRUCT, count($this->new_parts));
{
- foreach ($this->new_parts as $iter1040)
+ foreach ($this->new_parts as $iter1047)
{
- $xfer += $iter1040->write($output);
+ $xfer += $iter1047->write($output);
}
}
$output->writeListEnd();
@@ -25769,14 +26432,14 @@ class ThriftHiveMetastore_append_partition_args {
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size1041 = 0;
- $_etype1044 = 0;
- $xfer += $input->readListBegin($_etype1044, $_size1041);
- for ($_i1045 = 0; $_i1045 < $_size1041; ++$_i1045)
+ $_size1048 = 0;
+ $_etype1051 = 0;
+ $xfer += $input->readListBegin($_etype1051, $_size1048);
+ for ($_i1052 = 0; $_i1052 < $_size1048; ++$_i1052)
{
- $elem1046 = null;
- $xfer += $input->readString($elem1046);
- $this->part_vals []= $elem1046;
+ $elem1053 = null;
+ $xfer += $input->readString($elem1053);
+ $this->part_vals []= $elem1053;
}
$xfer += $input->readListEnd();
} else {
@@ -25814,9 +26477,9 @@ class ThriftHiveMetastore_append_partition_args {
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter1047)
+ foreach ($this->part_vals as $iter1054)
{
- $xfer += $output->writeString($iter1047);
+ $xfer += $output->writeString($iter1054);
}
}
$output->writeListEnd();
@@ -26318,14 +26981,14 @@ class ThriftHiveMetastore_append_partition_with_environment_context_args {
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size1048 = 0;
- $_etype1051 = 0;
- $xfer += $input->readListBegin($_etype1051, $_size1048);
- for ($_i1052 = 0; $_i1052 < $_size1048; ++$_i1052)
+ $_size1055 = 0;
+ $_etype1058 = 0;
+ $xfer += $input->readListBegin($_etype1058, $_size1055);
+ for ($_i1059 = 0; $_i1059 < $_size1055; ++$_i1059)
{
- $elem1053 = null;
- $xfer += $input->readString($elem1053);
- $this->part_vals []= $elem1053;
+ $elem1060 = null;
+ $xfer += $input->readString($elem1060);
+ $this->part_vals []= $elem1060;
}
$xfer += $input->readListEnd();
} else {
@@ -26371,9 +27034,9 @@ class ThriftHiveMetastore_append_partition_with_environment_context_args {
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter1054)
+ foreach ($this->part_vals as $iter1061)
{
- $xfer += $output->writeString($iter1054);
+ $xfer += $output->writeString($iter1061);
}
}
$output->writeListEnd();
@@ -27227,14 +27890,14 @@ class ThriftHiveMetastore_drop_partition_args {
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size1055 = 0;
- $_etype1058 = 0;
- $xfer += $input->readListBegin($_etype1058, $_size1055);
- for ($_i1059 = 0; $_i1059 < $_size1055; ++$_i1059)
+ $_size1062 = 0;
+ $_etype1065 = 0;
+ $xfer += $input->readListBegin($_etype1065, $_size1062);
+ for ($_i1066 = 0; $_i1066 < $_size1062; ++$_i1066)
{
- $elem1060 = null;
- $xfer += $input->readString($elem1060);
- $this->part_vals []= $elem1060;
+ $elem1067 = null;
+ $xfer += $input->readString($elem1067);
+ $this->part_vals []= $elem1067;
}
$xfer += $input->readListEnd();
} else {
@@ -27279,9 +27942,9 @@ class ThriftHiveMetastore_drop_partition_args {
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter1061)
+ foreach ($this->part_vals as $iter1068)
{
- $xfer += $output->writeString($iter1061);
+ $xfer += $output->writeString($iter1068);
}
}
$output->writeListEnd();
@@ -27534,14 +28197,14 @@ class ThriftHiveMetastore_drop_partition_with_environment_context_args {
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size1062 = 0;
- $_etype1065 = 0;
- $xfer += $input->readListBegin($_etype1065, $_size1062);
- for ($_i1066 = 0; $_i1066 < $_size1062; ++$_i1066)
+ $_size1069 = 0;
+ $_etype1072 = 0;
+ $xfer += $input->readListBegin($_etype1072, $_size1069);
+ for ($_i1073 = 0; $_i1073 < $_size1069; ++$_i1073)
{
- $elem1067 = null;
- $xfer += $input->readString($elem1067);
- $this->part_vals []= $elem1067;
+ $elem1074 = null;
+ $xfer += $input->readString($elem1074);
+ $this->part_vals []= $elem1074;
}
$xfer += $input->readListEnd();
} else {
@@ -27594,9 +28257,9 @@ class ThriftHiveMetastore_drop_partition_with_environment_context_args {
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter1068)
+ foreach ($this->part_vals as $iter1075)
{
- $xfer += $output->writeString($iter1068);
+ $xfer += $output->writeString($iter1075);
}
}
$output->writeListEnd();
@@ -28610,14 +29273,14 @@ class ThriftHiveMetastore_get_partition_args {
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size1069 = 0;
- $_etype1072 = 0;
- $xfer += $input->readListBegin($_etype1072, $_size1069);
- for ($_i1073 = 0; $_i1073 < $_size1069; ++$_i1073)
+ $_size1076 = 0;
+ $_etype1079 = 0;
+ $xfer += $input->readListBegin($_etype1079, $_size1076);
+ for ($_i1080 = 0; $_i1080 < $_size1076; ++$_i1080)
{
- $elem1074 = null;
- $xfer += $input->readString($elem1074);
- $this->part_vals []= $elem1074;
+ $elem1081 = null;
+ $xfer += $input->readString($elem1081);
+ $this->part_vals []= $elem1081;
}
$xfer += $input->readListEnd();
} else {
@@ -28655,9 +29318,9 @@ class ThriftHiveMetastore_get_partition_args {
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter1075)
+ foreach ($this->part_vals as $iter1082)
{
- $xfer += $output->writeString($iter1075);
+ $xfer += $output->writeString($iter1082);
}
}
$output->writeListEnd();
@@ -28899,17 +29562,17 @@ class ThriftH
<TRUNCATED>