database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

parallel hash: inner parallel

Browse Source
This commit is contained in:
wuyuechuan
2020-11-24 11:08:59 +08:00
parent 661bbda2e8
commit 974b231240
72 changed files with 4423 additions and 824 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/gausskernel/runtime/executor/execProcnode.cpp
View File

@ -1360,20 +1360,27 @@ void ExecEndNode(PlanState* node)
* no more rows will be needed (e.g. when a Limit is filled) rather than only
* at the end of ExecutorRun.
*/
bool ExecShutdownNode(PlanState *node)
bool ExecShutdownNode(PlanState* node)
{
if (node == NULL)
if (node == NULL) {
return false;
}
(void)planstate_tree_walker(node, (bool (*)())ExecShutdownNode, NULL);
switch (nodeTag(node)) {
case T_GatherState:
ExecShutdownGather((GatherState *)node);
ExecShutdownGather((GatherState*)node);
break;
case T_HashState:
ExecShutdownHash((HashState*)node);
break;
case T_HashJoinState:
ExecShutdownHashJoin((HashJoinState*)node);
break;
default:
break;
}
return planstate_tree_walker(node, (bool (*)())ExecShutdownNode, NULL);
return false;
}
/*