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

Dist table refactor

velioglu/wo_seq_test_1
Burak Velioglu 2021-12-23 00:16:38 +03:00
parent a448ca01bc
commit 48c5ce8960
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/backend/distributed/commands/create_distributed_table.c
View File

@ -450,14 +450,6 @@ CreateDistributedTable(Oid relationId, Var *distributionColumn, char distributio
ObjectAddressSet(tableAddress, RelationRelationId, relationId); ObjectAddressSet(tableAddress, RelationRelationId, relationId);
EnsureDependenciesExistOnAllNodes(&tableAddress); EnsureDependenciesExistOnAllNodes(&tableAddress);
CreateShellTableOnWorkers(relationId);
/* TODO: Consider partitioned tables */
if (EnableDependencyCreation)
{
MarkObjectDistributed(&tableAddress);
}
char replicationModel = DecideReplicationModel(distributionMethod, char replicationModel = DecideReplicationModel(distributionMethod,
colocateWithTableName, colocateWithTableName,
viaDeprecatedAPI); viaDeprecatedAPI);
@ -542,6 +534,15 @@ CreateDistributedTable(Oid relationId, Var *distributionColumn, char distributio
if (ShouldSyncTableMetadata(relationId)) if (ShouldSyncTableMetadata(relationId))
{ {
CreateShellTableOnWorkers(relationId);
/* TODO: Consider partitioned tables */
// TODO: Should we really check? or don't allow
if (EnableDependencyCreation)
{
MarkObjectDistributed(&tableAddress);
}
CreateTableMetadataOnWorkers(relationId); CreateTableMetadataOnWorkers(relationId);
} }