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

Show distributed subplan ID in EXPLAIN output

pull/1888/head
Marco Slot 2017-12-16 11:32:01 +01:00
parent 7a25ebe257
commit 44a1ea631a
1 changed files with 18 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
src/backend/distributed/planner/multi_explain.c
View File

@ -72,7 +72,7 @@ typedef struct RemoteExplainPlan
/* Explain functions for distributed queries */ /* Explain functions for distributed queries */
static void ExplainSubPlans(List *subPlanList, ExplainState *es); static void ExplainSubPlans(DistributedPlan *distributedPlan, ExplainState *es);
static void ExplainJob(Job *job, ExplainState *es); static void ExplainJob(Job *job, ExplainState *es);
static void ExplainMapMergeJob(MapMergeJob *mapMergeJob, ExplainState *es); static void ExplainMapMergeJob(MapMergeJob *mapMergeJob, ExplainState *es);
static void ExplainTaskList(List *taskList, ExplainState *es); static void ExplainTaskList(List *taskList, ExplainState *es);
@ -127,7 +127,7 @@ CitusExplainScan(CustomScanState *node, List *ancestors, struct ExplainState *es
if (distributedPlan->subPlanList != NIL) if (distributedPlan->subPlanList != NIL)
{ {
ExplainSubPlans(distributedPlan->subPlanList, es); ExplainSubPlans(distributedPlan, es);
} }
ExplainJob(distributedPlan->workerJob, es); ExplainJob(distributedPlan->workerJob, es);
@ -179,20 +179,14 @@ CoordinatorInsertSelectExplainScan(CustomScanState *node, List *ancestors,
* planning time and set it to 0. * planning time and set it to 0.
*/ */
static void static void
ExplainSubPlans(List *subPlanList, ExplainState *es) ExplainSubPlans(DistributedPlan *distributedPlan, ExplainState *es)
{ {
ListCell *subPlanCell = NULL; ListCell *subPlanCell = NULL;
uint64 planId = distributedPlan->planId;
ExplainOpenGroup("Subplans", "Subplans", false, es); ExplainOpenGroup("Subplans", "Subplans", false, es);
if (es->format == EXPLAIN_FORMAT_TEXT) foreach(subPlanCell, distributedPlan->subPlanList)
{
appendStringInfoSpaces(es->str, es->indent * 2);
appendStringInfo(es->str, "-> Distributed Subplan\n");
es->indent += 3;
}
foreach(subPlanCell, subPlanList)
{ {
DistributedSubPlan *subPlan = (DistributedSubPlan *) lfirst(subPlanCell); DistributedSubPlan *subPlan = (DistributedSubPlan *) lfirst(subPlanCell);
PlannedStmt *plan = subPlan->plan; PlannedStmt *plan = subPlan->plan;
@ -201,6 +195,15 @@ ExplainSubPlans(List *subPlanList, ExplainState *es)
char *queryString = NULL; char *queryString = NULL;
instr_time planduration; instr_time planduration;
if (es->format == EXPLAIN_FORMAT_TEXT)
{
char *resultId = GenerateResultId(planId, subPlan->subPlanId);
appendStringInfoSpaces(es->str, es->indent * 2);
appendStringInfo(es->str, "-> Distributed Subplan %s\n", resultId);
es->indent += 3;
}
/* set the planning time to 0 */ /* set the planning time to 0 */
INSTR_TIME_SET_CURRENT(planduration); INSTR_TIME_SET_CURRENT(planduration);
INSTR_TIME_SUBTRACT(planduration, planduration); INSTR_TIME_SUBTRACT(planduration, planduration);
@ -210,11 +213,11 @@ ExplainSubPlans(List *subPlanList, ExplainState *es)
#else #else
ExplainOnePlan(plan, into, es, queryString, params, &planduration); ExplainOnePlan(plan, into, es, queryString, params, &planduration);
#endif #endif
}
if (es->format == EXPLAIN_FORMAT_TEXT) if (es->format == EXPLAIN_FORMAT_TEXT)
{ {
es->indent -= 3; es->indent -= 3;
}
} }
ExplainCloseGroup("Subplans", "Subplans", false, es); ExplainCloseGroup("Subplans", "Subplans", false, es);