external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removes unnecessary files

create_drop_db_gh
gindibay 2023-10-04 13:17:49 +03:00
parent 84826dcc98
commit 90547e6cd5
4 changed files with 0 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/metadata/metadata_cache.c
View File

@ -182,8 +182,6 @@ typedef struct MetadataCacheData
Oid citusTaskStatusUnscheduledId; Oid citusTaskStatusUnscheduledId;
Oid citusTaskStatusCancelledId; Oid citusTaskStatusCancelledId;
Oid citusTaskStatusCancellingId; Oid citusTaskStatusCancellingId;
Oid databaseShardRelationId;
Oid databaseShardPKeyIndexId;
Oid distRebalanceStrategyRelationId; Oid distRebalanceStrategyRelationId;
Oid distNodeRelationId; Oid distNodeRelationId;
Oid distNodeNodeIdIndexId; Oid distNodeNodeIdIndexId;

53
src/include/distributed/database/database_sharding.h
View File

@ -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

2
src/include/distributed/metadata_cache.h
View File

@ -247,7 +247,6 @@ extern Oid DistLocalGroupIdRelationId(void);
extern Oid DistObjectRelationId(void); extern Oid DistObjectRelationId(void);
extern Oid DistEnabledCustomAggregatesId(void); extern Oid DistEnabledCustomAggregatesId(void);
extern Oid DistTenantSchemaRelationId(void); extern Oid DistTenantSchemaRelationId(void);
extern Oid DatabaseShardRelationId(void);
/* index oids */ /* index oids */
extern Oid DistNodeNodeIdIndexId(void); extern Oid DistNodeNodeIdIndexId(void);
@ -272,7 +271,6 @@ extern Oid DistObjectPrimaryKeyIndexId(void);
extern Oid DistCleanupPrimaryKeyIndexId(void); extern Oid DistCleanupPrimaryKeyIndexId(void);
extern Oid DistTenantSchemaPrimaryKeyIndexId(void); extern Oid DistTenantSchemaPrimaryKeyIndexId(void);
extern Oid DistTenantSchemaUniqueColocationIdIndexId(void); extern Oid DistTenantSchemaUniqueColocationIdIndexId(void);
extern Oid DatabaseShardPrimaryKeyIndexId(void);
/* sequence oids */ /* sequence oids */
extern Oid DistBackgroundJobJobIdSequenceId(void); extern Oid DistBackgroundJobJobIdSequenceId(void);

2
src/include/distributed/shared_library_init.h
View File

@ -17,8 +17,6 @@
#define MAX_SHARD_COUNT 64000 #define MAX_SHARD_COUNT 64000
#define MAX_SHARD_REPLICATION_FACTOR 100 #define MAX_SHARD_REPLICATION_FACTOR 100
extern char *CitusMainDatabase;
extern PGDLLEXPORT ColumnarSupportsIndexAM_type extern_ColumnarSupportsIndexAM; extern PGDLLEXPORT ColumnarSupportsIndexAM_type extern_ColumnarSupportsIndexAM;
extern PGDLLEXPORT CompressionTypeStr_type extern_CompressionTypeStr; extern PGDLLEXPORT CompressionTypeStr_type extern_CompressionTypeStr;
extern PGDLLEXPORT IsColumnarTableAmTable_type extern_IsColumnarTableAmTable; extern PGDLLEXPORT IsColumnarTableAmTable_type extern_IsColumnarTableAmTable;