You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by dj...@apache.org on 2018/05/08 18:42:16 UTC
[11/58] [abbrv] hive git commit: HIVE-18988: Support bootstrap
replication of ACID tables (Sankar Hariappan, reviewed by Mahesh Kumar Behera,
Thejas M Nair)
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/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 da66951..2056730 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
@@ -167,6 +167,7 @@ class ThriftHiveMetastoreIf : virtual public ::facebook::fb303::FacebookService
virtual void abort_txn(const AbortTxnRequest& rqst) = 0;
virtual void abort_txns(const AbortTxnsRequest& rqst) = 0;
virtual void commit_txn(const CommitTxnRequest& rqst) = 0;
+ virtual void repl_tbl_writeid_state(const ReplTblWriteIdStateRequest& rqst) = 0;
virtual void get_valid_write_ids(GetValidWriteIdsResponse& _return, const GetValidWriteIdsRequest& rqst) = 0;
virtual void allocate_table_write_ids(AllocateTableWriteIdsResponse& _return, const AllocateTableWriteIdsRequest& rqst) = 0;
virtual void lock(LockResponse& _return, const LockRequest& rqst) = 0;
@@ -717,6 +718,9 @@ class ThriftHiveMetastoreNull : virtual public ThriftHiveMetastoreIf , virtual p
void commit_txn(const CommitTxnRequest& /* rqst */) {
return;
}
+ void repl_tbl_writeid_state(const ReplTblWriteIdStateRequest& /* rqst */) {
+ return;
+ }
void get_valid_write_ids(GetValidWriteIdsResponse& /* _return */, const GetValidWriteIdsRequest& /* rqst */) {
return;
}
@@ -19064,6 +19068,92 @@ class ThriftHiveMetastore_commit_txn_presult {
};
+typedef struct _ThriftHiveMetastore_repl_tbl_writeid_state_args__isset {
+ _ThriftHiveMetastore_repl_tbl_writeid_state_args__isset() : rqst(false) {}
+ bool rqst :1;
+} _ThriftHiveMetastore_repl_tbl_writeid_state_args__isset;
+
+class ThriftHiveMetastore_repl_tbl_writeid_state_args {
+ public:
+
+ ThriftHiveMetastore_repl_tbl_writeid_state_args(const ThriftHiveMetastore_repl_tbl_writeid_state_args&);
+ ThriftHiveMetastore_repl_tbl_writeid_state_args& operator=(const ThriftHiveMetastore_repl_tbl_writeid_state_args&);
+ ThriftHiveMetastore_repl_tbl_writeid_state_args() {
+ }
+
+ virtual ~ThriftHiveMetastore_repl_tbl_writeid_state_args() throw();
+ ReplTblWriteIdStateRequest rqst;
+
+ _ThriftHiveMetastore_repl_tbl_writeid_state_args__isset __isset;
+
+ void __set_rqst(const ReplTblWriteIdStateRequest& val);
+
+ bool operator == (const ThriftHiveMetastore_repl_tbl_writeid_state_args & rhs) const
+ {
+ if (!(rqst == rhs.rqst))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_repl_tbl_writeid_state_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_repl_tbl_writeid_state_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_repl_tbl_writeid_state_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_repl_tbl_writeid_state_pargs() throw();
+ const ReplTblWriteIdStateRequest* rqst;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_repl_tbl_writeid_state_result {
+ public:
+
+ ThriftHiveMetastore_repl_tbl_writeid_state_result(const ThriftHiveMetastore_repl_tbl_writeid_state_result&);
+ ThriftHiveMetastore_repl_tbl_writeid_state_result& operator=(const ThriftHiveMetastore_repl_tbl_writeid_state_result&);
+ ThriftHiveMetastore_repl_tbl_writeid_state_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_repl_tbl_writeid_state_result() throw();
+
+ bool operator == (const ThriftHiveMetastore_repl_tbl_writeid_state_result & /* rhs */) const
+ {
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_repl_tbl_writeid_state_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_repl_tbl_writeid_state_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_repl_tbl_writeid_state_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_repl_tbl_writeid_state_presult() throw();
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
typedef struct _ThriftHiveMetastore_get_valid_write_ids_args__isset {
_ThriftHiveMetastore_get_valid_write_ids_args__isset() : rqst(false) {}
bool rqst :1;
@@ -26314,6 +26404,9 @@ class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public
void commit_txn(const CommitTxnRequest& rqst);
void send_commit_txn(const CommitTxnRequest& rqst);
void recv_commit_txn();
+ void repl_tbl_writeid_state(const ReplTblWriteIdStateRequest& rqst);
+ void send_repl_tbl_writeid_state(const ReplTblWriteIdStateRequest& rqst);
+ void recv_repl_tbl_writeid_state();
void get_valid_write_ids(GetValidWriteIdsResponse& _return, const GetValidWriteIdsRequest& rqst);
void send_get_valid_write_ids(const GetValidWriteIdsRequest& rqst);
void recv_get_valid_write_ids(GetValidWriteIdsResponse& _return);
@@ -26646,6 +26739,7 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP
void process_abort_txn(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_abort_txns(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_commit_txn(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_repl_tbl_writeid_state(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_get_valid_write_ids(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_allocate_table_write_ids(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_lock(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -26854,6 +26948,7 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP
processMap_["abort_txn"] = &ThriftHiveMetastoreProcessor::process_abort_txn;
processMap_["abort_txns"] = &ThriftHiveMetastoreProcessor::process_abort_txns;
processMap_["commit_txn"] = &ThriftHiveMetastoreProcessor::process_commit_txn;
+ processMap_["repl_tbl_writeid_state"] = &ThriftHiveMetastoreProcessor::process_repl_tbl_writeid_state;
processMap_["get_valid_write_ids"] = &ThriftHiveMetastoreProcessor::process_get_valid_write_ids;
processMap_["allocate_table_write_ids"] = &ThriftHiveMetastoreProcessor::process_allocate_table_write_ids;
processMap_["lock"] = &ThriftHiveMetastoreProcessor::process_lock;
@@ -28332,6 +28427,15 @@ class ThriftHiveMetastoreMultiface : virtual public ThriftHiveMetastoreIf, publi
ifaces_[i]->commit_txn(rqst);
}
+ void repl_tbl_writeid_state(const ReplTblWriteIdStateRequest& rqst) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->repl_tbl_writeid_state(rqst);
+ }
+ ifaces_[i]->repl_tbl_writeid_state(rqst);
+ }
+
void get_valid_write_ids(GetValidWriteIdsResponse& _return, const GetValidWriteIdsRequest& rqst) {
size_t sz = ifaces_.size();
size_t i = 0;
@@ -29358,6 +29462,9 @@ class ThriftHiveMetastoreConcurrentClient : virtual public ThriftHiveMetastoreIf
void commit_txn(const CommitTxnRequest& rqst);
int32_t send_commit_txn(const CommitTxnRequest& rqst);
void recv_commit_txn(const int32_t seqid);
+ void repl_tbl_writeid_state(const ReplTblWriteIdStateRequest& rqst);
+ int32_t send_repl_tbl_writeid_state(const ReplTblWriteIdStateRequest& rqst);
+ void recv_repl_tbl_writeid_state(const int32_t seqid);
void get_valid_write_ids(GetValidWriteIdsResponse& _return, const GetValidWriteIdsRequest& rqst);
int32_t send_get_valid_write_ids(const GetValidWriteIdsRequest& rqst);
void recv_get_valid_write_ids(GetValidWriteIdsResponse& _return, const int32_t seqid);
http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/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 3b0b38c..c1c0b77 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
@@ -747,6 +747,11 @@ class ThriftHiveMetastoreHandler : virtual public ThriftHiveMetastoreIf {
printf("commit_txn\n");
}
+ void repl_tbl_writeid_state(const ReplTblWriteIdStateRequest& rqst) {
+ // Your implementation goes here
+ printf("repl_tbl_writeid_state\n");
+ }
+
void get_valid_write_ids(GetValidWriteIdsResponse& _return, const GetValidWriteIdsRequest& rqst) {
// Your implementation goes here
printf("get_valid_write_ids\n");