Skip to content

Commit

Permalink
/
Browse files Browse the repository at this point in the history
Signed-off-by: AilinKid <314806019@qq.com>
  • Loading branch information
AilinKid committed Jul 15, 2024
1 parent 24dee3f commit bef2a35
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion pkg/executor/expand.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ import (
"github.com/pingcap/tidb/pkg/util/memory"
)

// ExpandExec is used to execute expand logical plan.
type ExpandExec struct {
exec.BaseExecutor

Expand Down Expand Up @@ -68,6 +69,7 @@ func (e *ExpandExec) open(_ context.Context) error {
return nil
}

// Next implements the Executor Next interface.
func (e *ExpandExec) Next(ctx context.Context, req *chunk.Chunk) error {
req.GrowAndReset(e.MaxChunkSize())
if e.isUnparalleled() {
Expand Down Expand Up @@ -106,10 +108,11 @@ func (e *ExpandExec) unParallelExecute(ctx context.Context, chk *chunk.Chunk) er
return nil
}

func (e *ExpandExec) parallelExecute(ctx context.Context, chk *chunk.Chunk) error {
func (*ExpandExec) parallelExecute(_ context.Context, _ *chunk.Chunk) error {
return errors.New("parallel expand eval logic not implemented")
}

// Close implements the Executor Close interface.
func (e *ExpandExec) Close() error {
// if e.BaseExecutor.Open returns error, e.childResult will be nil, see https://github.com/pingcap/tidb/issues/24210
// for more information
Expand Down

0 comments on commit bef2a35

Please sign in to comment.