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

add db4ai

Browse Source
This commit is contained in:
nwen
2021-08-05 17:00:58 +08:00
parent f868b1d935
commit 6a7eda6812
110 changed files with 15344 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -162,6 +162,8 @@
#include "securec.h"
#include "gstrace/gstrace_infra.h"
#include "gstrace/executer_gstrace.h"
#include "executor/nodeGD.h"
#include "executor/nodeKMeans.h"
#define NODENAMELEN 64
@ -391,6 +393,10 @@ PlanState* ExecInitNodeByType(Plan* node, EState* estate, int eflags)
return (PlanState*)ExecInitVecMergeJoin((VecMergeJoin*)node, estate, eflags);
case T_VecWindowAgg:
return (PlanState*)ExecInitVecWindowAgg((VecWindowAgg*)node, estate, eflags);
case T_GradientDescent:
return (PlanState*)ExecInitGradientDescent((GradientDescent*)node, estate, eflags);
case T_KMeans:
return (PlanState*)ExecInitKMeans((KMeans*)node, estate, eflags);
default:
ereport(ERROR,
(errmodule(MOD_EXECUTOR),
@ -692,7 +698,10 @@ TupleTableSlot* ExecProcNodeByType(PlanState* node)
result = ExecStream((StreamState*)node);
t_thrd.pgxc_cxt.GlobalNetInstr = NULL;
return result;
case T_GradientDescentState:
return ExecGradientDescent((GradientDescentState*)node);
case T_KMeansState:
return ExecKMeans((KMeansState*)node);
default:
ereport(ERROR,
(errmodule(MOD_EXECUTOR),
@ -1343,6 +1352,14 @@ static void ExecEndNodeByType(PlanState* node)
ExecEndVecWindowAgg((VecWindowAggState*)node);
break;
case T_GradientDescentState:
ExecEndGradientDescent((GradientDescentState*)node);
break;
case T_KMeansState:
ExecEndKMeans((KMeansState*)node);
break;
default:
ereport(ERROR,
(errmodule(MOD_EXECUTOR),