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

Refactor

users/saawasek/non_blocking_split_integrated
Sameer Awasekar 2022-07-21 10:42:04 +05:30
parent a4bf6a1dbb
commit 515f1e2346
2 changed files with 1 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/operations/split_shard_replication_setup.c → src/backend/distributed/operations/worker_split_shard_replication_setup_udf.c
View File

@ -1,6 +1,6 @@
/*-------------------------------------------------------------------------
*
* split_shard_replication_setup.c
* worker_split_shard_replication_setup.c
* This file contains functions to setup information about list of shards
* that are being split.
*

20
src/backend/distributed/shardsplit/shardsplit_logical_replication.c
View File

@ -218,26 +218,6 @@ PrintShardSplitPubSubMetadata(ShardSplitSubscriberMetadata *shardSplitMetadata)
printf("\n");
}
/* static void */
/* CreateShardSplitPublications(MultiConnection *sourceConnection, */
/* List *shardSplitPubSubMetadataList) */
/* { */
/* ShardSplitSubscriberMetadata *shardSplitPubSubMetadata = NULL; */
/* foreach_ptr(shardSplitPubSubMetadata, shardSplitPubSubMetadataList) */
/* { */
/* uint32 publicationForNodeId = shardSplitPubSubMetadata->slotInfo->targetNodeId; */
/* Oid tableOwnerId = shardSplitPubSubMetadata->tableOwnerId; */
/* CreateShardSplitPublicationForNode(sourceConnection, */
/* shardSplitPubSubMetadata-> */
/* shardIntervalListForSubscription, */
/* publicationForNodeId, */
/* tableOwnerId); */
/* } */
/* } */
void
CreateShardSplitSubscriptions(List *targetNodeConnectionList,
List *shardSplitPubSubMetadataList,