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

Rename a function

pull/896/head
Onder Kalaci 2016-10-19 14:08:28 +03:00
parent 616f370885
commit 0d0642f5a3
1 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/backend/distributed/planner/multi_router_planner.c
View File

@ -74,11 +74,11 @@ static MultiPlan * CreateSingleTaskRouterPlan(Query *originalQuery, Query *query
static MultiPlan * CreateMultiTaskRouterPlan(Query *originalQuery, Query *query, static MultiPlan * CreateMultiTaskRouterPlan(Query *originalQuery, Query *query,
RelationRestrictionContext * RelationRestrictionContext *
restrictionContext); restrictionContext);
static Task * CreateMultipleTaskRouterModifyTask(Query *originalQuery, Query *query, static Task * RouterModifyTaskForShardInterval(Query *originalQuery, Query *query,
ShardInterval *shardInterval, ShardInterval *shardInterval,
RelationRestrictionContext * RelationRestrictionContext *
restrictionContext, restrictionContext,
uint32 taskIdIndex); uint32 taskIdIndex);
static bool MasterIrreducibleExpression(Node *expression, bool *varArgument, static bool MasterIrreducibleExpression(Node *expression, bool *varArgument,
bool *badCoalesce); bool *badCoalesce);
static bool MasterIrreducibleExpressionWalker(Node *expression, WalkerState *state); static bool MasterIrreducibleExpressionWalker(Node *expression, WalkerState *state);
@ -247,10 +247,10 @@ CreateMultiTaskRouterPlan(Query *originalQuery, Query *query,
targetCacheEntry->sortedShardIntervalArray[shardOffset]; targetCacheEntry->sortedShardIntervalArray[shardOffset];
Task *modifyTask = NULL; Task *modifyTask = NULL;
modifyTask = CreateMultipleTaskRouterModifyTask(originalQuery, query, modifyTask = RouterModifyTaskForShardInterval(originalQuery, query,
targetShardInterval, targetShardInterval,
restrictionContext, restrictionContext,
taskIdIndex); taskIdIndex);
/* add the task if it could be created */ /* add the task if it could be created */
if (modifyTask != NULL) if (modifyTask != NULL)
@ -281,7 +281,7 @@ CreateMultiTaskRouterPlan(Query *originalQuery, Query *query,
/* /*
* CreateMultipleTaskRouterModifyTask creates a modify task by * RouterModifyTaskForShardInterval creates a modify task by
* replacing the partitioning qual parameter added in multi_planner() * replacing the partitioning qual parameter added in multi_planner()
* with the shardInterval's boundary value. Then perform the normal * with the shardInterval's boundary value. Then perform the normal
* shard pruning on the subquery. Finally, checks if the target shardInterval * shard pruning on the subquery. Finally, checks if the target shardInterval
@ -292,10 +292,10 @@ CreateMultiTaskRouterPlan(Query *originalQuery, Query *query,
* subqueries with non euqi-joins.). * subqueries with non euqi-joins.).
*/ */
static Task * static Task *
CreateMultipleTaskRouterModifyTask(Query *originalQuery, Query *query, RouterModifyTaskForShardInterval(Query *originalQuery, Query *query,
ShardInterval *shardInterval, ShardInterval *shardInterval,
RelationRestrictionContext *restrictionContext, RelationRestrictionContext *restrictionContext,
uint32 taskIdIndex) uint32 taskIdIndex)
{ {
RangeTblEntry *subqueryRte = lsecond(query->rtable); RangeTblEntry *subqueryRte = lsecond(query->rtable);
Query *subquery = subqueryRte->subquery; Query *subquery = subqueryRte->subquery;