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:22 UTC
[26/48] hive git commit: HIVE-20006: Make materializations
invalidation cache work with multiple active remote metastores (Jesus Camacho
Rodriguez, reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/1b5903b0/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h b/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
index 352f5c7..a547de1 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
@@ -65,7 +65,7 @@ class ThriftHiveMetastoreIf : virtual public ::facebook::fb303::FacebookService
virtual void get_table_objects_by_name(std::vector<Table> & _return, const std::string& dbname, const std::vector<std::string> & tbl_names) = 0;
virtual void get_table_req(GetTableResult& _return, const GetTableRequest& req) = 0;
virtual void get_table_objects_by_name_req(GetTablesResult& _return, const GetTablesRequest& req) = 0;
- virtual void get_materialization_invalidation_info(std::map<std::string, Materialization> & _return, const std::string& dbname, const std::vector<std::string> & tbl_names) = 0;
+ virtual void get_materialization_invalidation_info(Materialization& _return, const CreationMetadata& creation_metadata, const std::string& validTxnList) = 0;
virtual void update_creation_metadata(const std::string& catName, const std::string& dbname, const std::string& tbl_name, const CreationMetadata& creation_metadata) = 0;
virtual void get_table_names_by_filter(std::vector<std::string> & _return, const std::string& dbname, const std::string& filter, const int16_t max_tables) = 0;
virtual void alter_table(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl) = 0;
@@ -390,7 +390,7 @@ class ThriftHiveMetastoreNull : virtual public ThriftHiveMetastoreIf , virtual p
void get_table_objects_by_name_req(GetTablesResult& /* _return */, const GetTablesRequest& /* req */) {
return;
}
- void get_materialization_invalidation_info(std::map<std::string, Materialization> & /* _return */, const std::string& /* dbname */, const std::vector<std::string> & /* tbl_names */) {
+ void get_materialization_invalidation_info(Materialization& /* _return */, const CreationMetadata& /* creation_metadata */, const std::string& /* validTxnList */) {
return;
}
void update_creation_metadata(const std::string& /* catName */, const std::string& /* dbname */, const std::string& /* tbl_name */, const CreationMetadata& /* creation_metadata */) {
@@ -6131,9 +6131,9 @@ class ThriftHiveMetastore_get_table_objects_by_name_req_presult {
};
typedef struct _ThriftHiveMetastore_get_materialization_invalidation_info_args__isset {
- _ThriftHiveMetastore_get_materialization_invalidation_info_args__isset() : dbname(false), tbl_names(false) {}
- bool dbname :1;
- bool tbl_names :1;
+ _ThriftHiveMetastore_get_materialization_invalidation_info_args__isset() : creation_metadata(false), validTxnList(false) {}
+ bool creation_metadata :1;
+ bool validTxnList :1;
} _ThriftHiveMetastore_get_materialization_invalidation_info_args__isset;
class ThriftHiveMetastore_get_materialization_invalidation_info_args {
@@ -6141,24 +6141,24 @@ class ThriftHiveMetastore_get_materialization_invalidation_info_args {
ThriftHiveMetastore_get_materialization_invalidation_info_args(const ThriftHiveMetastore_get_materialization_invalidation_info_args&);
ThriftHiveMetastore_get_materialization_invalidation_info_args& operator=(const ThriftHiveMetastore_get_materialization_invalidation_info_args&);
- ThriftHiveMetastore_get_materialization_invalidation_info_args() : dbname() {
+ ThriftHiveMetastore_get_materialization_invalidation_info_args() : validTxnList() {
}
virtual ~ThriftHiveMetastore_get_materialization_invalidation_info_args() throw();
- std::string dbname;
- std::vector<std::string> tbl_names;
+ CreationMetadata creation_metadata;
+ std::string validTxnList;
_ThriftHiveMetastore_get_materialization_invalidation_info_args__isset __isset;
- void __set_dbname(const std::string& val);
+ void __set_creation_metadata(const CreationMetadata& val);
- void __set_tbl_names(const std::vector<std::string> & val);
+ void __set_validTxnList(const std::string& val);
bool operator == (const ThriftHiveMetastore_get_materialization_invalidation_info_args & rhs) const
{
- if (!(dbname == rhs.dbname))
+ if (!(creation_metadata == rhs.creation_metadata))
return false;
- if (!(tbl_names == rhs.tbl_names))
+ if (!(validTxnList == rhs.validTxnList))
return false;
return true;
}
@@ -6179,8 +6179,8 @@ class ThriftHiveMetastore_get_materialization_invalidation_info_pargs {
virtual ~ThriftHiveMetastore_get_materialization_invalidation_info_pargs() throw();
- const std::string* dbname;
- const std::vector<std::string> * tbl_names;
+ const CreationMetadata* creation_metadata;
+ const std::string* validTxnList;
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
@@ -6203,14 +6203,14 @@ class ThriftHiveMetastore_get_materialization_invalidation_info_result {
}
virtual ~ThriftHiveMetastore_get_materialization_invalidation_info_result() throw();
- std::map<std::string, Materialization> success;
+ Materialization success;
MetaException o1;
InvalidOperationException o2;
UnknownDBException o3;
_ThriftHiveMetastore_get_materialization_invalidation_info_result__isset __isset;
- void __set_success(const std::map<std::string, Materialization> & val);
+ void __set_success(const Materialization& val);
void __set_o1(const MetaException& val);
@@ -6254,7 +6254,7 @@ class ThriftHiveMetastore_get_materialization_invalidation_info_presult {
virtual ~ThriftHiveMetastore_get_materialization_invalidation_info_presult() throw();
- std::map<std::string, Materialization> * success;
+ Materialization* success;
MetaException o1;
InvalidOperationException o2;
UnknownDBException o3;
@@ -26460,9 +26460,9 @@ class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public
void get_table_objects_by_name_req(GetTablesResult& _return, const GetTablesRequest& req);
void send_get_table_objects_by_name_req(const GetTablesRequest& req);
void recv_get_table_objects_by_name_req(GetTablesResult& _return);
- void get_materialization_invalidation_info(std::map<std::string, Materialization> & _return, const std::string& dbname, const std::vector<std::string> & tbl_names);
- void send_get_materialization_invalidation_info(const std::string& dbname, const std::vector<std::string> & tbl_names);
- void recv_get_materialization_invalidation_info(std::map<std::string, Materialization> & _return);
+ void get_materialization_invalidation_info(Materialization& _return, const CreationMetadata& creation_metadata, const std::string& validTxnList);
+ void send_get_materialization_invalidation_info(const CreationMetadata& creation_metadata, const std::string& validTxnList);
+ void recv_get_materialization_invalidation_info(Materialization& _return);
void update_creation_metadata(const std::string& catName, const std::string& dbname, const std::string& tbl_name, const CreationMetadata& creation_metadata);
void send_update_creation_metadata(const std::string& catName, const std::string& dbname, const std::string& tbl_name, const CreationMetadata& creation_metadata);
void recv_update_creation_metadata();
@@ -27826,13 +27826,13 @@ class ThriftHiveMetastoreMultiface : virtual public ThriftHiveMetastoreIf, publi
return;
}
- void get_materialization_invalidation_info(std::map<std::string, Materialization> & _return, const std::string& dbname, const std::vector<std::string> & tbl_names) {
+ void get_materialization_invalidation_info(Materialization& _return, const CreationMetadata& creation_metadata, const std::string& validTxnList) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->get_materialization_invalidation_info(_return, dbname, tbl_names);
+ ifaces_[i]->get_materialization_invalidation_info(_return, creation_metadata, validTxnList);
}
- ifaces_[i]->get_materialization_invalidation_info(_return, dbname, tbl_names);
+ ifaces_[i]->get_materialization_invalidation_info(_return, creation_metadata, validTxnList);
return;
}
@@ -29562,9 +29562,9 @@ class ThriftHiveMetastoreConcurrentClient : virtual public ThriftHiveMetastoreIf
void get_table_objects_by_name_req(GetTablesResult& _return, const GetTablesRequest& req);
int32_t send_get_table_objects_by_name_req(const GetTablesRequest& req);
void recv_get_table_objects_by_name_req(GetTablesResult& _return, const int32_t seqid);
- void get_materialization_invalidation_info(std::map<std::string, Materialization> & _return, const std::string& dbname, const std::vector<std::string> & tbl_names);
- int32_t send_get_materialization_invalidation_info(const std::string& dbname, const std::vector<std::string> & tbl_names);
- void recv_get_materialization_invalidation_info(std::map<std::string, Materialization> & _return, const int32_t seqid);
+ void get_materialization_invalidation_info(Materialization& _return, const CreationMetadata& creation_metadata, const std::string& validTxnList);
+ int32_t send_get_materialization_invalidation_info(const CreationMetadata& creation_metadata, const std::string& validTxnList);
+ void recv_get_materialization_invalidation_info(Materialization& _return, const int32_t seqid);
void update_creation_metadata(const std::string& catName, const std::string& dbname, const std::string& tbl_name, const CreationMetadata& creation_metadata);
int32_t send_update_creation_metadata(const std::string& catName, const std::string& dbname, const std::string& tbl_name, const CreationMetadata& creation_metadata);
void recv_update_creation_metadata(const int32_t seqid);
http://git-wip-us.apache.org/repos/asf/hive/blob/1b5903b0/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp b/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
index 789c150..5819b17 100644
--- a/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
+++ b/standalone-metastore/metastore-common/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
@@ -237,7 +237,7 @@ class ThriftHiveMetastoreHandler : virtual public ThriftHiveMetastoreIf {
printf("get_table_objects_by_name_req\n");
}
- void get_materialization_invalidation_info(std::map<std::string, Materialization> & _return, const std::string& dbname, const std::vector<std::string> & tbl_names) {
+ void get_materialization_invalidation_info(Materialization& _return, const CreationMetadata& creation_metadata, const std::string& validTxnList) {
// Your implementation goes here
printf("get_materialization_invalidation_info\n");
}