[03/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-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
--
diff --git
a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index 0bca4eb..afe82e3 100644
---
a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++
b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -442,6 +442,10 @@ import org.slf4j.LoggerFactory;
public SerDeInfo get_serde(GetSerdeRequest rqst) throws
NoSuchObjectException, MetaException, org.apache.thrift.TException;
+public LockResponse get_lock_materialization_rebuild(String dbName, String
tableName, long txnId) throws org.apache.thrift.TException;
+
+public boolean heartbeat_lock_materialization_rebuild(String dbName,
String tableName, long txnId) throws org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public interface
AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
@@ -846,6 +850,10 @@ import org.slf4j.LoggerFactory;
public void get_serde(GetSerdeRequest rqst,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+public void get_lock_materialization_rebuild(String dbName, String
tableName, long txnId, org.apache.thrift.async.AsyncMethodCallback
resultHandler) throws org.apache.thrift.TException;
+
+public void heartbeat_lock_materialization_rebuild(String dbName, String
tableName, long txnId, org.apache.thrift.async.AsyncMethodCallback
resultHandler) throws org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Client extends com.facebook.fb303.FacebookService.Client implements Iface {
@@ -6634,6 +6642,56 @@ import org.slf4j.LoggerFactory;
throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"get_serde failed: unknown result");
}
+public LockResponse get_lock_materialization_rebuild(String dbName, String
tableName, long txnId) throws org.apache.thrift.TException
+{
+ send_get_lock_materialization_rebuild(dbName, tableName, txnId);
+ return recv_get_lock_materialization_rebuild();
+}
+
+public void send_get_lock_materialization_rebuild(String dbName, String
tableName, long txnId) throws org.apache.thrift.TException
+{
+ get_lock_materialization_rebuild_args args = new
get_lock_materialization_rebuild_args();
+ args.setDbName(dbName);
+ args.setTableName(tableName);
+ args.setTxnId(txnId);
+ sendBase("get_lock_materialization_rebuild", args);
+}
+
+public LockResponse recv_get_lock_materialization_rebuild() throws
org.apache.thrift.TException
+{
+ get_lock_materialization_rebuild_result result = new
get_lock_materialization_rebuild_result();
+ receiveBase(result, "get_lock_materialization_rebuild");
+ if (result.isSetSuccess()) {
+return result.success;
+ }
+ throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"get_lock_materialization_rebuild failed: unknown result");
+}
+
+public boolean heartbeat_lock_materialization_rebuild(String dbName,
String tableName, long txnId) throws org.apache.thrift.TException
+{
+ send_heartbeat_lock_materialization_rebuild(dbName, tableName, txnId);
+ return recv_heartbeat_lock_materialization_rebuild();
+}
+
+public void send_heartbeat_lock_materialization_rebuild(String dbName,
String tableName, long txnId) throws org.apache.thrift.TException
+{
+ heartbeat_lock_materialization_rebuild_args args = new
heartbeat_lock_materialization_rebuild_args();
+ args.setDbName(dbName);
+ args.setTableName(tableName);
+ args.setTxnId(txnId);
+ sendBase("heartbeat_lock_materialization_rebuild", args);
+}
+
+public boolean recv_heartbeat_lock_materialization_rebuild() throws
org.apache.thrift.TException
+{
+ heartbeat_lock_materialization_rebuild_result result = new
heartbeat_lock_materialization_rebuild_result();
+ receiveBase(result, "heartbeat_lock_materialization_rebuild");
+ if (result.isSetSuccess()) {
+return result.success;
+ }
+ throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"heartbeat_lock_materialization_rebuild failed: unknown result");
+}
+
[03/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-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
--
diff --git
a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
index 0bca4eb..afe82e3 100644
---
a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
+++
b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ThriftHiveMetastore.java
@@ -442,6 +442,10 @@ import org.slf4j.LoggerFactory;
public SerDeInfo get_serde(GetSerdeRequest rqst) throws
NoSuchObjectException, MetaException, org.apache.thrift.TException;
+public LockResponse get_lock_materialization_rebuild(String dbName, String
tableName, long txnId) throws org.apache.thrift.TException;
+
+public boolean heartbeat_lock_materialization_rebuild(String dbName,
String tableName, long txnId) throws org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public interface
AsyncIface extends com.facebook.fb303.FacebookService .AsyncIface {
@@ -846,6 +850,10 @@ import org.slf4j.LoggerFactory;
public void get_serde(GetSerdeRequest rqst,
org.apache.thrift.async.AsyncMethodCallback resultHandler) throws
org.apache.thrift.TException;
+public void get_lock_materialization_rebuild(String dbName, String
tableName, long txnId, org.apache.thrift.async.AsyncMethodCallback
resultHandler) throws org.apache.thrift.TException;
+
+public void heartbeat_lock_materialization_rebuild(String dbName, String
tableName, long txnId, org.apache.thrift.async.AsyncMethodCallback
resultHandler) throws org.apache.thrift.TException;
+
}
@org.apache.hadoop.classification.InterfaceAudience.Public
@org.apache.hadoop.classification.InterfaceStability.Stable public static class
Client extends com.facebook.fb303.FacebookService.Client implements Iface {
@@ -6634,6 +6642,56 @@ import org.slf4j.LoggerFactory;
throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"get_serde failed: unknown result");
}
+public LockResponse get_lock_materialization_rebuild(String dbName, String
tableName, long txnId) throws org.apache.thrift.TException
+{
+ send_get_lock_materialization_rebuild(dbName, tableName, txnId);
+ return recv_get_lock_materialization_rebuild();
+}
+
+public void send_get_lock_materialization_rebuild(String dbName, String
tableName, long txnId) throws org.apache.thrift.TException
+{
+ get_lock_materialization_rebuild_args args = new
get_lock_materialization_rebuild_args();
+ args.setDbName(dbName);
+ args.setTableName(tableName);
+ args.setTxnId(txnId);
+ sendBase("get_lock_materialization_rebuild", args);
+}
+
+public LockResponse recv_get_lock_materialization_rebuild() throws
org.apache.thrift.TException
+{
+ get_lock_materialization_rebuild_result result = new
get_lock_materialization_rebuild_result();
+ receiveBase(result, "get_lock_materialization_rebuild");
+ if (result.isSetSuccess()) {
+return result.success;
+ }
+ throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"get_lock_materialization_rebuild failed: unknown result");
+}
+
+public boolean heartbeat_lock_materialization_rebuild(String dbName,
String tableName, long txnId) throws org.apache.thrift.TException
+{
+ send_heartbeat_lock_materialization_rebuild(dbName, tableName, txnId);
+ return recv_heartbeat_lock_materialization_rebuild();
+}
+
+public void send_heartbeat_lock_materialization_rebuild(String dbName,
String tableName, long txnId) throws org.apache.thrift.TException
+{
+ heartbeat_lock_materialization_rebuild_args args = new
heartbeat_lock_materialization_rebuild_args();
+ args.setDbName(dbName);
+ args.setTableName(tableName);
+ args.setTxnId(txnId);
+ sendBase("heartbeat_lock_materialization_rebuild", args);
+}
+
+public boolean recv_heartbeat_lock_materialization_rebuild() throws
org.apache.thrift.TException
+{
+ heartbeat_lock_materialization_rebuild_result result = new
heartbeat_lock_materialization_rebuild_result();
+ receiveBase(result, "heartbeat_lock_materialization_rebuild");
+ if (result.isSetSuccess()) {
+return result.success;
+ }
+ throw new
org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT,
"heartbeat_lock_materialization_rebuild failed: unknown result");
+}
+
