users/saawasek/non_blocking_split_integrated
Sameer Awasekar 2022-06-22 11:07:20 +05:30
parent 0b11a324a4
commit 99a21757d4
3 changed files with 3 additions and 3 deletions

View File

@ -89,7 +89,7 @@ static int NodeShardMappingHashCompare(const void *left, const void *right, Size
* There is a 1-1 mapping between a table owner and a replication slot. One replication
* slot takes care of replicating changes for all shards belonging to the same owner on a particular node.
*
* During the replication phase, 'decoding_plugin_for_shard_split' will attach to the shared memory
* During the replication phase, WAL senders will attach to the shared memory
* populated by current UDF. It routes the tuple from the source shard to the appropriate destination
* shard for which the respective slot is responsible.
*/

View File

@ -27,7 +27,7 @@ SELECT create_distributed_table('table_to_split','id');
-- ROW(1, 3 , 0 , 2147483647, 18 )
-- ]
-- );
-- 5. Create Replication slot with 'decoding_plugin_for_shard_split'
-- 5. Create Replication slot with 'citus'
-- 6. Setup Pub/Sub
-- 7. Insert into table_to_split_1 at source worker1
-- 8. Expect the results in either table_to_split_2 or table_to_split_3 at worker2

View File

@ -25,7 +25,7 @@ SELECT create_distributed_table('table_to_split','id');
-- ROW(1, 3 , 0 , 2147483647, 18 )
-- ]
-- );
-- 5. Create Replication slot with 'decoding_plugin_for_shard_split'
-- 5. Create Replication slot with 'citus'
-- 6. Setup Pub/Sub
-- 7. Insert into table_to_split_1 at source worker1
-- 8. Expect the results in either table_to_split_2 or table_to_split_3 at worker2