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/03 18:00:32 UTC
[08/10] hive git commit: HIVE-19975 : Checking writeIdList per table
may not check the commit level of a partition on a partitioned table (Sergey
Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/a47a80fe/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h b/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
index 3b18dc8..b887210 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
@@ -105,7 +105,8 @@ class ThriftHiveMetastoreIf : virtual public ::facebook::fb303::FacebookService
virtual void get_partitions_by_names(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & names) = 0;
virtual void alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part) = 0;
virtual void alter_partitions(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts) = 0;
- virtual void alter_partitions_with_environment_context(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req) = 0;
+ virtual void alter_partitions_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext& environment_context) = 0;
+ virtual void alter_partitions_with_environment_context_req(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req) = 0;
virtual void alter_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context) = 0;
virtual void rename_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part) = 0;
virtual bool partition_name_has_valid_characters(const std::vector<std::string> & part_vals, const bool throw_exception) = 0;
@@ -517,7 +518,10 @@ class ThriftHiveMetastoreNull : virtual public ThriftHiveMetastoreIf , virtual p
void alter_partitions(const std::string& /* db_name */, const std::string& /* tbl_name */, const std::vector<Partition> & /* new_parts */) {
return;
}
- void alter_partitions_with_environment_context(AlterPartitionsResponse& /* _return */, const AlterPartitionsRequest& /* req */) {
+ void alter_partitions_with_environment_context(const std::string& /* db_name */, const std::string& /* tbl_name */, const std::vector<Partition> & /* new_parts */, const EnvironmentContext& /* environment_context */) {
+ return;
+ }
+ void alter_partitions_with_environment_context_req(AlterPartitionsResponse& /* _return */, const AlterPartitionsRequest& /* req */) {
return;
}
void alter_partition_with_environment_context(const std::string& /* db_name */, const std::string& /* tbl_name */, const Partition& /* new_part */, const EnvironmentContext& /* environment_context */) {
@@ -11641,8 +11645,11 @@ class ThriftHiveMetastore_alter_partitions_presult {
};
typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset {
- _ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset() : req(false) {}
- bool req :1;
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset() : db_name(false), tbl_name(false), new_parts(false), environment_context(false) {}
+ bool db_name :1;
+ bool tbl_name :1;
+ bool new_parts :1;
+ bool environment_context :1;
} _ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset;
class ThriftHiveMetastore_alter_partitions_with_environment_context_args {
@@ -11650,19 +11657,34 @@ class ThriftHiveMetastore_alter_partitions_with_environment_context_args {
ThriftHiveMetastore_alter_partitions_with_environment_context_args(const ThriftHiveMetastore_alter_partitions_with_environment_context_args&);
ThriftHiveMetastore_alter_partitions_with_environment_context_args& operator=(const ThriftHiveMetastore_alter_partitions_with_environment_context_args&);
- ThriftHiveMetastore_alter_partitions_with_environment_context_args() {
+ ThriftHiveMetastore_alter_partitions_with_environment_context_args() : db_name(), tbl_name() {
}
virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_args() throw();
- AlterPartitionsRequest req;
+ std::string db_name;
+ std::string tbl_name;
+ std::vector<Partition> new_parts;
+ EnvironmentContext environment_context;
_ThriftHiveMetastore_alter_partitions_with_environment_context_args__isset __isset;
- void __set_req(const AlterPartitionsRequest& val);
+ void __set_db_name(const std::string& val);
+
+ void __set_tbl_name(const std::string& val);
+
+ void __set_new_parts(const std::vector<Partition> & val);
+
+ void __set_environment_context(const EnvironmentContext& val);
bool operator == (const ThriftHiveMetastore_alter_partitions_with_environment_context_args & rhs) const
{
- if (!(req == rhs.req))
+ if (!(db_name == rhs.db_name))
+ return false;
+ if (!(tbl_name == rhs.tbl_name))
+ return false;
+ if (!(new_parts == rhs.new_parts))
+ return false;
+ if (!(environment_context == rhs.environment_context))
return false;
return true;
}
@@ -11683,15 +11705,17 @@ class ThriftHiveMetastore_alter_partitions_with_environment_context_pargs {
virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_pargs() throw();
- const AlterPartitionsRequest* req;
+ const std::string* db_name;
+ const std::string* tbl_name;
+ const std::vector<Partition> * new_parts;
+ const EnvironmentContext* environment_context;
uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
};
typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset {
- _ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset() : success(false), o1(false), o2(false) {}
- bool success :1;
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset() : o1(false), o2(false) {}
bool o1 :1;
bool o2 :1;
} _ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset;
@@ -11705,22 +11729,17 @@ class ThriftHiveMetastore_alter_partitions_with_environment_context_result {
}
virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_result() throw();
- AlterPartitionsResponse success;
InvalidOperationException o1;
MetaException o2;
_ThriftHiveMetastore_alter_partitions_with_environment_context_result__isset __isset;
- void __set_success(const AlterPartitionsResponse& val);
-
void __set_o1(const InvalidOperationException& val);
void __set_o2(const MetaException& val);
bool operator == (const ThriftHiveMetastore_alter_partitions_with_environment_context_result & rhs) const
{
- if (!(success == rhs.success))
- return false;
if (!(o1 == rhs.o1))
return false;
if (!(o2 == rhs.o2))
@@ -11739,8 +11758,7 @@ class ThriftHiveMetastore_alter_partitions_with_environment_context_result {
};
typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_presult__isset {
- _ThriftHiveMetastore_alter_partitions_with_environment_context_presult__isset() : success(false), o1(false), o2(false) {}
- bool success :1;
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_presult__isset() : o1(false), o2(false) {}
bool o1 :1;
bool o2 :1;
} _ThriftHiveMetastore_alter_partitions_with_environment_context_presult__isset;
@@ -11750,7 +11768,6 @@ class ThriftHiveMetastore_alter_partitions_with_environment_context_presult {
virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_presult() throw();
- AlterPartitionsResponse* success;
InvalidOperationException o1;
MetaException o2;
@@ -11760,6 +11777,126 @@ class ThriftHiveMetastore_alter_partitions_with_environment_context_presult {
};
+typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_req_args__isset {
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_req_args__isset() : req(false) {}
+ bool req :1;
+} _ThriftHiveMetastore_alter_partitions_with_environment_context_req_args__isset;
+
+class ThriftHiveMetastore_alter_partitions_with_environment_context_req_args {
+ public:
+
+ ThriftHiveMetastore_alter_partitions_with_environment_context_req_args(const ThriftHiveMetastore_alter_partitions_with_environment_context_req_args&);
+ ThriftHiveMetastore_alter_partitions_with_environment_context_req_args& operator=(const ThriftHiveMetastore_alter_partitions_with_environment_context_req_args&);
+ ThriftHiveMetastore_alter_partitions_with_environment_context_req_args() {
+ }
+
+ virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_req_args() throw();
+ AlterPartitionsRequest req;
+
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_req_args__isset __isset;
+
+ void __set_req(const AlterPartitionsRequest& val);
+
+ bool operator == (const ThriftHiveMetastore_alter_partitions_with_environment_context_req_args & rhs) const
+ {
+ if (!(req == rhs.req))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_alter_partitions_with_environment_context_req_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_alter_partitions_with_environment_context_req_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_alter_partitions_with_environment_context_req_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_req_pargs() throw();
+ const AlterPartitionsRequest* req;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_req_result__isset {
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_req_result__isset() : success(false), o1(false), o2(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+} _ThriftHiveMetastore_alter_partitions_with_environment_context_req_result__isset;
+
+class ThriftHiveMetastore_alter_partitions_with_environment_context_req_result {
+ public:
+
+ ThriftHiveMetastore_alter_partitions_with_environment_context_req_result(const ThriftHiveMetastore_alter_partitions_with_environment_context_req_result&);
+ ThriftHiveMetastore_alter_partitions_with_environment_context_req_result& operator=(const ThriftHiveMetastore_alter_partitions_with_environment_context_req_result&);
+ ThriftHiveMetastore_alter_partitions_with_environment_context_req_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_req_result() throw();
+ AlterPartitionsResponse success;
+ InvalidOperationException o1;
+ MetaException o2;
+
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_req_result__isset __isset;
+
+ void __set_success(const AlterPartitionsResponse& val);
+
+ void __set_o1(const InvalidOperationException& val);
+
+ void __set_o2(const MetaException& val);
+
+ bool operator == (const ThriftHiveMetastore_alter_partitions_with_environment_context_req_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(o1 == rhs.o1))
+ return false;
+ if (!(o2 == rhs.o2))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_alter_partitions_with_environment_context_req_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_alter_partitions_with_environment_context_req_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_alter_partitions_with_environment_context_req_presult__isset {
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_req_presult__isset() : success(false), o1(false), o2(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+} _ThriftHiveMetastore_alter_partitions_with_environment_context_req_presult__isset;
+
+class ThriftHiveMetastore_alter_partitions_with_environment_context_req_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_alter_partitions_with_environment_context_req_presult() throw();
+ AlterPartitionsResponse* success;
+ InvalidOperationException o1;
+ MetaException o2;
+
+ _ThriftHiveMetastore_alter_partitions_with_environment_context_req_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
typedef struct _ThriftHiveMetastore_alter_partition_with_environment_context_args__isset {
_ThriftHiveMetastore_alter_partition_with_environment_context_args__isset() : db_name(false), tbl_name(false), new_part(false), environment_context(false) {}
bool db_name :1;
@@ -26567,9 +26704,12 @@ class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public
void alter_partitions(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts);
void send_alter_partitions(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts);
void recv_alter_partitions();
- void alter_partitions_with_environment_context(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req);
- void send_alter_partitions_with_environment_context(const AlterPartitionsRequest& req);
- void recv_alter_partitions_with_environment_context(AlterPartitionsResponse& _return);
+ void alter_partitions_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext& environment_context);
+ void send_alter_partitions_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext& environment_context);
+ void recv_alter_partitions_with_environment_context();
+ void alter_partitions_with_environment_context_req(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req);
+ void send_alter_partitions_with_environment_context_req(const AlterPartitionsRequest& req);
+ void recv_alter_partitions_with_environment_context_req(AlterPartitionsResponse& _return);
void alter_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context);
void send_alter_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context);
void recv_alter_partition_with_environment_context();
@@ -27036,6 +27176,7 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP
void process_alter_partition(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_alter_partitions(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_alter_partitions_with_environment_context(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_alter_partitions_with_environment_context_req(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_alter_partition_with_environment_context(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_rename_partition(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_partition_name_has_valid_characters(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -27248,6 +27389,7 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP
processMap_["alter_partition"] = &ThriftHiveMetastoreProcessor::process_alter_partition;
processMap_["alter_partitions"] = &ThriftHiveMetastoreProcessor::process_alter_partitions;
processMap_["alter_partitions_with_environment_context"] = &ThriftHiveMetastoreProcessor::process_alter_partitions_with_environment_context;
+ processMap_["alter_partitions_with_environment_context_req"] = &ThriftHiveMetastoreProcessor::process_alter_partitions_with_environment_context_req;
processMap_["alter_partition_with_environment_context"] = &ThriftHiveMetastoreProcessor::process_alter_partition_with_environment_context;
processMap_["rename_partition"] = &ThriftHiveMetastoreProcessor::process_rename_partition;
processMap_["partition_name_has_valid_characters"] = &ThriftHiveMetastoreProcessor::process_partition_name_has_valid_characters;
@@ -28200,13 +28342,22 @@ class ThriftHiveMetastoreMultiface : virtual public ThriftHiveMetastoreIf, publi
ifaces_[i]->alter_partitions(db_name, tbl_name, new_parts);
}
- void alter_partitions_with_environment_context(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req) {
+ void alter_partitions_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext& environment_context) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->alter_partitions_with_environment_context(db_name, tbl_name, new_parts, environment_context);
+ }
+ ifaces_[i]->alter_partitions_with_environment_context(db_name, tbl_name, new_parts, environment_context);
+ }
+
+ void alter_partitions_with_environment_context_req(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req) {
size_t sz = ifaces_.size();
size_t i = 0;
for (; i < (sz - 1); ++i) {
- ifaces_[i]->alter_partitions_with_environment_context(_return, req);
+ ifaces_[i]->alter_partitions_with_environment_context_req(_return, req);
}
- ifaces_[i]->alter_partitions_with_environment_context(_return, req);
+ ifaces_[i]->alter_partitions_with_environment_context_req(_return, req);
return;
}
@@ -29670,9 +29821,12 @@ class ThriftHiveMetastoreConcurrentClient : virtual public ThriftHiveMetastoreIf
void alter_partitions(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts);
int32_t send_alter_partitions(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts);
void recv_alter_partitions(const int32_t seqid);
- void alter_partitions_with_environment_context(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req);
- int32_t send_alter_partitions_with_environment_context(const AlterPartitionsRequest& req);
- void recv_alter_partitions_with_environment_context(AlterPartitionsResponse& _return, const int32_t seqid);
+ void alter_partitions_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext& environment_context);
+ int32_t send_alter_partitions_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext& environment_context);
+ void recv_alter_partitions_with_environment_context(const int32_t seqid);
+ void alter_partitions_with_environment_context_req(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req);
+ int32_t send_alter_partitions_with_environment_context_req(const AlterPartitionsRequest& req);
+ void recv_alter_partitions_with_environment_context_req(AlterPartitionsResponse& _return, const int32_t seqid);
void alter_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context);
int32_t send_alter_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context);
void recv_alter_partition_with_environment_context(const int32_t seqid);
http://git-wip-us.apache.org/repos/asf/hive/blob/a47a80fe/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp b/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
index 493c3ff..fba2f57 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
@@ -437,11 +437,16 @@ class ThriftHiveMetastoreHandler : virtual public ThriftHiveMetastoreIf {
printf("alter_partitions\n");
}
- void alter_partitions_with_environment_context(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req) {
+ void alter_partitions_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<Partition> & new_parts, const EnvironmentContext& environment_context) {
// Your implementation goes here
printf("alter_partitions_with_environment_context\n");
}
+ void alter_partitions_with_environment_context_req(AlterPartitionsResponse& _return, const AlterPartitionsRequest& req) {
+ // Your implementation goes here
+ printf("alter_partitions_with_environment_context_req\n");
+ }
+
void alter_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const Partition& new_part, const EnvironmentContext& environment_context) {
// Your implementation goes here
printf("alter_partition_with_environment_context\n");