Searched refs:combineQuery (Results 1 – 11 of 11) sorted by relevance
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/ |
H A D | combine_query_planner.c | 30 static PlannedStmt * BuildSelectStatementViaStdPlanner(Query *combineQuery, 63 Query *combineQuery = distributedPlan->combineQuery; in PlanCombineQuery() local 68 return BuildSelectStatementViaStdPlanner(combineQuery, remoteScanTargetList, in PlanCombineQuery() 242 BuildSelectStatementViaStdPlanner(Query *combineQuery, List *remoteScanTargetList, in BuildSelectStatementViaStdPlanner() argument 264 FindCitusExtradataContainerRTE((Node *) combineQuery, &extradataContainerRTE); in BuildSelectStatementViaStdPlanner() 285 pg_get_query_def(combineQuery, queryString); in BuildSelectStatementViaStdPlanner() 298 standardStmt = standard_planner_compat(combineQuery, 0, NULL); in BuildSelectStatementViaStdPlanner()
|
H A D | insert_select_planner.c | 352 distributedPlan->combineQuery = NULL; in CreateDistributedInsertSelectPlan() 398 if (distPlan->combineQuery == NULL) in CreateInsertSelectIntoLocalTablePlan() 419 selectRte->subquery = distPlan->combineQuery; in CreateInsertSelectIntoLocalTablePlan() 420 distPlan->combineQuery = originalQuery; in CreateInsertSelectIntoLocalTablePlan() 483 Query *combineQuery = makeNode(Query); in CreateCombineQueryForRouterPlan() local 484 combineQuery->commandType = CMD_SELECT; in CreateCombineQueryForRouterPlan() 485 combineQuery->querySource = QSRC_ORIGINAL; in CreateCombineQueryForRouterPlan() 486 combineQuery->canSetTag = true; in CreateCombineQueryForRouterPlan() 488 combineQuery->targetList = targetList; in CreateCombineQueryForRouterPlan() 489 combineQuery->jointree = joinTree; in CreateCombineQueryForRouterPlan() [all …]
|
H A D | intermediate_result_pruning.c | 57 if (plan->combineQuery != NULL) in FindSubPlanUsages() 59 localSubPlans = FindSubPlansUsedInNode((Node *) plan->combineQuery, in FindSubPlanUsages()
|
H A D | function_call_delegation.c | 333 distributedPlan->combineQuery = NULL; in TryToDelegateFunctionCall()
|
H A D | multi_router_planner.c | 254 distributedPlan->combineQuery = NULL; in CreateModifyPlan() 292 distributedPlan->combineQuery = NULL; in CreateSingleTaskRouterSelectPlan()
|
H A D | distributed_planner.c | 1297 if (distributedPlan->combineQuery) in FinalizePlan()
|
H A D | multi_physical_planner.c | 260 Query *combineQuery = BuildJobQuery((MultiNode *) multiTree, masterDependentJobList); in CreatePhysicalDistributedPlan() local 264 distributedPlan->combineQuery = combineQuery; in CreatePhysicalDistributedPlan()
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/ |
H A D | insert_select_executor.c | 797 if (distSelectPlan->combineQuery != NULL) in IsRedistributablePlan() 799 Query *combineQuery = (Query *) distSelectPlan->combineQuery; in IsRedistributablePlan() local 801 if (contain_nextval_expression_walker((Node *) combineQuery->targetList, NULL)) in IsRedistributablePlan()
|
/dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
H A D | citus_copyfuncs.c | 126 COPY_NODE_FIELD(combineQuery); in CopyNodeDistributedPlan()
|
H A D | citus_outfuncs.c | 191 WRITE_NODE_FIELD(combineQuery); in OutDistributedPlan()
|
/dports/databases/pg_citus/citus-10.2.3/src/include/distributed/ |
H A D | multi_physical_planner.h | 401 Query *combineQuery; member
|