[02/24] hive git commit: HIVE-18839: Implement incremental rebuild for materialized views (only insert operations in source tables) (Jesus Camacho Rodriguez, reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/c695c70b/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
--
diff --git
a/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
b/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
index 5e3dff1..7a8a42a 100644
---
a/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
+++
b/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
@@ -1514,6 +1514,20 @@ interface ThriftHiveMetastoreIf extends
\FacebookServiceIf {
* @throws \metastore\MetaException
*/
public function get_serde(\metastore\GetSerdeRequest $rqst);
+ /**
+ * @param string $dbName
+ * @param string $tableName
+ * @param int $txnId
+ * @return \metastore\LockResponse
+ */
+ public function get_lock_materialization_rebuild($dbName, $tableName,
$txnId);
+ /**
+ * @param string $dbName
+ * @param string $tableName
+ * @param int $txnId
+ * @return bool
+ */
+ public function heartbeat_lock_materialization_rebuild($dbName, $tableName,
$txnId);
}
class ThriftHiveMetastoreClient extends \FacebookServiceClient implements
\metastore\ThriftHiveMetastoreIf {
@@ -12887,6 +12901,112 @@ class ThriftHiveMetastoreClient extends
\FacebookServiceClient implements \metas
throw new \Exception("get_serde failed: unknown result");
}
+ public function get_lock_materialization_rebuild($dbName, $tableName, $txnId)
+ {
+$this->send_get_lock_materialization_rebuild($dbName, $tableName, $txnId);
+return $this->recv_get_lock_materialization_rebuild();
+ }
+
+ public function send_get_lock_materialization_rebuild($dbName, $tableName,
$txnId)
+ {
+$args = new
\metastore\ThriftHiveMetastore_get_lock_materialization_rebuild_args();
+$args->dbName = $dbName;
+$args->tableName = $tableName;
+$args->txnId = $txnId;
+$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) &&
function_exists('thrift_protocol_write_binary');
+if ($bin_accel)
+{
+ thrift_protocol_write_binary($this->output_,
'get_lock_materialization_rebuild', TMessageType::CALL, $args, $this->seqid_,
$this->output_->isStrictWrite());
+}
+else
+{
+ $this->output_->writeMessageBegin('get_lock_materialization_rebuild',
TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+}
+ }
+
+ public function recv_get_lock_materialization_rebuild()
+ {
+$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) &&
function_exists('thrift_protocol_read_binary');
+if ($bin_accel) $result = thrift_protocol_read_binary($this->input_,
'\metastore\ThriftHiveMetastore_get_lock_materialization_rebuild_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_get_lock_materialization_rebuild_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+}
+if ($result->success !== null) {
+ return $result->success;
+}
+throw new \Exception("get_lock_materialization_rebuild failed: unknown
result");
+ }
+
+ public function heartbeat_lock_materialization_rebuild($dbName, $tableName,
$txnId)
+ {
+$this->send_heartbeat_lock_materialization_rebuild($dbName, $tableName,
$txnId);
+return $this->recv_heartbeat_lock_materialization_rebuild();
+ }
+
+ public function send_heartbeat_lock_materialization_rebuild($dbName,
$tableName, $txnId)
+ {
+$args = new
\metastore\ThriftHiveMetastore_heartbeat_lock_materialization_rebuild_args();
+$args->dbName = $dbName;
+$args->tableName = $tableName;
+$args->txnId = $txnId;
+$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) &&
function_exists('thrift_protocol_write_binary');
+if ($bin_accel)
+{
+ thrift_protocol_write_binary($this->output_,
'heartbeat_lock_materialization_rebuild', TMessageType::CALL, $args,
$this->seqid_, $this->output_->isStrictWrite());
+}
+else
+{
+
$this->output_->writeMessageBegin('heartbeat_lock_materialization_rebuild',
TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+}
+ }
+
+ public function recv_heartbeat_lock_materialization_rebuild()
+ {
+$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) &&
[02/24] hive git commit: HIVE-18839: Implement incremental rebuild for materialized views (only insert operations in source tables) (Jesus Camacho Rodriguez, reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/be420098/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
--
diff --git
a/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
b/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
index 5e3dff1..7a8a42a 100644
---
a/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
+++
b/standalone-metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
@@ -1514,6 +1514,20 @@ interface ThriftHiveMetastoreIf extends
\FacebookServiceIf {
* @throws \metastore\MetaException
*/
public function get_serde(\metastore\GetSerdeRequest $rqst);
+ /**
+ * @param string $dbName
+ * @param string $tableName
+ * @param int $txnId
+ * @return \metastore\LockResponse
+ */
+ public function get_lock_materialization_rebuild($dbName, $tableName,
$txnId);
+ /**
+ * @param string $dbName
+ * @param string $tableName
+ * @param int $txnId
+ * @return bool
+ */
+ public function heartbeat_lock_materialization_rebuild($dbName, $tableName,
$txnId);
}
class ThriftHiveMetastoreClient extends \FacebookServiceClient implements
\metastore\ThriftHiveMetastoreIf {
@@ -12887,6 +12901,112 @@ class ThriftHiveMetastoreClient extends
\FacebookServiceClient implements \metas
throw new \Exception("get_serde failed: unknown result");
}
+ public function get_lock_materialization_rebuild($dbName, $tableName, $txnId)
+ {
+$this->send_get_lock_materialization_rebuild($dbName, $tableName, $txnId);
+return $this->recv_get_lock_materialization_rebuild();
+ }
+
+ public function send_get_lock_materialization_rebuild($dbName, $tableName,
$txnId)
+ {
+$args = new
\metastore\ThriftHiveMetastore_get_lock_materialization_rebuild_args();
+$args->dbName = $dbName;
+$args->tableName = $tableName;
+$args->txnId = $txnId;
+$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) &&
function_exists('thrift_protocol_write_binary');
+if ($bin_accel)
+{
+ thrift_protocol_write_binary($this->output_,
'get_lock_materialization_rebuild', TMessageType::CALL, $args, $this->seqid_,
$this->output_->isStrictWrite());
+}
+else
+{
+ $this->output_->writeMessageBegin('get_lock_materialization_rebuild',
TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+}
+ }
+
+ public function recv_get_lock_materialization_rebuild()
+ {
+$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) &&
function_exists('thrift_protocol_read_binary');
+if ($bin_accel) $result = thrift_protocol_read_binary($this->input_,
'\metastore\ThriftHiveMetastore_get_lock_materialization_rebuild_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_get_lock_materialization_rebuild_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+}
+if ($result->success !== null) {
+ return $result->success;
+}
+throw new \Exception("get_lock_materialization_rebuild failed: unknown
result");
+ }
+
+ public function heartbeat_lock_materialization_rebuild($dbName, $tableName,
$txnId)
+ {
+$this->send_heartbeat_lock_materialization_rebuild($dbName, $tableName,
$txnId);
+return $this->recv_heartbeat_lock_materialization_rebuild();
+ }
+
+ public function send_heartbeat_lock_materialization_rebuild($dbName,
$tableName, $txnId)
+ {
+$args = new
\metastore\ThriftHiveMetastore_heartbeat_lock_materialization_rebuild_args();
+$args->dbName = $dbName;
+$args->tableName = $tableName;
+$args->txnId = $txnId;
+$bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) &&
function_exists('thrift_protocol_write_binary');
+if ($bin_accel)
+{
+ thrift_protocol_write_binary($this->output_,
'heartbeat_lock_materialization_rebuild', TMessageType::CALL, $args,
$this->seqid_, $this->output_->isStrictWrite());
+}
+else
+{
+
$this->output_->writeMessageBegin('heartbeat_lock_materialization_rebuild',
TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+}
+ }
+
+ public function recv_heartbeat_lock_materialization_rebuild()
+ {
+$bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) &&
