From 8919708288a95ee6cf8179c2528e1576269f48b5 Mon Sep 17 00:00:00 2001 From: qxhy123 Date: Mon, 12 Mar 2018 10:25:20 +0800 Subject: [PATCH] remove Next() function for MaxOneRowExec --- executor/executor.go | 23 ----------------------- 1 file changed, 23 deletions(-) diff --git a/executor/executor.go b/executor/executor.go index efc11feb7427e..ff3e7e25e04f6 100644 --- a/executor/executor.go +++ b/executor/executor.go @@ -1140,29 +1140,6 @@ func (e *MaxOneRowExec) Open(ctx context.Context) error { return nil } -// Next implements the Executor Next interface. -func (e *MaxOneRowExec) Next(ctx context.Context) (Row, error) { - if !e.evaluated { - e.evaluated = true - srcRow, err := e.children[0].Next(ctx) - if err != nil { - return nil, errors.Trace(err) - } - if srcRow == nil { - return make([]types.Datum, e.schema.Len()), nil - } - srcRow1, err := e.children[0].Next(ctx) - if err != nil { - return nil, errors.Trace(err) - } - if srcRow1 != nil { - return nil, errors.New("subquery returns more than 1 row") - } - return srcRow, nil - } - return nil, nil -} - // NextChunk implements the Executor NextChunk interface. func (e *MaxOneRowExec) NextChunk(ctx context.Context, chk *chunk.Chunk) error { chk.Reset()