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

minor suggestion - 1

onur-suggestions
Onur Tirtir 2025-07-14 17:49:20 +03:00
parent 3cbcf40cea
commit e1879c0628
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/distributed/planner/fast_path_router_planner.c
View File

@ -221,9 +221,6 @@ FastPathRouterQuery(Query *query, FastPathRestrictionContext *fastPathContext)
{ {
FromExpr *joinTree = query->jointree; FromExpr *joinTree = query->jointree;
Node *quals = NULL; Node *quals = NULL;
bool isFastPath = false;
bool canAvoidDeparse = false;
Node *distributionKeyValue = NULL;
if (!EnableFastPathRouterPlanner) if (!EnableFastPathRouterPlanner)
{ {
@ -280,6 +277,10 @@ FastPathRouterQuery(Query *query, FastPathRestrictionContext *fastPathContext)
return false; return false;
} }
bool isFastPath = false;
bool canAvoidDeparse = false;
Node *distributionKeyValue = NULL;
/* /*
* If the table doesn't have a distribution column, we don't need to * If the table doesn't have a distribution column, we don't need to
* check anything further. * check anything further.
@ -292,8 +293,7 @@ FastPathRouterQuery(Query *query, FastPathRestrictionContext *fastPathContext)
SINGLE_SHARD_DISTRIBUTED); SINGLE_SHARD_DISTRIBUTED);
isFastPath = true; isFastPath = true;
} }
else
if (!isFastPath)
{ {
canAvoidDeparse = IsCitusTableTypeCacheEntry(cacheEntry, DISTRIBUTED_TABLE); canAvoidDeparse = IsCitusTableTypeCacheEntry(cacheEntry, DISTRIBUTED_TABLE);