You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by kh...@apache.org on 2017/04/28 04:26:18 UTC
[5/7] hive git commit: HIVE-16171 : Support replication of truncate
table (Sankar Hariappan, reviewed by Sushanth Sowmyan)
http://git-wip-us.apache.org/repos/asf/hive/blob/bbf5ecce/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
index fca5ae5..ca71711 100644
--- a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
+++ b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
@@ -46,6 +46,7 @@ class ThriftHiveMetastoreIf : virtual public ::facebook::fb303::FacebookService
virtual void add_foreign_key(const AddForeignKeyRequest& req) = 0;
virtual void drop_table(const std::string& dbname, const std::string& name, const bool deleteData) = 0;
virtual void drop_table_with_environment_context(const std::string& dbname, const std::string& name, const bool deleteData, const EnvironmentContext& environment_context) = 0;
+ virtual void truncate_table(const std::string& dbName, const std::string& tableName, const std::vector<std::string> & partNames) = 0;
virtual void get_tables(std::vector<std::string> & _return, const std::string& db_name, const std::string& pattern) = 0;
virtual void get_tables_by_type(std::vector<std::string> & _return, const std::string& db_name, const std::string& pattern, const std::string& tableType) = 0;
virtual void get_table_meta(std::vector<TableMeta> & _return, const std::string& db_patterns, const std::string& tbl_patterns, const std::vector<std::string> & tbl_types) = 0;
@@ -278,6 +279,9 @@ class ThriftHiveMetastoreNull : virtual public ThriftHiveMetastoreIf , virtual p
void drop_table_with_environment_context(const std::string& /* dbname */, const std::string& /* name */, const bool /* deleteData */, const EnvironmentContext& /* environment_context */) {
return;
}
+ void truncate_table(const std::string& /* dbName */, const std::string& /* tableName */, const std::vector<std::string> & /* partNames */) {
+ return;
+ }
void get_tables(std::vector<std::string> & /* _return */, const std::string& /* db_name */, const std::string& /* pattern */) {
return;
}
@@ -3655,6 +3659,124 @@ class ThriftHiveMetastore_drop_table_with_environment_context_presult {
};
+typedef struct _ThriftHiveMetastore_truncate_table_args__isset {
+ _ThriftHiveMetastore_truncate_table_args__isset() : dbName(false), tableName(false), partNames(false) {}
+ bool dbName :1;
+ bool tableName :1;
+ bool partNames :1;
+} _ThriftHiveMetastore_truncate_table_args__isset;
+
+class ThriftHiveMetastore_truncate_table_args {
+ public:
+
+ ThriftHiveMetastore_truncate_table_args(const ThriftHiveMetastore_truncate_table_args&);
+ ThriftHiveMetastore_truncate_table_args& operator=(const ThriftHiveMetastore_truncate_table_args&);
+ ThriftHiveMetastore_truncate_table_args() : dbName(), tableName() {
+ }
+
+ virtual ~ThriftHiveMetastore_truncate_table_args() throw();
+ std::string dbName;
+ std::string tableName;
+ std::vector<std::string> partNames;
+
+ _ThriftHiveMetastore_truncate_table_args__isset __isset;
+
+ void __set_dbName(const std::string& val);
+
+ void __set_tableName(const std::string& val);
+
+ void __set_partNames(const std::vector<std::string> & val);
+
+ bool operator == (const ThriftHiveMetastore_truncate_table_args & rhs) const
+ {
+ if (!(dbName == rhs.dbName))
+ return false;
+ if (!(tableName == rhs.tableName))
+ return false;
+ if (!(partNames == rhs.partNames))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_truncate_table_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_truncate_table_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_truncate_table_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_truncate_table_pargs() throw();
+ const std::string* dbName;
+ const std::string* tableName;
+ const std::vector<std::string> * partNames;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_truncate_table_result__isset {
+ _ThriftHiveMetastore_truncate_table_result__isset() : o1(false) {}
+ bool o1 :1;
+} _ThriftHiveMetastore_truncate_table_result__isset;
+
+class ThriftHiveMetastore_truncate_table_result {
+ public:
+
+ ThriftHiveMetastore_truncate_table_result(const ThriftHiveMetastore_truncate_table_result&);
+ ThriftHiveMetastore_truncate_table_result& operator=(const ThriftHiveMetastore_truncate_table_result&);
+ ThriftHiveMetastore_truncate_table_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_truncate_table_result() throw();
+ MetaException o1;
+
+ _ThriftHiveMetastore_truncate_table_result__isset __isset;
+
+ void __set_o1(const MetaException& val);
+
+ bool operator == (const ThriftHiveMetastore_truncate_table_result & rhs) const
+ {
+ if (!(o1 == rhs.o1))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_truncate_table_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_truncate_table_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_truncate_table_presult__isset {
+ _ThriftHiveMetastore_truncate_table_presult__isset() : o1(false) {}
+ bool o1 :1;
+} _ThriftHiveMetastore_truncate_table_presult__isset;
+
+class ThriftHiveMetastore_truncate_table_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_truncate_table_presult() throw();
+ MetaException o1;
+
+ _ThriftHiveMetastore_truncate_table_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
typedef struct _ThriftHiveMetastore_get_tables_args__isset {
_ThriftHiveMetastore_get_tables_args__isset() : db_name(false), pattern(false) {}
bool db_name :1;
@@ -19684,6 +19806,9 @@ class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public
void drop_table_with_environment_context(const std::string& dbname, const std::string& name, const bool deleteData, const EnvironmentContext& environment_context);
void send_drop_table_with_environment_context(const std::string& dbname, const std::string& name, const bool deleteData, const EnvironmentContext& environment_context);
void recv_drop_table_with_environment_context();
+ void truncate_table(const std::string& dbName, const std::string& tableName, const std::vector<std::string> & partNames);
+ void send_truncate_table(const std::string& dbName, const std::string& tableName, const std::vector<std::string> & partNames);
+ void recv_truncate_table();
void get_tables(std::vector<std::string> & _return, const std::string& db_name, const std::string& pattern);
void send_get_tables(const std::string& db_name, const std::string& pattern);
void recv_get_tables(std::vector<std::string> & _return);
@@ -20105,6 +20230,7 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP
void process_add_foreign_key(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_drop_table(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_drop_table_with_environment_context(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_truncate_table(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_get_tables(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_get_tables_by_type(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_get_table_meta(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
@@ -20262,6 +20388,7 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP
processMap_["add_foreign_key"] = &ThriftHiveMetastoreProcessor::process_add_foreign_key;
processMap_["drop_table"] = &ThriftHiveMetastoreProcessor::process_drop_table;
processMap_["drop_table_with_environment_context"] = &ThriftHiveMetastoreProcessor::process_drop_table_with_environment_context;
+ processMap_["truncate_table"] = &ThriftHiveMetastoreProcessor::process_truncate_table;
processMap_["get_tables"] = &ThriftHiveMetastoreProcessor::process_get_tables;
processMap_["get_tables_by_type"] = &ThriftHiveMetastoreProcessor::process_get_tables_by_type;
processMap_["get_table_meta"] = &ThriftHiveMetastoreProcessor::process_get_table_meta;
@@ -20650,6 +20777,15 @@ class ThriftHiveMetastoreMultiface : virtual public ThriftHiveMetastoreIf, publi
ifaces_[i]->drop_table_with_environment_context(dbname, name, deleteData, environment_context);
}
+ void truncate_table(const std::string& dbName, const std::string& tableName, const std::vector<std::string> & partNames) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->truncate_table(dbName, tableName, partNames);
+ }
+ ifaces_[i]->truncate_table(dbName, tableName, partNames);
+ }
+
void get_tables(std::vector<std::string> & _return, const std::string& db_name, const std::string& pattern) {
size_t sz = ifaces_.size();
size_t i = 0;
@@ -21979,6 +22115,9 @@ class ThriftHiveMetastoreConcurrentClient : virtual public ThriftHiveMetastoreIf
void drop_table_with_environment_context(const std::string& dbname, const std::string& name, const bool deleteData, const EnvironmentContext& environment_context);
int32_t send_drop_table_with_environment_context(const std::string& dbname, const std::string& name, const bool deleteData, const EnvironmentContext& environment_context);
void recv_drop_table_with_environment_context(const int32_t seqid);
+ void truncate_table(const std::string& dbName, const std::string& tableName, const std::vector<std::string> & partNames);
+ int32_t send_truncate_table(const std::string& dbName, const std::string& tableName, const std::vector<std::string> & partNames);
+ void recv_truncate_table(const int32_t seqid);
void get_tables(std::vector<std::string> & _return, const std::string& db_name, const std::string& pattern);
int32_t send_get_tables(const std::string& db_name, const std::string& pattern);
void recv_get_tables(std::vector<std::string> & _return, const int32_t seqid);
http://git-wip-us.apache.org/repos/asf/hive/blob/bbf5ecce/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
index dfa462d..b4a2a92 100644
--- a/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
+++ b/metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore_server.skeleton.cpp
@@ -142,6 +142,11 @@ class ThriftHiveMetastoreHandler : virtual public ThriftHiveMetastoreIf {
printf("drop_table_with_environment_context\n");
}
+ void truncate_table(const std::string& dbName, const std::string& tableName, const std::vector<std::string> & partNames) {
+ // Your implementation goes here
+ printf("truncate_table\n");
+ }
+
void get_tables(std::vector<std::string> & _return, const std::string& db_name, const std::string& pattern) {
// Your implementation goes here
printf("get_tables\n");