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

Use empty partition column list instead of partition column list with NULL

multi-column-distribution
Jelte Fennema 2021-06-09 11:28:37 +02:00
parent 0757100833
commit 3e96d3a736
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/backend/distributed/commands/citus_add_local_table_to_metadata.c
View File

@ -1010,9 +1010,9 @@ InsertMetadataForCitusLocalTable(Oid citusLocalTableId, uint64 shardId)
char replicationModel = REPLICATION_MODEL_STREAMING; char replicationModel = REPLICATION_MODEL_STREAMING;
uint32 colocationId = INVALID_COLOCATION_ID; uint32 colocationId = INVALID_COLOCATION_ID;
Var *distributionColumn = NULL; List *distributionColumnList = NIL;
InsertIntoPgDistPartition(citusLocalTableId, distributionMethod, InsertIntoPgDistPartition(citusLocalTableId, distributionMethod,
list_make1(distributionColumn), colocationId, distributionColumnList, colocationId,
replicationModel); replicationModel);
/* set shard storage type according to relation type */ /* set shard storage type according to relation type */

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

@ -348,7 +348,6 @@ create_reference_table(PG_FUNCTION_ARGS)
Oid relationId = PG_GETARG_OID(0); Oid relationId = PG_GETARG_OID(0);
char *colocateWithTableName = NULL; char *colocateWithTableName = NULL;
Var *distributionColumn = NULL;
bool viaDeprecatedAPI = false; bool viaDeprecatedAPI = false;
@ -384,7 +383,8 @@ create_reference_table(PG_FUNCTION_ARGS)
errdetail("There are no active worker nodes."))); errdetail("There are no active worker nodes.")));
} }
CreateDistributedTable(relationId, list_make1(distributionColumn), DISTRIBUTE_BY_NONE, List *distributionColumnList = NIL;
CreateDistributedTable(relationId, distributionColumnList, DISTRIBUTE_BY_NONE,
ShardCount, false, colocateWithTableName, viaDeprecatedAPI); ShardCount, false, colocateWithTableName, viaDeprecatedAPI);
PG_RETURN_VOID(); PG_RETURN_VOID();
} }