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

Style

support-partitioning-for-citus-local-tables
Ahmet Gedemenli 2021-08-16 18:30:55 +03:00
parent f5378a8c9d
commit 360c11f7fd
2 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -400,7 +400,8 @@ ErrorIfUnsupportedCitusLocalTableKind(Oid relationId)
char relationKind = get_rel_relkind(relationId); char relationKind = get_rel_relkind(relationId);
if (!(relationKind == RELKIND_RELATION || relationKind == RELKIND_FOREIGN_TABLE || relationKind == RELKIND_PARTITIONED_TABLE)) if (!(relationKind == RELKIND_RELATION || relationKind == RELKIND_FOREIGN_TABLE ||
relationKind == RELKIND_PARTITIONED_TABLE))
{ {
ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED), ereport(ERROR, (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
errmsg("cannot add local table \"%s\" to metadata, only regular " errmsg("cannot add local table \"%s\" to metadata, only regular "

2
src/backend/distributed/commands/table.c
View File

@ -360,7 +360,7 @@ PostprocessCreateTableStmtPartitionOf(CreateStmt *createStatement, const
*/ */
if (IsCitusTable(parentRelationId)) if (IsCitusTable(parentRelationId))
{ {
if(IsCitusTableType(parentRelationId, CITUS_LOCAL_TABLE)) if (IsCitusTableType(parentRelationId, CITUS_LOCAL_TABLE))
{ {
/* if it's a citus local table, we don't need distribution column */ /* if it's a citus local table, we don't need distribution column */
CreateCitusLocalTable(relationId, false); CreateCitusLocalTable(relationId, false);