executor

package
v0.0.0-...-959c02d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 10, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Builder

type Builder struct {
	// contains filtered or unexported fields
}

Builder is used to build from a plan into executor.

func NewBuilder

func NewBuilder(sc *stmtctx.Context) *Builder

NewBuilder returns a build instance.

func (*Builder) Build

func (b *Builder) Build(plan planner.Plan) Executor

Build builds an executor from a plan.

func (*Builder) Error

func (b *Builder) Error() error

Error returns the internal error encountered while building.

type DDLExec

type DDLExec struct {
	// contains filtered or unexported fields
}

DDLExec is used to execute a DDL operation.

func (*DDLExec) Close

func (e *DDLExec) Close() error

Close closes all executors and release all resources.

func (*DDLExec) Columns

func (e *DDLExec) Columns() planner.ResultColumns

func (*DDLExec) Next

func (e *DDLExec) Next(_ context.Context) (datum.Row, error)

Next implements the Executor interface.

func (*DDLExec) Open

func (e *DDLExec) Open(ctx context.Context) error

Open initializes children recursively and "childrenResults" according to children's schemas.

type Executor

type Executor interface {
	Columns() planner.ResultColumns
	Open(context.Context) error
	Next(context.Context) (datum.Row, error)
	Close() error
	// contains filtered or unexported methods
}

Executor is the physical implementation of an algebra operator.

type InsertExec

type InsertExec struct {
	// contains filtered or unexported fields
}

InsertExec represents the executor of INSERT statement.

func (*InsertExec) Close

func (e *InsertExec) Close() error

func (*InsertExec) Columns

func (e *InsertExec) Columns() planner.ResultColumns

func (*InsertExec) Next

func (e *InsertExec) Next(ctx context.Context) (datum.Row, error)

Next implements the Executor interface.

func (*InsertExec) Open

func (e *InsertExec) Open(ctx context.Context) error

Open implements the Executor interface.

type MatchExec

type MatchExec struct {
	// contains filtered or unexported fields
}

func (*MatchExec) Close

func (m *MatchExec) Close() error

func (*MatchExec) Columns

func (e *MatchExec) Columns() planner.ResultColumns

func (*MatchExec) Next

func (m *MatchExec) Next(ctx context.Context) (datum.Row, error)

func (*MatchExec) Open

func (e *MatchExec) Open(ctx context.Context) error

Open initializes children recursively and "childrenResults" according to children's schemas.

type ProjectionExec

type ProjectionExec struct {
	// contains filtered or unexported fields
}

ProjectionExec represents a projection executor.

func (*ProjectionExec) Close

func (e *ProjectionExec) Close() error

Close closes all executors and release all resources.

func (*ProjectionExec) Columns

func (e *ProjectionExec) Columns() planner.ResultColumns

func (*ProjectionExec) Next

func (p *ProjectionExec) Next(ctx context.Context) (datum.Row, error)

func (*ProjectionExec) Open

func (e *ProjectionExec) Open(ctx context.Context) error

Open initializes children recursively and "childrenResults" according to children's schemas.

type SelectionExec

type SelectionExec struct {
	// contains filtered or unexported fields
}

SelectionExec represents a selection executor.

func (*SelectionExec) Close

func (e *SelectionExec) Close() error

Close closes all executors and release all resources.

func (*SelectionExec) Columns

func (e *SelectionExec) Columns() planner.ResultColumns

func (*SelectionExec) Next

func (p *SelectionExec) Next(ctx context.Context) (datum.Row, error)

func (*SelectionExec) Open

func (e *SelectionExec) Open(ctx context.Context) error

Open initializes children recursively and "childrenResults" according to children's schemas.

type ShowExec

type ShowExec struct {
	// contains filtered or unexported fields
}

ShowExec is used to execute the show statements.

func (*ShowExec) Close

func (e *ShowExec) Close() error

Close closes all executors and release all resources.

func (*ShowExec) Columns

func (e *ShowExec) Columns() planner.ResultColumns

func (*ShowExec) Next

func (e *ShowExec) Next(_ context.Context) (datum.Row, error)

func (*ShowExec) Open

func (e *ShowExec) Open(ctx context.Context) error

type SimpleExec

type SimpleExec struct {
	// contains filtered or unexported fields
}

SimpleExec is used to execute some simple tasks.

func (*SimpleExec) Close

func (e *SimpleExec) Close() error

Close closes all executors and release all resources.

func (*SimpleExec) Columns

func (e *SimpleExec) Columns() planner.ResultColumns

func (*SimpleExec) Next

func (e *SimpleExec) Next(_ context.Context) (datum.Row, error)

func (*SimpleExec) Open

func (e *SimpleExec) Open(ctx context.Context) error

Open initializes children recursively and "childrenResults" according to children's schemas.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL