Home
last modified time | relevance | path

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 Dcombine_query_planner.c30 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 Dinsert_select_planner.c352 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 Dintermediate_result_pruning.c57 if (plan->combineQuery != NULL) in FindSubPlanUsages()
59 localSubPlans = FindSubPlansUsedInNode((Node *) plan->combineQuery, in FindSubPlanUsages()
H A Dfunction_call_delegation.c333 distributedPlan->combineQuery = NULL; in TryToDelegateFunctionCall()
H A Dmulti_router_planner.c254 distributedPlan->combineQuery = NULL; in CreateModifyPlan()
292 distributedPlan->combineQuery = NULL; in CreateSingleTaskRouterSelectPlan()
H A Ddistributed_planner.c1297 if (distributedPlan->combineQuery) in FinalizePlan()
H A Dmulti_physical_planner.c260 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 Dinsert_select_executor.c797 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 Dcitus_copyfuncs.c126 COPY_NODE_FIELD(combineQuery); in CopyNodeDistributedPlan()
H A Dcitus_outfuncs.c191 WRITE_NODE_FIELD(combineQuery); in OutDistributedPlan()
/dports/databases/pg_citus/citus-10.2.3/src/include/distributed/
H A Dmulti_physical_planner.h401 Query *combineQuery; member