From 90547e6cd5914abc1fb3c78d27f3d75dd5850996 Mon Sep 17 00:00:00 2001 From: gindibay Date: Wed, 4 Oct 2023 13:17:49 +0300 Subject: [PATCH] Removes unnecessary files --- .../distributed/metadata/metadata_cache.c | 2 - .../distributed/database/database_sharding.h | 53 ------------------- src/include/distributed/metadata_cache.h | 2 - src/include/distributed/shared_library_init.h | 2 - 4 files changed, 59 deletions(-) delete mode 100644 src/include/distributed/database/database_sharding.h diff --git a/src/backend/distributed/metadata/metadata_cache.c b/src/backend/distributed/metadata/metadata_cache.c index 7345b1839..531db2796 100644 --- a/src/backend/distributed/metadata/metadata_cache.c +++ b/src/backend/distributed/metadata/metadata_cache.c @@ -182,8 +182,6 @@ typedef struct MetadataCacheData Oid citusTaskStatusUnscheduledId; Oid citusTaskStatusCancelledId; Oid citusTaskStatusCancellingId; - Oid databaseShardRelationId; - Oid databaseShardPKeyIndexId; Oid distRebalanceStrategyRelationId; Oid distNodeRelationId; Oid distNodeNodeIdIndexId; diff --git a/src/include/distributed/database/database_sharding.h b/src/include/distributed/database/database_sharding.h deleted file mode 100644 index 390be1383..000000000 --- a/src/include/distributed/database/database_sharding.h +++ /dev/null @@ -1,53 +0,0 @@ -/* - * database_sharding.h - * - * Data structure definition for managing backend data and related function - * - * Copyright (c) Microsoft, Inc. - */ - -#ifndef DATABASE_SHARDING_H -#define DATABASE_SHARDING_H - - -#include "tcop/utility.h" - - -/* attributes of citus_catalog.database_shard */ -#define Natts_database_shard 3 -#define Anum_database_shard_database_id 1 -#define Anum_database_shard_node_group_id 2 -#define Anum_database_shard_is_available 3 - - -typedef struct DatabaseShard -{ - /* database oid */ - Oid databaseOid; - - /* node group on which the database shard is placed */ - int nodeGroupId; - - /* whether the database shard is available */ - bool isAvailable; -} DatabaseShard; - -/* citus.enable_database_sharding setting */ -extern bool EnableDatabaseSharding; - -void PreProcessUtilityInDatabaseShard(Node *parseTree, const char *queryString, - ProcessUtilityContext context, - bool *runPreviousUtilityHook); -void PostProcessUtilityInDatabaseShard(Node *parseTree, const char *queryString, - ProcessUtilityContext context); -bool DatabaseShardingEnabled(void); -void AssignDatabaseToShard(Oid databaseOid); -void UpdateDatabaseShard(Oid databaseOid, int targetNodeGroupId); -void DeleteDatabaseShardByDatabaseIdLocally(Oid databaseOid); -DatabaseShard * GetDatabaseShardByOid(Oid databaseOid); -List * ListDatabaseShards(void); -int64 CitusDatabaseSize(Oid databaseId); -char * InsertDatabaseShardAssignmentCommand(Oid databaseOid, int nodeGroupId); - - -#endif diff --git a/src/include/distributed/metadata_cache.h b/src/include/distributed/metadata_cache.h index a5e9081a4..34b95b859 100644 --- a/src/include/distributed/metadata_cache.h +++ b/src/include/distributed/metadata_cache.h @@ -247,7 +247,6 @@ extern Oid DistLocalGroupIdRelationId(void); extern Oid DistObjectRelationId(void); extern Oid DistEnabledCustomAggregatesId(void); extern Oid DistTenantSchemaRelationId(void); -extern Oid DatabaseShardRelationId(void); /* index oids */ extern Oid DistNodeNodeIdIndexId(void); @@ -272,7 +271,6 @@ extern Oid DistObjectPrimaryKeyIndexId(void); extern Oid DistCleanupPrimaryKeyIndexId(void); extern Oid DistTenantSchemaPrimaryKeyIndexId(void); extern Oid DistTenantSchemaUniqueColocationIdIndexId(void); -extern Oid DatabaseShardPrimaryKeyIndexId(void); /* sequence oids */ extern Oid DistBackgroundJobJobIdSequenceId(void); diff --git a/src/include/distributed/shared_library_init.h b/src/include/distributed/shared_library_init.h index 82910d453..3764b52fd 100644 --- a/src/include/distributed/shared_library_init.h +++ b/src/include/distributed/shared_library_init.h @@ -17,8 +17,6 @@ #define MAX_SHARD_COUNT 64000 #define MAX_SHARD_REPLICATION_FACTOR 100 -extern char *CitusMainDatabase; - extern PGDLLEXPORT ColumnarSupportsIndexAM_type extern_ColumnarSupportsIndexAM; extern PGDLLEXPORT CompressionTypeStr_type extern_CompressionTypeStr; extern PGDLLEXPORT IsColumnarTableAmTable_type extern_IsColumnarTableAmTable;