From d71dfeded218b61ba959ffb539fb501fe9ca7968 Mon Sep 17 00:00:00 2001 From: Weizhen Wang Date: Fri, 9 Aug 2024 00:31:52 +0800 Subject: [PATCH] just for test Signed-off-by: Weizhen Wang --- pkg/executor/builder.go | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/pkg/executor/builder.go b/pkg/executor/builder.go index 86eaf1503442c7..eea8907b3b3c83 100644 --- a/pkg/executor/builder.go +++ b/pkg/executor/builder.go @@ -999,6 +999,7 @@ func (b *executorBuilder) buildInsert(v *plannercore.Insert) exec.Executor { insert := &InsertExec{ InsertValues: ivs, OnDuplicate: append(v.OnDuplicate, v.GenCols.OnDuplicates...), + IgnoreErr: v.IgnoreErr, } return insert } @@ -2650,6 +2651,7 @@ func (b *executorBuilder) buildUpdate(v *plannercore.Update) exec.Executor { tblID2table: tblID2table, tblColPosInfos: v.TblColPosInfos, assignFlag: assignFlag, + IgnoreError: v.IgnoreError, } updateExec.fkChecks, b.err = buildTblID2FKCheckExecs(b.ctx, tblID2table, v.FKChecks) if b.err != nil { @@ -3993,6 +3995,7 @@ func buildNoRangeIndexLookUpReader(b *executorBuilder, v *plannercore.PhysicalIn if err != nil { return nil, err } + e := &IndexLookUpExecutor{ indexLookUpExecutorContext: newIndexLookUpExecutorContext(b.ctx), BaseExecutorV2: exec.NewBaseExecutorV2(b.ctx.GetSessionVars(), v.Schema(), v.ID()), @@ -4956,10 +4959,15 @@ func (b *executorBuilder) buildWindow(v *plannercore.PhysicalWindow) exec.Execut BaseExecutor: base, groupChecker: vecgroupchecker.NewVecGroupChecker(b.ctx.GetExprCtx().GetEvalCtx(), b.ctx.GetSessionVars().EnableVectorizedExpression, groupByItems), numWindowFuncs: len(v.WindowFuncDescs), + windowFuncs: windowFuncs, + partialResults: partialResults, + } + exec.slidingWindowFuncs = make([]aggfuncs.SlidingWindowAggFunc, len(exec.windowFuncs)) + for i, windowFunc := range exec.windowFuncs { + if slidingWindowAggFunc, ok := windowFunc.(aggfuncs.SlidingWindowAggFunc); ok { + exec.slidingWindowFuncs[i] = slidingWindowAggFunc + } } - - exec.windowFuncs = windowFuncs - exec.partialResults = partialResults if v.Frame == nil { exec.start = &logicalop.FrameBound{ Type: ast.Preceding,