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 2017/11/27 22:28:04 UTC
[10/13] hive git commit: HIVE-17954 : Implement pool, user,
group and trigger to pool management API's (Harish Jaiprakash,
reviewed by Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/44ef5991/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 5c4284b..dc9540d 100644
--- a/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
+++ b/standalone-metastore/src/gen/thrift/gen-cpp/ThriftHiveMetastore.h
@@ -195,6 +195,12 @@ class ThriftHiveMetastoreIf : virtual public ::facebook::fb303::FacebookService
virtual void alter_wm_trigger(WMAlterTriggerResponse& _return, const WMAlterTriggerRequest& request) = 0;
virtual void drop_wm_trigger(WMDropTriggerResponse& _return, const WMDropTriggerRequest& request) = 0;
virtual void get_triggers_for_resourceplan(WMGetTriggersForResourePlanResponse& _return, const WMGetTriggersForResourePlanRequest& request) = 0;
+ virtual void create_wm_pool(WMCreatePoolResponse& _return, const WMCreatePoolRequest& request) = 0;
+ virtual void alter_wm_pool(WMAlterPoolResponse& _return, const WMAlterPoolRequest& request) = 0;
+ virtual void drop_wm_pool(WMDropPoolResponse& _return, const WMDropPoolRequest& request) = 0;
+ virtual void create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse& _return, const WMCreateOrUpdateMappingRequest& request) = 0;
+ virtual void drop_wm_mapping(WMDropMappingResponse& _return, const WMDropMappingRequest& request) = 0;
+ virtual void create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse& _return, const WMCreateOrDropTriggerToPoolMappingRequest& request) = 0;
};
class ThriftHiveMetastoreIfFactory : virtual public ::facebook::fb303::FacebookServiceIfFactory {
@@ -771,6 +777,24 @@ class ThriftHiveMetastoreNull : virtual public ThriftHiveMetastoreIf , virtual p
void get_triggers_for_resourceplan(WMGetTriggersForResourePlanResponse& /* _return */, const WMGetTriggersForResourePlanRequest& /* request */) {
return;
}
+ void create_wm_pool(WMCreatePoolResponse& /* _return */, const WMCreatePoolRequest& /* request */) {
+ return;
+ }
+ void alter_wm_pool(WMAlterPoolResponse& /* _return */, const WMAlterPoolRequest& /* request */) {
+ return;
+ }
+ void drop_wm_pool(WMDropPoolResponse& /* _return */, const WMDropPoolRequest& /* request */) {
+ return;
+ }
+ void create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse& /* _return */, const WMCreateOrUpdateMappingRequest& /* request */) {
+ return;
+ }
+ void drop_wm_mapping(WMDropMappingResponse& /* _return */, const WMDropMappingRequest& /* request */) {
+ return;
+ }
+ void create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse& /* _return */, const WMCreateOrDropTriggerToPoolMappingRequest& /* request */) {
+ return;
+ }
};
typedef struct _ThriftHiveMetastore_getMetaConf_args__isset {
@@ -22081,242 +22105,1042 @@ class ThriftHiveMetastore_get_triggers_for_resourceplan_presult {
};
-class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public ::facebook::fb303::FacebookServiceClient {
+typedef struct _ThriftHiveMetastore_create_wm_pool_args__isset {
+ _ThriftHiveMetastore_create_wm_pool_args__isset() : request(false) {}
+ bool request :1;
+} _ThriftHiveMetastore_create_wm_pool_args__isset;
+
+class ThriftHiveMetastore_create_wm_pool_args {
public:
- ThriftHiveMetastoreClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) :
- ::facebook::fb303::FacebookServiceClient(prot, prot) {}
- ThriftHiveMetastoreClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) : ::facebook::fb303::FacebookServiceClient(iprot, oprot) {}
- boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getInputProtocol() {
- return piprot_;
+
+ ThriftHiveMetastore_create_wm_pool_args(const ThriftHiveMetastore_create_wm_pool_args&);
+ ThriftHiveMetastore_create_wm_pool_args& operator=(const ThriftHiveMetastore_create_wm_pool_args&);
+ ThriftHiveMetastore_create_wm_pool_args() {
}
- boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getOutputProtocol() {
- return poprot_;
+
+ virtual ~ThriftHiveMetastore_create_wm_pool_args() throw();
+ WMCreatePoolRequest request;
+
+ _ThriftHiveMetastore_create_wm_pool_args__isset __isset;
+
+ void __set_request(const WMCreatePoolRequest& val);
+
+ bool operator == (const ThriftHiveMetastore_create_wm_pool_args & rhs) const
+ {
+ if (!(request == rhs.request))
+ return false;
+ return true;
}
- void getMetaConf(std::string& _return, const std::string& key);
- void send_getMetaConf(const std::string& key);
- void recv_getMetaConf(std::string& _return);
- void setMetaConf(const std::string& key, const std::string& value);
- void send_setMetaConf(const std::string& key, const std::string& value);
- void recv_setMetaConf();
- void create_database(const Database& database);
- void send_create_database(const Database& database);
- void recv_create_database();
- void get_database(Database& _return, const std::string& name);
- void send_get_database(const std::string& name);
- void recv_get_database(Database& _return);
- void drop_database(const std::string& name, const bool deleteData, const bool cascade);
- void send_drop_database(const std::string& name, const bool deleteData, const bool cascade);
- void recv_drop_database();
- void get_databases(std::vector<std::string> & _return, const std::string& pattern);
- void send_get_databases(const std::string& pattern);
- void recv_get_databases(std::vector<std::string> & _return);
- void get_all_databases(std::vector<std::string> & _return);
- void send_get_all_databases();
- void recv_get_all_databases(std::vector<std::string> & _return);
- void alter_database(const std::string& dbname, const Database& db);
- void send_alter_database(const std::string& dbname, const Database& db);
- void recv_alter_database();
- void get_type(Type& _return, const std::string& name);
- void send_get_type(const std::string& name);
- void recv_get_type(Type& _return);
- bool create_type(const Type& type);
- void send_create_type(const Type& type);
- bool recv_create_type();
- bool drop_type(const std::string& type);
- void send_drop_type(const std::string& type);
- bool recv_drop_type();
- void get_type_all(std::map<std::string, Type> & _return, const std::string& name);
- void send_get_type_all(const std::string& name);
- void recv_get_type_all(std::map<std::string, Type> & _return);
- void get_fields(std::vector<FieldSchema> & _return, const std::string& db_name, const std::string& table_name);
- void send_get_fields(const std::string& db_name, const std::string& table_name);
- void recv_get_fields(std::vector<FieldSchema> & _return);
- void get_fields_with_environment_context(std::vector<FieldSchema> & _return, const std::string& db_name, const std::string& table_name, const EnvironmentContext& environment_context);
- void send_get_fields_with_environment_context(const std::string& db_name, const std::string& table_name, const EnvironmentContext& environment_context);
- void recv_get_fields_with_environment_context(std::vector<FieldSchema> & _return);
- void get_schema(std::vector<FieldSchema> & _return, const std::string& db_name, const std::string& table_name);
- void send_get_schema(const std::string& db_name, const std::string& table_name);
- void recv_get_schema(std::vector<FieldSchema> & _return);
- void get_schema_with_environment_context(std::vector<FieldSchema> & _return, const std::string& db_name, const std::string& table_name, const EnvironmentContext& environment_context);
- void send_get_schema_with_environment_context(const std::string& db_name, const std::string& table_name, const EnvironmentContext& environment_context);
- void recv_get_schema_with_environment_context(std::vector<FieldSchema> & _return);
- void create_table(const Table& tbl);
- void send_create_table(const Table& tbl);
- void recv_create_table();
- void create_table_with_environment_context(const Table& tbl, const EnvironmentContext& environment_context);
- void send_create_table_with_environment_context(const Table& tbl, const EnvironmentContext& environment_context);
- void recv_create_table_with_environment_context();
- void create_table_with_constraints(const Table& tbl, const std::vector<SQLPrimaryKey> & primaryKeys, const std::vector<SQLForeignKey> & foreignKeys, const std::vector<SQLUniqueConstraint> & uniqueConstraints, const std::vector<SQLNotNullConstraint> & notNullConstraints);
- void send_create_table_with_constraints(const Table& tbl, const std::vector<SQLPrimaryKey> & primaryKeys, const std::vector<SQLForeignKey> & foreignKeys, const std::vector<SQLUniqueConstraint> & uniqueConstraints, const std::vector<SQLNotNullConstraint> & notNullConstraints);
- void recv_create_table_with_constraints();
- void drop_constraint(const DropConstraintRequest& req);
- void send_drop_constraint(const DropConstraintRequest& req);
- void recv_drop_constraint();
- void add_primary_key(const AddPrimaryKeyRequest& req);
- void send_add_primary_key(const AddPrimaryKeyRequest& req);
- void recv_add_primary_key();
- void add_foreign_key(const AddForeignKeyRequest& req);
- void send_add_foreign_key(const AddForeignKeyRequest& req);
- void recv_add_foreign_key();
- void add_unique_constraint(const AddUniqueConstraintRequest& req);
- void send_add_unique_constraint(const AddUniqueConstraintRequest& req);
- void recv_add_unique_constraint();
- void add_not_null_constraint(const AddNotNullConstraintRequest& req);
- void send_add_not_null_constraint(const AddNotNullConstraintRequest& req);
- void recv_add_not_null_constraint();
- void drop_table(const std::string& dbname, const std::string& name, const bool deleteData);
- void send_drop_table(const std::string& dbname, const std::string& name, const bool deleteData);
- void recv_drop_table();
- 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);
- void get_tables_by_type(std::vector<std::string> & _return, const std::string& db_name, const std::string& pattern, const std::string& tableType);
- void send_get_tables_by_type(const std::string& db_name, const std::string& pattern, const std::string& tableType);
- void recv_get_tables_by_type(std::vector<std::string> & _return);
- 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);
- void send_get_table_meta(const std::string& db_patterns, const std::string& tbl_patterns, const std::vector<std::string> & tbl_types);
- void recv_get_table_meta(std::vector<TableMeta> & _return);
- void get_all_tables(std::vector<std::string> & _return, const std::string& db_name);
- void send_get_all_tables(const std::string& db_name);
- void recv_get_all_tables(std::vector<std::string> & _return);
- void get_table(Table& _return, const std::string& dbname, const std::string& tbl_name);
- void send_get_table(const std::string& dbname, const std::string& tbl_name);
- void recv_get_table(Table& _return);
- void get_table_objects_by_name(std::vector<Table> & _return, const std::string& dbname, const std::vector<std::string> & tbl_names);
- void send_get_table_objects_by_name(const std::string& dbname, const std::vector<std::string> & tbl_names);
- void recv_get_table_objects_by_name(std::vector<Table> & _return);
- void get_table_req(GetTableResult& _return, const GetTableRequest& req);
- void send_get_table_req(const GetTableRequest& req);
- void recv_get_table_req(GetTableResult& _return);
- 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_table_names_by_filter(std::vector<std::string> & _return, const std::string& dbname, const std::string& filter, const int16_t max_tables);
- void send_get_table_names_by_filter(const std::string& dbname, const std::string& filter, const int16_t max_tables);
- void recv_get_table_names_by_filter(std::vector<std::string> & _return);
- void alter_table(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl);
- void send_alter_table(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl);
- void recv_alter_table();
- void alter_table_with_environment_context(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl, const EnvironmentContext& environment_context);
- void send_alter_table_with_environment_context(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl, const EnvironmentContext& environment_context);
- void recv_alter_table_with_environment_context();
- void alter_table_with_cascade(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl, const bool cascade);
- void send_alter_table_with_cascade(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl, const bool cascade);
- void recv_alter_table_with_cascade();
- void add_partition(Partition& _return, const Partition& new_part);
- void send_add_partition(const Partition& new_part);
- void recv_add_partition(Partition& _return);
- void add_partition_with_environment_context(Partition& _return, const Partition& new_part, const EnvironmentContext& environment_context);
- void send_add_partition_with_environment_context(const Partition& new_part, const EnvironmentContext& environment_context);
- void recv_add_partition_with_environment_context(Partition& _return);
- int32_t add_partitions(const std::vector<Partition> & new_parts);
- void send_add_partitions(const std::vector<Partition> & new_parts);
- int32_t recv_add_partitions();
- int32_t add_partitions_pspec(const std::vector<PartitionSpec> & new_parts);
- void send_add_partitions_pspec(const std::vector<PartitionSpec> & new_parts);
- int32_t recv_add_partitions_pspec();
- void append_partition(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals);
- void send_append_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals);
- void recv_append_partition(Partition& _return);
- void add_partitions_req(AddPartitionsResult& _return, const AddPartitionsRequest& request);
- void send_add_partitions_req(const AddPartitionsRequest& request);
- void recv_add_partitions_req(AddPartitionsResult& _return);
- void append_partition_with_environment_context(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const EnvironmentContext& environment_context);
- void send_append_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const EnvironmentContext& environment_context);
- void recv_append_partition_with_environment_context(Partition& _return);
- void append_partition_by_name(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::string& part_name);
- void send_append_partition_by_name(const std::string& db_name, const std::string& tbl_name, const std::string& part_name);
- void recv_append_partition_by_name(Partition& _return);
- void append_partition_by_name_with_environment_context(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const EnvironmentContext& environment_context);
- void send_append_partition_by_name_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const EnvironmentContext& environment_context);
- void recv_append_partition_by_name_with_environment_context(Partition& _return);
- bool drop_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const bool deleteData);
- void send_drop_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const bool deleteData);
- bool recv_drop_partition();
- bool drop_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const bool deleteData, const EnvironmentContext& environment_context);
- void send_drop_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const bool deleteData, const EnvironmentContext& environment_context);
- bool recv_drop_partition_with_environment_context();
- bool drop_partition_by_name(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const bool deleteData);
- void send_drop_partition_by_name(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const bool deleteData);
- bool recv_drop_partition_by_name();
- bool drop_partition_by_name_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const bool deleteData, const EnvironmentContext& environment_context);
- void send_drop_partition_by_name_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const bool deleteData, const EnvironmentContext& environment_context);
- bool recv_drop_partition_by_name_with_environment_context();
- void drop_partitions_req(DropPartitionsResult& _return, const DropPartitionsRequest& req);
- void send_drop_partitions_req(const DropPartitionsRequest& req);
- void recv_drop_partitions_req(DropPartitionsResult& _return);
- void get_partition(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals);
- void send_get_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals);
- void recv_get_partition(Partition& _return);
- void exchange_partition(Partition& _return, const std::map<std::string, std::string> & partitionSpecs, const std::string& source_db, const std::string& source_table_name, const std::string& dest_db, const std::string& dest_table_name);
- void send_exchange_partition(const std::map<std::string, std::string> & partitionSpecs, const std::string& source_db, const std::string& source_table_name, const std::string& dest_db, const std::string& dest_table_name);
- void recv_exchange_partition(Partition& _return);
- void exchange_partitions(std::vector<Partition> & _return, const std::map<std::string, std::string> & partitionSpecs, const std::string& source_db, const std::string& source_table_name, const std::string& dest_db, const std::string& dest_table_name);
- void send_exchange_partitions(const std::map<std::string, std::string> & partitionSpecs, const std::string& source_db, const std::string& source_table_name, const std::string& dest_db, const std::string& dest_table_name);
- void recv_exchange_partitions(std::vector<Partition> & _return);
- void get_partition_with_auth(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const std::string& user_name, const std::vector<std::string> & group_names);
- void send_get_partition_with_auth(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const std::string& user_name, const std::vector<std::string> & group_names);
- void recv_get_partition_with_auth(Partition& _return);
- void get_partition_by_name(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::string& part_name);
- void send_get_partition_by_name(const std::string& db_name, const std::string& tbl_name, const std::string& part_name);
- void recv_get_partition_by_name(Partition& _return);
- void get_partitions(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const int16_t max_parts);
- void send_get_partitions(const std::string& db_name, const std::string& tbl_name, const int16_t max_parts);
- void recv_get_partitions(std::vector<Partition> & _return);
- void get_partitions_with_auth(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const int16_t max_parts, const std::string& user_name, const std::vector<std::string> & group_names);
- void send_get_partitions_with_auth(const std::string& db_name, const std::string& tbl_name, const int16_t max_parts, const std::string& user_name, const std::vector<std::string> & group_names);
- void recv_get_partitions_with_auth(std::vector<Partition> & _return);
- void get_partitions_pspec(std::vector<PartitionSpec> & _return, const std::string& db_name, const std::string& tbl_name, const int32_t max_parts);
- void send_get_partitions_pspec(const std::string& db_name, const std::string& tbl_name, const int32_t max_parts);
- void recv_get_partitions_pspec(std::vector<PartitionSpec> & _return);
- void get_partition_names(std::vector<std::string> & _return, const std::string& db_name, const std::string& tbl_name, const int16_t max_parts);
- void send_get_partition_names(const std::string& db_name, const std::string& tbl_name, const int16_t max_parts);
- void recv_get_partition_names(std::vector<std::string> & _return);
- void get_partition_values(PartitionValuesResponse& _return, const PartitionValuesRequest& request);
- void send_get_partition_values(const PartitionValuesRequest& request);
- void recv_get_partition_values(PartitionValuesResponse& _return);
- void get_partitions_ps(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts);
- void send_get_partitions_ps(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts);
- void recv_get_partitions_ps(std::vector<Partition> & _return);
- void get_partitions_ps_with_auth(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts, const std::string& user_name, const std::vector<std::string> & group_names);
- void send_get_partitions_ps_with_auth(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts, const std::string& user_name, const std::vector<std::string> & group_names);
- void recv_get_partitions_ps_with_auth(std::vector<Partition> & _return);
- void get_partition_names_ps(std::vector<std::string> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts);
- void send_get_partition_names_ps(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts);
- void recv_get_partition_names_ps(std::vector<std::string> & _return);
- void get_partitions_by_filter(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int16_t max_parts);
- void send_get_partitions_by_filter(const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int16_t max_parts);
- void recv_get_partitions_by_filter(std::vector<Partition> & _return);
- void get_part_specs_by_filter(std::vector<PartitionSpec> & _return, const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int32_t max_parts);
- void send_get_part_specs_by_filter(const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int32_t max_parts);
- void recv_get_part_specs_by_filter(std::vector<PartitionSpec> & _return);
- void get_partitions_by_expr(PartitionsByExprResult& _return, const PartitionsByExprRequest& req);
- void send_get_partitions_by_expr(const PartitionsByExprRequest& req);
- void recv_get_partitions_by_expr(PartitionsByExprResult& _return);
- int32_t get_num_partitions_by_filter(const std::string& db_name, const std::string& tbl_name, const std::string& filter);
- void send_get_num_partitions_by_filter(const std::string& db_name, const std::string& tbl_name, const std::string& filter);
- int32_t recv_get_num_partitions_by_filter();
- 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);
- void send_get_partitions_by_names(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & names);
- void recv_get_partitions_by_names(std::vector<Partition> & _return);
- void alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part);
- void send_alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part);
- void recv_alter_partition();
- 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(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_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();
+ bool operator != (const ThriftHiveMetastore_create_wm_pool_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_create_wm_pool_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_create_wm_pool_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_create_wm_pool_pargs() throw();
+ const WMCreatePoolRequest* request;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_create_wm_pool_result__isset {
+ _ThriftHiveMetastore_create_wm_pool_result__isset() : success(false), o1(false), o2(false), o3(false), o4(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+ bool o4 :1;
+} _ThriftHiveMetastore_create_wm_pool_result__isset;
+
+class ThriftHiveMetastore_create_wm_pool_result {
+ public:
+
+ ThriftHiveMetastore_create_wm_pool_result(const ThriftHiveMetastore_create_wm_pool_result&);
+ ThriftHiveMetastore_create_wm_pool_result& operator=(const ThriftHiveMetastore_create_wm_pool_result&);
+ ThriftHiveMetastore_create_wm_pool_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_create_wm_pool_result() throw();
+ WMCreatePoolResponse success;
+ AlreadyExistsException o1;
+ NoSuchObjectException o2;
+ InvalidObjectException o3;
+ MetaException o4;
+
+ _ThriftHiveMetastore_create_wm_pool_result__isset __isset;
+
+ void __set_success(const WMCreatePoolResponse& val);
+
+ void __set_o1(const AlreadyExistsException& val);
+
+ void __set_o2(const NoSuchObjectException& val);
+
+ void __set_o3(const InvalidObjectException& val);
+
+ void __set_o4(const MetaException& val);
+
+ bool operator == (const ThriftHiveMetastore_create_wm_pool_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(o1 == rhs.o1))
+ return false;
+ if (!(o2 == rhs.o2))
+ return false;
+ if (!(o3 == rhs.o3))
+ return false;
+ if (!(o4 == rhs.o4))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_create_wm_pool_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_create_wm_pool_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_create_wm_pool_presult__isset {
+ _ThriftHiveMetastore_create_wm_pool_presult__isset() : success(false), o1(false), o2(false), o3(false), o4(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+ bool o4 :1;
+} _ThriftHiveMetastore_create_wm_pool_presult__isset;
+
+class ThriftHiveMetastore_create_wm_pool_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_create_wm_pool_presult() throw();
+ WMCreatePoolResponse* success;
+ AlreadyExistsException o1;
+ NoSuchObjectException o2;
+ InvalidObjectException o3;
+ MetaException o4;
+
+ _ThriftHiveMetastore_create_wm_pool_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+typedef struct _ThriftHiveMetastore_alter_wm_pool_args__isset {
+ _ThriftHiveMetastore_alter_wm_pool_args__isset() : request(false) {}
+ bool request :1;
+} _ThriftHiveMetastore_alter_wm_pool_args__isset;
+
+class ThriftHiveMetastore_alter_wm_pool_args {
+ public:
+
+ ThriftHiveMetastore_alter_wm_pool_args(const ThriftHiveMetastore_alter_wm_pool_args&);
+ ThriftHiveMetastore_alter_wm_pool_args& operator=(const ThriftHiveMetastore_alter_wm_pool_args&);
+ ThriftHiveMetastore_alter_wm_pool_args() {
+ }
+
+ virtual ~ThriftHiveMetastore_alter_wm_pool_args() throw();
+ WMAlterPoolRequest request;
+
+ _ThriftHiveMetastore_alter_wm_pool_args__isset __isset;
+
+ void __set_request(const WMAlterPoolRequest& val);
+
+ bool operator == (const ThriftHiveMetastore_alter_wm_pool_args & rhs) const
+ {
+ if (!(request == rhs.request))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_alter_wm_pool_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_alter_wm_pool_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_alter_wm_pool_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_alter_wm_pool_pargs() throw();
+ const WMAlterPoolRequest* request;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_alter_wm_pool_result__isset {
+ _ThriftHiveMetastore_alter_wm_pool_result__isset() : success(false), o1(false), o2(false), o3(false), o4(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+ bool o4 :1;
+} _ThriftHiveMetastore_alter_wm_pool_result__isset;
+
+class ThriftHiveMetastore_alter_wm_pool_result {
+ public:
+
+ ThriftHiveMetastore_alter_wm_pool_result(const ThriftHiveMetastore_alter_wm_pool_result&);
+ ThriftHiveMetastore_alter_wm_pool_result& operator=(const ThriftHiveMetastore_alter_wm_pool_result&);
+ ThriftHiveMetastore_alter_wm_pool_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_alter_wm_pool_result() throw();
+ WMAlterPoolResponse success;
+ AlreadyExistsException o1;
+ NoSuchObjectException o2;
+ InvalidObjectException o3;
+ MetaException o4;
+
+ _ThriftHiveMetastore_alter_wm_pool_result__isset __isset;
+
+ void __set_success(const WMAlterPoolResponse& val);
+
+ void __set_o1(const AlreadyExistsException& val);
+
+ void __set_o2(const NoSuchObjectException& val);
+
+ void __set_o3(const InvalidObjectException& val);
+
+ void __set_o4(const MetaException& val);
+
+ bool operator == (const ThriftHiveMetastore_alter_wm_pool_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(o1 == rhs.o1))
+ return false;
+ if (!(o2 == rhs.o2))
+ return false;
+ if (!(o3 == rhs.o3))
+ return false;
+ if (!(o4 == rhs.o4))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_alter_wm_pool_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_alter_wm_pool_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_alter_wm_pool_presult__isset {
+ _ThriftHiveMetastore_alter_wm_pool_presult__isset() : success(false), o1(false), o2(false), o3(false), o4(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+ bool o4 :1;
+} _ThriftHiveMetastore_alter_wm_pool_presult__isset;
+
+class ThriftHiveMetastore_alter_wm_pool_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_alter_wm_pool_presult() throw();
+ WMAlterPoolResponse* success;
+ AlreadyExistsException o1;
+ NoSuchObjectException o2;
+ InvalidObjectException o3;
+ MetaException o4;
+
+ _ThriftHiveMetastore_alter_wm_pool_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+typedef struct _ThriftHiveMetastore_drop_wm_pool_args__isset {
+ _ThriftHiveMetastore_drop_wm_pool_args__isset() : request(false) {}
+ bool request :1;
+} _ThriftHiveMetastore_drop_wm_pool_args__isset;
+
+class ThriftHiveMetastore_drop_wm_pool_args {
+ public:
+
+ ThriftHiveMetastore_drop_wm_pool_args(const ThriftHiveMetastore_drop_wm_pool_args&);
+ ThriftHiveMetastore_drop_wm_pool_args& operator=(const ThriftHiveMetastore_drop_wm_pool_args&);
+ ThriftHiveMetastore_drop_wm_pool_args() {
+ }
+
+ virtual ~ThriftHiveMetastore_drop_wm_pool_args() throw();
+ WMDropPoolRequest request;
+
+ _ThriftHiveMetastore_drop_wm_pool_args__isset __isset;
+
+ void __set_request(const WMDropPoolRequest& val);
+
+ bool operator == (const ThriftHiveMetastore_drop_wm_pool_args & rhs) const
+ {
+ if (!(request == rhs.request))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_drop_wm_pool_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_drop_wm_pool_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_drop_wm_pool_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_drop_wm_pool_pargs() throw();
+ const WMDropPoolRequest* request;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_drop_wm_pool_result__isset {
+ _ThriftHiveMetastore_drop_wm_pool_result__isset() : success(false), o1(false), o2(false), o3(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+} _ThriftHiveMetastore_drop_wm_pool_result__isset;
+
+class ThriftHiveMetastore_drop_wm_pool_result {
+ public:
+
+ ThriftHiveMetastore_drop_wm_pool_result(const ThriftHiveMetastore_drop_wm_pool_result&);
+ ThriftHiveMetastore_drop_wm_pool_result& operator=(const ThriftHiveMetastore_drop_wm_pool_result&);
+ ThriftHiveMetastore_drop_wm_pool_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_drop_wm_pool_result() throw();
+ WMDropPoolResponse success;
+ NoSuchObjectException o1;
+ InvalidOperationException o2;
+ MetaException o3;
+
+ _ThriftHiveMetastore_drop_wm_pool_result__isset __isset;
+
+ void __set_success(const WMDropPoolResponse& val);
+
+ void __set_o1(const NoSuchObjectException& val);
+
+ void __set_o2(const InvalidOperationException& val);
+
+ void __set_o3(const MetaException& val);
+
+ bool operator == (const ThriftHiveMetastore_drop_wm_pool_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(o1 == rhs.o1))
+ return false;
+ if (!(o2 == rhs.o2))
+ return false;
+ if (!(o3 == rhs.o3))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_drop_wm_pool_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_drop_wm_pool_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_drop_wm_pool_presult__isset {
+ _ThriftHiveMetastore_drop_wm_pool_presult__isset() : success(false), o1(false), o2(false), o3(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+} _ThriftHiveMetastore_drop_wm_pool_presult__isset;
+
+class ThriftHiveMetastore_drop_wm_pool_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_drop_wm_pool_presult() throw();
+ WMDropPoolResponse* success;
+ NoSuchObjectException o1;
+ InvalidOperationException o2;
+ MetaException o3;
+
+ _ThriftHiveMetastore_drop_wm_pool_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+typedef struct _ThriftHiveMetastore_create_or_update_wm_mapping_args__isset {
+ _ThriftHiveMetastore_create_or_update_wm_mapping_args__isset() : request(false) {}
+ bool request :1;
+} _ThriftHiveMetastore_create_or_update_wm_mapping_args__isset;
+
+class ThriftHiveMetastore_create_or_update_wm_mapping_args {
+ public:
+
+ ThriftHiveMetastore_create_or_update_wm_mapping_args(const ThriftHiveMetastore_create_or_update_wm_mapping_args&);
+ ThriftHiveMetastore_create_or_update_wm_mapping_args& operator=(const ThriftHiveMetastore_create_or_update_wm_mapping_args&);
+ ThriftHiveMetastore_create_or_update_wm_mapping_args() {
+ }
+
+ virtual ~ThriftHiveMetastore_create_or_update_wm_mapping_args() throw();
+ WMCreateOrUpdateMappingRequest request;
+
+ _ThriftHiveMetastore_create_or_update_wm_mapping_args__isset __isset;
+
+ void __set_request(const WMCreateOrUpdateMappingRequest& val);
+
+ bool operator == (const ThriftHiveMetastore_create_or_update_wm_mapping_args & rhs) const
+ {
+ if (!(request == rhs.request))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_create_or_update_wm_mapping_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_create_or_update_wm_mapping_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_create_or_update_wm_mapping_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_create_or_update_wm_mapping_pargs() throw();
+ const WMCreateOrUpdateMappingRequest* request;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_create_or_update_wm_mapping_result__isset {
+ _ThriftHiveMetastore_create_or_update_wm_mapping_result__isset() : success(false), o1(false), o2(false), o3(false), o4(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+ bool o4 :1;
+} _ThriftHiveMetastore_create_or_update_wm_mapping_result__isset;
+
+class ThriftHiveMetastore_create_or_update_wm_mapping_result {
+ public:
+
+ ThriftHiveMetastore_create_or_update_wm_mapping_result(const ThriftHiveMetastore_create_or_update_wm_mapping_result&);
+ ThriftHiveMetastore_create_or_update_wm_mapping_result& operator=(const ThriftHiveMetastore_create_or_update_wm_mapping_result&);
+ ThriftHiveMetastore_create_or_update_wm_mapping_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_create_or_update_wm_mapping_result() throw();
+ WMCreateOrUpdateMappingResponse success;
+ AlreadyExistsException o1;
+ NoSuchObjectException o2;
+ InvalidObjectException o3;
+ MetaException o4;
+
+ _ThriftHiveMetastore_create_or_update_wm_mapping_result__isset __isset;
+
+ void __set_success(const WMCreateOrUpdateMappingResponse& val);
+
+ void __set_o1(const AlreadyExistsException& val);
+
+ void __set_o2(const NoSuchObjectException& val);
+
+ void __set_o3(const InvalidObjectException& val);
+
+ void __set_o4(const MetaException& val);
+
+ bool operator == (const ThriftHiveMetastore_create_or_update_wm_mapping_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(o1 == rhs.o1))
+ return false;
+ if (!(o2 == rhs.o2))
+ return false;
+ if (!(o3 == rhs.o3))
+ return false;
+ if (!(o4 == rhs.o4))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_create_or_update_wm_mapping_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_create_or_update_wm_mapping_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_create_or_update_wm_mapping_presult__isset {
+ _ThriftHiveMetastore_create_or_update_wm_mapping_presult__isset() : success(false), o1(false), o2(false), o3(false), o4(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+ bool o4 :1;
+} _ThriftHiveMetastore_create_or_update_wm_mapping_presult__isset;
+
+class ThriftHiveMetastore_create_or_update_wm_mapping_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_create_or_update_wm_mapping_presult() throw();
+ WMCreateOrUpdateMappingResponse* success;
+ AlreadyExistsException o1;
+ NoSuchObjectException o2;
+ InvalidObjectException o3;
+ MetaException o4;
+
+ _ThriftHiveMetastore_create_or_update_wm_mapping_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+typedef struct _ThriftHiveMetastore_drop_wm_mapping_args__isset {
+ _ThriftHiveMetastore_drop_wm_mapping_args__isset() : request(false) {}
+ bool request :1;
+} _ThriftHiveMetastore_drop_wm_mapping_args__isset;
+
+class ThriftHiveMetastore_drop_wm_mapping_args {
+ public:
+
+ ThriftHiveMetastore_drop_wm_mapping_args(const ThriftHiveMetastore_drop_wm_mapping_args&);
+ ThriftHiveMetastore_drop_wm_mapping_args& operator=(const ThriftHiveMetastore_drop_wm_mapping_args&);
+ ThriftHiveMetastore_drop_wm_mapping_args() {
+ }
+
+ virtual ~ThriftHiveMetastore_drop_wm_mapping_args() throw();
+ WMDropMappingRequest request;
+
+ _ThriftHiveMetastore_drop_wm_mapping_args__isset __isset;
+
+ void __set_request(const WMDropMappingRequest& val);
+
+ bool operator == (const ThriftHiveMetastore_drop_wm_mapping_args & rhs) const
+ {
+ if (!(request == rhs.request))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_drop_wm_mapping_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_drop_wm_mapping_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_drop_wm_mapping_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_drop_wm_mapping_pargs() throw();
+ const WMDropMappingRequest* request;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_drop_wm_mapping_result__isset {
+ _ThriftHiveMetastore_drop_wm_mapping_result__isset() : success(false), o1(false), o2(false), o3(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+} _ThriftHiveMetastore_drop_wm_mapping_result__isset;
+
+class ThriftHiveMetastore_drop_wm_mapping_result {
+ public:
+
+ ThriftHiveMetastore_drop_wm_mapping_result(const ThriftHiveMetastore_drop_wm_mapping_result&);
+ ThriftHiveMetastore_drop_wm_mapping_result& operator=(const ThriftHiveMetastore_drop_wm_mapping_result&);
+ ThriftHiveMetastore_drop_wm_mapping_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_drop_wm_mapping_result() throw();
+ WMDropMappingResponse success;
+ NoSuchObjectException o1;
+ InvalidOperationException o2;
+ MetaException o3;
+
+ _ThriftHiveMetastore_drop_wm_mapping_result__isset __isset;
+
+ void __set_success(const WMDropMappingResponse& val);
+
+ void __set_o1(const NoSuchObjectException& val);
+
+ void __set_o2(const InvalidOperationException& val);
+
+ void __set_o3(const MetaException& val);
+
+ bool operator == (const ThriftHiveMetastore_drop_wm_mapping_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(o1 == rhs.o1))
+ return false;
+ if (!(o2 == rhs.o2))
+ return false;
+ if (!(o3 == rhs.o3))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_drop_wm_mapping_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_drop_wm_mapping_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_drop_wm_mapping_presult__isset {
+ _ThriftHiveMetastore_drop_wm_mapping_presult__isset() : success(false), o1(false), o2(false), o3(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+} _ThriftHiveMetastore_drop_wm_mapping_presult__isset;
+
+class ThriftHiveMetastore_drop_wm_mapping_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_drop_wm_mapping_presult() throw();
+ WMDropMappingResponse* success;
+ NoSuchObjectException o1;
+ InvalidOperationException o2;
+ MetaException o3;
+
+ _ThriftHiveMetastore_drop_wm_mapping_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+typedef struct _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args__isset {
+ _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args__isset() : request(false) {}
+ bool request :1;
+} _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args__isset;
+
+class ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args {
+ public:
+
+ ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args(const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args&);
+ ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args& operator=(const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args&);
+ ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args() {
+ }
+
+ virtual ~ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args() throw();
+ WMCreateOrDropTriggerToPoolMappingRequest request;
+
+ _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args__isset __isset;
+
+ void __set_request(const WMCreateOrDropTriggerToPoolMappingRequest& val);
+
+ bool operator == (const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args & rhs) const
+ {
+ if (!(request == rhs.request))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_args & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+
+class ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_pargs {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_pargs() throw();
+ const WMCreateOrDropTriggerToPoolMappingRequest* request;
+
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result__isset {
+ _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result__isset() : success(false), o1(false), o2(false), o3(false), o4(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+ bool o4 :1;
+} _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result__isset;
+
+class ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result {
+ public:
+
+ ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result(const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result&);
+ ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result& operator=(const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result&);
+ ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result() {
+ }
+
+ virtual ~ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result() throw();
+ WMCreateOrDropTriggerToPoolMappingResponse success;
+ AlreadyExistsException o1;
+ NoSuchObjectException o2;
+ InvalidObjectException o3;
+ MetaException o4;
+
+ _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result__isset __isset;
+
+ void __set_success(const WMCreateOrDropTriggerToPoolMappingResponse& val);
+
+ void __set_o1(const AlreadyExistsException& val);
+
+ void __set_o2(const NoSuchObjectException& val);
+
+ void __set_o3(const InvalidObjectException& val);
+
+ void __set_o4(const MetaException& val);
+
+ bool operator == (const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result & rhs) const
+ {
+ if (!(success == rhs.success))
+ return false;
+ if (!(o1 == rhs.o1))
+ return false;
+ if (!(o2 == rhs.o2))
+ return false;
+ if (!(o3 == rhs.o3))
+ return false;
+ if (!(o4 == rhs.o4))
+ return false;
+ return true;
+ }
+ bool operator != (const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result &rhs) const {
+ return !(*this == rhs);
+ }
+
+ bool operator < (const ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_result & ) const;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+ uint32_t write(::apache::thrift::protocol::TProtocol* oprot) const;
+
+};
+
+typedef struct _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_presult__isset {
+ _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_presult__isset() : success(false), o1(false), o2(false), o3(false), o4(false) {}
+ bool success :1;
+ bool o1 :1;
+ bool o2 :1;
+ bool o3 :1;
+ bool o4 :1;
+} _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_presult__isset;
+
+class ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_presult {
+ public:
+
+
+ virtual ~ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_presult() throw();
+ WMCreateOrDropTriggerToPoolMappingResponse* success;
+ AlreadyExistsException o1;
+ NoSuchObjectException o2;
+ InvalidObjectException o3;
+ MetaException o4;
+
+ _ThriftHiveMetastore_create_or_drop_wm_trigger_to_pool_mapping_presult__isset __isset;
+
+ uint32_t read(::apache::thrift::protocol::TProtocol* iprot);
+
+};
+
+class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public ::facebook::fb303::FacebookServiceClient {
+ public:
+ ThriftHiveMetastoreClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> prot) :
+ ::facebook::fb303::FacebookServiceClient(prot, prot) {}
+ ThriftHiveMetastoreClient(boost::shared_ptr< ::apache::thrift::protocol::TProtocol> iprot, boost::shared_ptr< ::apache::thrift::protocol::TProtocol> oprot) : ::facebook::fb303::FacebookServiceClient(iprot, oprot) {}
+ boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getInputProtocol() {
+ return piprot_;
+ }
+ boost::shared_ptr< ::apache::thrift::protocol::TProtocol> getOutputProtocol() {
+ return poprot_;
+ }
+ void getMetaConf(std::string& _return, const std::string& key);
+ void send_getMetaConf(const std::string& key);
+ void recv_getMetaConf(std::string& _return);
+ void setMetaConf(const std::string& key, const std::string& value);
+ void send_setMetaConf(const std::string& key, const std::string& value);
+ void recv_setMetaConf();
+ void create_database(const Database& database);
+ void send_create_database(const Database& database);
+ void recv_create_database();
+ void get_database(Database& _return, const std::string& name);
+ void send_get_database(const std::string& name);
+ void recv_get_database(Database& _return);
+ void drop_database(const std::string& name, const bool deleteData, const bool cascade);
+ void send_drop_database(const std::string& name, const bool deleteData, const bool cascade);
+ void recv_drop_database();
+ void get_databases(std::vector<std::string> & _return, const std::string& pattern);
+ void send_get_databases(const std::string& pattern);
+ void recv_get_databases(std::vector<std::string> & _return);
+ void get_all_databases(std::vector<std::string> & _return);
+ void send_get_all_databases();
+ void recv_get_all_databases(std::vector<std::string> & _return);
+ void alter_database(const std::string& dbname, const Database& db);
+ void send_alter_database(const std::string& dbname, const Database& db);
+ void recv_alter_database();
+ void get_type(Type& _return, const std::string& name);
+ void send_get_type(const std::string& name);
+ void recv_get_type(Type& _return);
+ bool create_type(const Type& type);
+ void send_create_type(const Type& type);
+ bool recv_create_type();
+ bool drop_type(const std::string& type);
+ void send_drop_type(const std::string& type);
+ bool recv_drop_type();
+ void get_type_all(std::map<std::string, Type> & _return, const std::string& name);
+ void send_get_type_all(const std::string& name);
+ void recv_get_type_all(std::map<std::string, Type> & _return);
+ void get_fields(std::vector<FieldSchema> & _return, const std::string& db_name, const std::string& table_name);
+ void send_get_fields(const std::string& db_name, const std::string& table_name);
+ void recv_get_fields(std::vector<FieldSchema> & _return);
+ void get_fields_with_environment_context(std::vector<FieldSchema> & _return, const std::string& db_name, const std::string& table_name, const EnvironmentContext& environment_context);
+ void send_get_fields_with_environment_context(const std::string& db_name, const std::string& table_name, const EnvironmentContext& environment_context);
+ void recv_get_fields_with_environment_context(std::vector<FieldSchema> & _return);
+ void get_schema(std::vector<FieldSchema> & _return, const std::string& db_name, const std::string& table_name);
+ void send_get_schema(const std::string& db_name, const std::string& table_name);
+ void recv_get_schema(std::vector<FieldSchema> & _return);
+ void get_schema_with_environment_context(std::vector<FieldSchema> & _return, const std::string& db_name, const std::string& table_name, const EnvironmentContext& environment_context);
+ void send_get_schema_with_environment_context(const std::string& db_name, const std::string& table_name, const EnvironmentContext& environment_context);
+ void recv_get_schema_with_environment_context(std::vector<FieldSchema> & _return);
+ void create_table(const Table& tbl);
+ void send_create_table(const Table& tbl);
+ void recv_create_table();
+ void create_table_with_environment_context(const Table& tbl, const EnvironmentContext& environment_context);
+ void send_create_table_with_environment_context(const Table& tbl, const EnvironmentContext& environment_context);
+ void recv_create_table_with_environment_context();
+ void create_table_with_constraints(const Table& tbl, const std::vector<SQLPrimaryKey> & primaryKeys, const std::vector<SQLForeignKey> & foreignKeys, const std::vector<SQLUniqueConstraint> & uniqueConstraints, const std::vector<SQLNotNullConstraint> & notNullConstraints);
+ void send_create_table_with_constraints(const Table& tbl, const std::vector<SQLPrimaryKey> & primaryKeys, const std::vector<SQLForeignKey> & foreignKeys, const std::vector<SQLUniqueConstraint> & uniqueConstraints, const std::vector<SQLNotNullConstraint> & notNullConstraints);
+ void recv_create_table_with_constraints();
+ void drop_constraint(const DropConstraintRequest& req);
+ void send_drop_constraint(const DropConstraintRequest& req);
+ void recv_drop_constraint();
+ void add_primary_key(const AddPrimaryKeyRequest& req);
+ void send_add_primary_key(const AddPrimaryKeyRequest& req);
+ void recv_add_primary_key();
+ void add_foreign_key(const AddForeignKeyRequest& req);
+ void send_add_foreign_key(const AddForeignKeyRequest& req);
+ void recv_add_foreign_key();
+ void add_unique_constraint(const AddUniqueConstraintRequest& req);
+ void send_add_unique_constraint(const AddUniqueConstraintRequest& req);
+ void recv_add_unique_constraint();
+ void add_not_null_constraint(const AddNotNullConstraintRequest& req);
+ void send_add_not_null_constraint(const AddNotNullConstraintRequest& req);
+ void recv_add_not_null_constraint();
+ void drop_table(const std::string& dbname, const std::string& name, const bool deleteData);
+ void send_drop_table(const std::string& dbname, const std::string& name, const bool deleteData);
+ void recv_drop_table();
+ 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);
+ void get_tables_by_type(std::vector<std::string> & _return, const std::string& db_name, const std::string& pattern, const std::string& tableType);
+ void send_get_tables_by_type(const std::string& db_name, const std::string& pattern, const std::string& tableType);
+ void recv_get_tables_by_type(std::vector<std::string> & _return);
+ 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);
+ void send_get_table_meta(const std::string& db_patterns, const std::string& tbl_patterns, const std::vector<std::string> & tbl_types);
+ void recv_get_table_meta(std::vector<TableMeta> & _return);
+ void get_all_tables(std::vector<std::string> & _return, const std::string& db_name);
+ void send_get_all_tables(const std::string& db_name);
+ void recv_get_all_tables(std::vector<std::string> & _return);
+ void get_table(Table& _return, const std::string& dbname, const std::string& tbl_name);
+ void send_get_table(const std::string& dbname, const std::string& tbl_name);
+ void recv_get_table(Table& _return);
+ void get_table_objects_by_name(std::vector<Table> & _return, const std::string& dbname, const std::vector<std::string> & tbl_names);
+ void send_get_table_objects_by_name(const std::string& dbname, const std::vector<std::string> & tbl_names);
+ void recv_get_table_objects_by_name(std::vector<Table> & _return);
+ void get_table_req(GetTableResult& _return, const GetTableRequest& req);
+ void send_get_table_req(const GetTableRequest& req);
+ void recv_get_table_req(GetTableResult& _return);
+ 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_table_names_by_filter(std::vector<std::string> & _return, const std::string& dbname, const std::string& filter, const int16_t max_tables);
+ void send_get_table_names_by_filter(const std::string& dbname, const std::string& filter, const int16_t max_tables);
+ void recv_get_table_names_by_filter(std::vector<std::string> & _return);
+ void alter_table(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl);
+ void send_alter_table(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl);
+ void recv_alter_table();
+ void alter_table_with_environment_context(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl, const EnvironmentContext& environment_context);
+ void send_alter_table_with_environment_context(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl, const EnvironmentContext& environment_context);
+ void recv_alter_table_with_environment_context();
+ void alter_table_with_cascade(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl, const bool cascade);
+ void send_alter_table_with_cascade(const std::string& dbname, const std::string& tbl_name, const Table& new_tbl, const bool cascade);
+ void recv_alter_table_with_cascade();
+ void add_partition(Partition& _return, const Partition& new_part);
+ void send_add_partition(const Partition& new_part);
+ void recv_add_partition(Partition& _return);
+ void add_partition_with_environment_context(Partition& _return, const Partition& new_part, const EnvironmentContext& environment_context);
+ void send_add_partition_with_environment_context(const Partition& new_part, const EnvironmentContext& environment_context);
+ void recv_add_partition_with_environment_context(Partition& _return);
+ int32_t add_partitions(const std::vector<Partition> & new_parts);
+ void send_add_partitions(const std::vector<Partition> & new_parts);
+ int32_t recv_add_partitions();
+ int32_t add_partitions_pspec(const std::vector<PartitionSpec> & new_parts);
+ void send_add_partitions_pspec(const std::vector<PartitionSpec> & new_parts);
+ int32_t recv_add_partitions_pspec();
+ void append_partition(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals);
+ void send_append_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals);
+ void recv_append_partition(Partition& _return);
+ void add_partitions_req(AddPartitionsResult& _return, const AddPartitionsRequest& request);
+ void send_add_partitions_req(const AddPartitionsRequest& request);
+ void recv_add_partitions_req(AddPartitionsResult& _return);
+ void append_partition_with_environment_context(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const EnvironmentContext& environment_context);
+ void send_append_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const EnvironmentContext& environment_context);
+ void recv_append_partition_with_environment_context(Partition& _return);
+ void append_partition_by_name(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::string& part_name);
+ void send_append_partition_by_name(const std::string& db_name, const std::string& tbl_name, const std::string& part_name);
+ void recv_append_partition_by_name(Partition& _return);
+ void append_partition_by_name_with_environment_context(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const EnvironmentContext& environment_context);
+ void send_append_partition_by_name_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const EnvironmentContext& environment_context);
+ void recv_append_partition_by_name_with_environment_context(Partition& _return);
+ bool drop_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const bool deleteData);
+ void send_drop_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const bool deleteData);
+ bool recv_drop_partition();
+ bool drop_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const bool deleteData, const EnvironmentContext& environment_context);
+ void send_drop_partition_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const bool deleteData, const EnvironmentContext& environment_context);
+ bool recv_drop_partition_with_environment_context();
+ bool drop_partition_by_name(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const bool deleteData);
+ void send_drop_partition_by_name(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const bool deleteData);
+ bool recv_drop_partition_by_name();
+ bool drop_partition_by_name_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const bool deleteData, const EnvironmentContext& environment_context);
+ void send_drop_partition_by_name_with_environment_context(const std::string& db_name, const std::string& tbl_name, const std::string& part_name, const bool deleteData, const EnvironmentContext& environment_context);
+ bool recv_drop_partition_by_name_with_environment_context();
+ void drop_partitions_req(DropPartitionsResult& _return, const DropPartitionsRequest& req);
+ void send_drop_partitions_req(const DropPartitionsRequest& req);
+ void recv_drop_partitions_req(DropPartitionsResult& _return);
+ void get_partition(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals);
+ void send_get_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals);
+ void recv_get_partition(Partition& _return);
+ void exchange_partition(Partition& _return, const std::map<std::string, std::string> & partitionSpecs, const std::string& source_db, const std::string& source_table_name, const std::string& dest_db, const std::string& dest_table_name);
+ void send_exchange_partition(const std::map<std::string, std::string> & partitionSpecs, const std::string& source_db, const std::string& source_table_name, const std::string& dest_db, const std::string& dest_table_name);
+ void recv_exchange_partition(Partition& _return);
+ void exchange_partitions(std::vector<Partition> & _return, const std::map<std::string, std::string> & partitionSpecs, const std::string& source_db, const std::string& source_table_name, const std::string& dest_db, const std::string& dest_table_name);
+ void send_exchange_partitions(const std::map<std::string, std::string> & partitionSpecs, const std::string& source_db, const std::string& source_table_name, const std::string& dest_db, const std::string& dest_table_name);
+ void recv_exchange_partitions(std::vector<Partition> & _return);
+ void get_partition_with_auth(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const std::string& user_name, const std::vector<std::string> & group_names);
+ void send_get_partition_with_auth(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const std::string& user_name, const std::vector<std::string> & group_names);
+ void recv_get_partition_with_auth(Partition& _return);
+ void get_partition_by_name(Partition& _return, const std::string& db_name, const std::string& tbl_name, const std::string& part_name);
+ void send_get_partition_by_name(const std::string& db_name, const std::string& tbl_name, const std::string& part_name);
+ void recv_get_partition_by_name(Partition& _return);
+ void get_partitions(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const int16_t max_parts);
+ void send_get_partitions(const std::string& db_name, const std::string& tbl_name, const int16_t max_parts);
+ void recv_get_partitions(std::vector<Partition> & _return);
+ void get_partitions_with_auth(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const int16_t max_parts, const std::string& user_name, const std::vector<std::string> & group_names);
+ void send_get_partitions_with_auth(const std::string& db_name, const std::string& tbl_name, const int16_t max_parts, const std::string& user_name, const std::vector<std::string> & group_names);
+ void recv_get_partitions_with_auth(std::vector<Partition> & _return);
+ void get_partitions_pspec(std::vector<PartitionSpec> & _return, const std::string& db_name, const std::string& tbl_name, const int32_t max_parts);
+ void send_get_partitions_pspec(const std::string& db_name, const std::string& tbl_name, const int32_t max_parts);
+ void recv_get_partitions_pspec(std::vector<PartitionSpec> & _return);
+ void get_partition_names(std::vector<std::string> & _return, const std::string& db_name, const std::string& tbl_name, const int16_t max_parts);
+ void send_get_partition_names(const std::string& db_name, const std::string& tbl_name, const int16_t max_parts);
+ void recv_get_partition_names(std::vector<std::string> & _return);
+ void get_partition_values(PartitionValuesResponse& _return, const PartitionValuesRequest& request);
+ void send_get_partition_values(const PartitionValuesRequest& request);
+ void recv_get_partition_values(PartitionValuesResponse& _return);
+ void get_partitions_ps(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts);
+ void send_get_partitions_ps(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts);
+ void recv_get_partitions_ps(std::vector<Partition> & _return);
+ void get_partitions_ps_with_auth(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts, const std::string& user_name, const std::vector<std::string> & group_names);
+ void send_get_partitions_ps_with_auth(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts, const std::string& user_name, const std::vector<std::string> & group_names);
+ void recv_get_partitions_ps_with_auth(std::vector<Partition> & _return);
+ void get_partition_names_ps(std::vector<std::string> & _return, const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts);
+ void send_get_partition_names_ps(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const int16_t max_parts);
+ void recv_get_partition_names_ps(std::vector<std::string> & _return);
+ void get_partitions_by_filter(std::vector<Partition> & _return, const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int16_t max_parts);
+ void send_get_partitions_by_filter(const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int16_t max_parts);
+ void recv_get_partitions_by_filter(std::vector<Partition> & _return);
+ void get_part_specs_by_filter(std::vector<PartitionSpec> & _return, const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int32_t max_parts);
+ void send_get_part_specs_by_filter(const std::string& db_name, const std::string& tbl_name, const std::string& filter, const int32_t max_parts);
+ void recv_get_part_specs_by_filter(std::vector<PartitionSpec> & _return);
+ void get_partitions_by_expr(PartitionsByExprResult& _return, const PartitionsByExprRequest& req);
+ void send_get_partitions_by_expr(const PartitionsByExprRequest& req);
+ void recv_get_partitions_by_expr(PartitionsByExprResult& _return);
+ int32_t get_num_partitions_by_filter(const std::string& db_name, const std::string& tbl_name, const std::string& filter);
+ void send_get_num_partitions_by_filter(const std::string& db_name, const std::string& tbl_name, const std::string& filter);
+ int32_t recv_get_num_partitions_by_filter();
+ 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);
+ void send_get_partitions_by_names(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & names);
+ void recv_get_partitions_by_names(std::vector<Partition> & _return);
+ void alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part);
+ void send_alter_partition(const std::string& db_name, const std::string& tbl_name, const Partition& new_part);
+ void recv_alter_partition();
+ 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(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_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();
void rename_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part);
void send_rename_partition(const std::string& db_name, const std::string& tbl_name, const std::vector<std::string> & part_vals, const Partition& new_part);
void recv_rename_partition();
@@ -22611,6 +23435,24 @@ class ThriftHiveMetastoreClient : virtual public ThriftHiveMetastoreIf, public
void get_triggers_for_resourceplan(WMGetTriggersForResourePlanResponse& _return, const WMGetTriggersForResourePlanRequest& request);
void send_get_triggers_for_resourceplan(const WMGetTriggersForResourePlanRequest& request);
void recv_get_triggers_for_resourceplan(WMGetTriggersForResourePlanResponse& _return);
+ void create_wm_pool(WMCreatePoolResponse& _return, const WMCreatePoolRequest& request);
+ void send_create_wm_pool(const WMCreatePoolRequest& request);
+ void recv_create_wm_pool(WMCreatePoolResponse& _return);
+ void alter_wm_pool(WMAlterPoolResponse& _return, const WMAlterPoolRequest& request);
+ void send_alter_wm_pool(const WMAlterPoolRequest& request);
+ void recv_alter_wm_pool(WMAlterPoolResponse& _return);
+ void drop_wm_pool(WMDropPoolResponse& _return, const WMDropPoolRequest& request);
+ void send_drop_wm_pool(const WMDropPoolRequest& request);
+ void recv_drop_wm_pool(WMDropPoolResponse& _return);
+ void create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse& _return, const WMCreateOrUpdateMappingRequest& request);
+ void send_create_or_update_wm_mapping(const WMCreateOrUpdateMappingRequest& request);
+ void recv_create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse& _return);
+ void drop_wm_mapping(WMDropMappingResponse& _return, const WMDropMappingRequest& request);
+ void send_drop_wm_mapping(const WMDropMappingRequest& request);
+ void recv_drop_wm_mapping(WMDropMappingResponse& _return);
+ void create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse& _return, const WMCreateOrDropTriggerToPoolMappingRequest& request);
+ void send_create_or_drop_wm_trigger_to_pool_mapping(const WMCreateOrDropTriggerToPoolMappingRequest& request);
+ void recv_create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse& _return);
};
class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceProcessor {
@@ -22794,6 +23636,12 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP
void process_alter_wm_trigger(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_drop_wm_trigger(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
void process_get_triggers_for_resourceplan(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_create_wm_pool(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_alter_wm_pool(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_drop_wm_pool(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_create_or_update_wm_mapping(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_drop_wm_mapping(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
+ void process_create_or_drop_wm_trigger_to_pool_mapping(int32_t seqid, ::apache::thrift::protocol::TProtocol* iprot, ::apache::thrift::protocol::TProtocol* oprot, void* callContext);
public:
ThriftHiveMetastoreProcessor(boost::shared_ptr<ThriftHiveMetastoreIf> iface) :
::facebook::fb303::FacebookServiceProcessor(iface),
@@ -22971,6 +23819,12 @@ class ThriftHiveMetastoreProcessor : public ::facebook::fb303::FacebookServiceP
processMap_["alter_wm_trigger"] = &ThriftHiveMetastoreProcessor::process_alter_wm_trigger;
processMap_["drop_wm_trigger"] = &ThriftHiveMetastoreProcessor::process_drop_wm_trigger;
processMap_["get_triggers_for_resourceplan"] = &ThriftHiveMetastoreProcessor::process_get_triggers_for_resourceplan;
+ processMap_["create_wm_pool"] = &ThriftHiveMetastoreProcessor::process_create_wm_pool;
+ processMap_["alter_wm_pool"] = &ThriftHiveMetastoreProcessor::process_alter_wm_pool;
+ processMap_["drop_wm_pool"] = &ThriftHiveMetastoreProcessor::process_drop_wm_pool;
+ processMap_["create_or_update_wm_mapping"] = &ThriftHiveMetastoreProcessor::process_create_or_update_wm_mapping;
+ processMap_["drop_wm_mapping"] = &ThriftHiveMetastoreProcessor::process_drop_wm_mapping;
+ processMap_["create_or_drop_wm_trigger_to_pool_mapping"] = &ThriftHiveMetastoreProcessor::process_create_or_drop_wm_trigger_to_pool_mapping;
}
virtual ~ThriftHiveMetastoreProcessor() {}
@@ -24668,6 +25522,66 @@ class ThriftHiveMetastoreMultiface : virtual public ThriftHiveMetastoreIf, publi
return;
}
+ void create_wm_pool(WMCreatePoolResponse& _return, const WMCreatePoolRequest& request) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->create_wm_pool(_return, request);
+ }
+ ifaces_[i]->create_wm_pool(_return, request);
+ return;
+ }
+
+ void alter_wm_pool(WMAlterPoolResponse& _return, const WMAlterPoolRequest& request) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->alter_wm_pool(_return, request);
+ }
+ ifaces_[i]->alter_wm_pool(_return, request);
+ return;
+ }
+
+ void drop_wm_pool(WMDropPoolResponse& _return, const WMDropPoolRequest& request) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->drop_wm_pool(_return, request);
+ }
+ ifaces_[i]->drop_wm_pool(_return, request);
+ return;
+ }
+
+ void create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse& _return, const WMCreateOrUpdateMappingRequest& request) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->create_or_update_wm_mapping(_return, request);
+ }
+ ifaces_[i]->create_or_update_wm_mapping(_return, request);
+ return;
+ }
+
+ void drop_wm_mapping(WMDropMappingResponse& _return, const WMDropMappingRequest& request) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->drop_wm_mapping(_return, request);
+ }
+ ifaces_[i]->drop_wm_mapping(_return, request);
+ return;
+ }
+
+ void create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse& _return, const WMCreateOrDropTriggerToPoolMappingRequest& request) {
+ size_t sz = ifaces_.size();
+ size_t i = 0;
+ for (; i < (sz - 1); ++i) {
+ ifaces_[i]->create_or_drop_wm_trigger_to_pool_mapping(_return, request);
+ }
+ ifaces_[i]->create_or_drop_wm_trigger_to_pool_mapping(_return, request);
+ return;
+ }
+
};
// The 'concurrent' client is a thread safe client that correctly handles
@@ -25203,6 +26117,24 @@ class ThriftHiveMetastoreConcurrentClient : virtual public ThriftHiveMetastoreIf
void get_triggers_for_resourceplan(WMGetTriggersForResourePlanResponse& _return, const WMGetTriggersForResourePlanRequest& request);
int32_t send_get_triggers_for_resourceplan(const WMGetTriggersForResourePlanRequest& request);
void recv_get_triggers_for_resourceplan(WMGetTriggersForResourePlanResponse& _return, const int32_t seqid);
+ void create_wm_pool(WMCreatePoolResponse& _return, const WMCreatePoolRequest& request);
+ int32_t send_create_wm_pool(const WMCreatePoolRequest& request);
+ void recv_create_wm_pool(WMCreatePoolResponse& _return, const int32_t seqid);
+ void alter_wm_pool(WMAlterPoolResponse& _return, const WMAlterPoolRequest& request);
+ int32_t send_alter_wm_pool(const WMAlterPoolRequest& request);
+ void recv_alter_wm_pool(WMAlterPoolResponse& _return, const int32_t seqid);
+ void drop_wm_pool(WMDropPoolResponse& _return, const WMDropPoolRequest& request);
+ int32_t send_drop_wm_pool(const WMDropPoolRequest& request);
+ void recv_drop_wm_pool(WMDropPoolResponse& _return, const int32_t seqid);
+ void create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse& _return, const WMCreateOrUpdateMappingRequest& request);
+ int32_t send_create_or_update_wm_mapping(const WMCreateOrUpdateMappingRequest& request);
+ void recv_create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse& _return, const int32_t seqid);
+ void drop_wm_mapping(WMDropMappingResponse& _return, const WMDropMappingRequest& request);
+ int32_t send_drop_wm_mapping(const WMDropMappingRequest& request);
+ void recv_drop_wm_mapping(WMDropMappingResponse& _return, const int32_t seqid);
+ void create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse& _return, const WMCreateOrDropTriggerToPoolMappingRequest& request);
+ int32_t send_create_or_drop_wm_trigger_to_pool_mapping(const WMCreateOrDropTriggerToPoolMappingRequest& request);
+ void recv_create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse& _return, const int32_t seqid);
};
#ifdef _WIN32
http://git-wip-us.apache.org/repos/asf/hive/blob/44ef5991/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 2aa3954..bf4bd7a 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
@@ -887,6 +887,36 @@ class ThriftHiveMetastoreHandler : virtual public ThriftHiveMetastoreIf {
printf("get_triggers_for_resourceplan\n");
}
+ void create_wm_pool(WMCreatePoolResponse& _return, const WMCreatePoolRequest& request) {
+ // Your implementation goes here
+ printf("create_wm_pool\n");
+ }
+
+ void alter_wm_pool(WMAlterPoolResponse& _return, const WMAlterPoolRequest& request) {
+ // Your implementation goes here
+ printf("alter_wm_pool\n");
+ }
+
+ void drop_wm_pool(WMDropPoolResponse& _return, const WMDropPoolRequest& request) {
+ // Your implementation goes here
+ printf("drop_wm_pool\n");
+ }
+
+ void create_or_update_wm_mapping(WMCreateOrUpdateMappingResponse& _return, const WMCreateOrUpdateMappingRequest& request) {
+ // Your implementation goes here
+ printf("create_or_update_wm_mapping\n");
+ }
+
+ void drop_wm_mapping(WMDropMappingResponse& _return, const WMDropMappingRequest& request) {
+ // Your implementation goes here
+ printf("drop_wm_mapping\n");
+ }
+
+ void create_or_drop_wm_trigger_to_pool_mapping(WMCreateOrDropTriggerToPoolMappingResponse& _return, const WMCreateOrDropTriggerToPoolMappingRequest& request) {
+ // Your implementation goes here
+ printf("create_or_drop_wm_trigger_to_pool_mapping\n");
+ }
+
};
int main(int argc, char **argv) {