executor

package

Go to main page

Versions in this module

v1

v1.2.6

Jul 29, 2026

v1.2.1

Jul 27, 2026

v1.2.0

Jul 23, 2026

Changes in this version

+ type DistinctOp struct

+ func NewDistinctOp(child Operator, plan *planner.PhysicalDistinct) *DistinctOp

+ func (op *DistinctOp) Close() error

+ func (op *DistinctOp) Next() (Row, *planner.Schema, error)

+ func (op *DistinctOp) Open() error

type ExecContext

+ Ctx context.Context

+ NamedParams map[string]interface{}

v1.1.9

Jul 23, 2026

Changes in this version

type ExecContext

+ Debugf func(format string, args ...interface{})

+ type InfoSchemaViewsOp struct

+ func NewInfoSchemaViewsOp(cat *catalog.Catalog, txn engine.Transaction) *InfoSchemaViewsOp

+ func (op *InfoSchemaViewsOp) Close() error

+ func (op *InfoSchemaViewsOp) Next() (Row, *planner.Schema, error)

+ func (op *InfoSchemaViewsOp) Open() error

v1.1.8

Jul 22, 2026

v1.1.6

Jul 22, 2026

Changes in this version

+ const MaxSortRows

+ func CheckConstraints(row []types.Value, table *catalog.TableDesc) error

+ func MatchIndexFilter(idx catalog.IndexDesc, row Row, params []interface{}) bool

+ type AlterTableOp struct

+ func NewAlterTableOp(txn engine.Transaction, cat *catalog.Catalog, plan *planner.PhysicalAlterTable) *AlterTableOp

+ func (op *AlterTableOp) Close() error

+ func (op *AlterTableOp) Next() (Row, *planner.Schema, error)

+ func (op *AlterTableOp) Open() error

+ type CreateViewOp struct

+ func NewCreateViewOp(txn engine.Transaction, cat *catalog.Catalog, plan *planner.PhysicalCreateView) *CreateViewOp

+ func (op *CreateViewOp) Close() error

+ func (op *CreateViewOp) Next() (Row, *planner.Schema, error)

+ func (op *CreateViewOp) Open() error

+ type DropViewOp struct

+ func NewDropViewOp(txn engine.Transaction, cat *catalog.Catalog, plan *planner.PhysicalDropView) *DropViewOp

+ func (op *DropViewOp) Close() error

+ func (op *DropViewOp) Next() (Row, *planner.Schema, error)

+ func (op *DropViewOp) Open() error

+ type DualScanOp struct

+ func NewDualScanOp() *DualScanOp

+ func (op *DualScanOp) Close() error

+ func (op *DualScanOp) Next() (Row, *planner.Schema, error)

+ func (op *DualScanOp) Open() error

+ type ExplainOp struct

+ func NewExplainOp(plan *planner.PhysicalExplain) *ExplainOp

+ func (op *ExplainOp) Close() error

+ func (op *ExplainOp) Next() (Row, *planner.Schema, error)

+ func (op *ExplainOp) Open() error

type FilterOp

+ func NewFilterOpCtx(child Operator, plan *planner.PhysicalFilter, params []interface{}, ...) *FilterOp

+ type InfoSchemaColumnsOp struct

+ func NewInfoSchemaColumnsOp(cat *catalog.Catalog, txn engine.Transaction, filterTable string) *InfoSchemaColumnsOp

+ func (op *InfoSchemaColumnsOp) Close() error

+ func (op *InfoSchemaColumnsOp) Next() (Row, *planner.Schema, error)

+ func (op *InfoSchemaColumnsOp) Open() error

+ type InfoSchemaTablesOp struct

+ func NewInfoSchemaTablesOp(cat *catalog.Catalog, txn engine.Transaction) *InfoSchemaTablesOp

+ func (op *InfoSchemaTablesOp) Close() error

+ func (op *InfoSchemaTablesOp) Next() (Row, *planner.Schema, error)

+ func (op *InfoSchemaTablesOp) Open() error

type InsertOp

+ LastInsertId int64

type ProjectOp

+ func NewProjectOpCtx(child Operator, plan *planner.PhysicalProject, params []interface{}, ...) *ProjectOp

+ type ReleaseSavepointOp struct

+ func NewReleaseSavepointOp(txn engine.Transaction, name string) *ReleaseSavepointOp

+ func (op *ReleaseSavepointOp) Close() error

+ func (op *ReleaseSavepointOp) Next() (Row, *planner.Schema, error)

+ func (op *ReleaseSavepointOp) Open() error

+ type RollbackToSavepointOp struct

+ func NewRollbackToSavepointOp(txn engine.Transaction, name string) *RollbackToSavepointOp

+ func (op *RollbackToSavepointOp) Close() error

+ func (op *RollbackToSavepointOp) Next() (Row, *planner.Schema, error)

+ func (op *RollbackToSavepointOp) Open() error

+ type SavepointOp struct

+ func NewSavepointOp(txn engine.Transaction, name string) *SavepointOp

+ func (op *SavepointOp) Close() error

+ func (op *SavepointOp) Next() (Row, *planner.Schema, error)

+ func (op *SavepointOp) Open() error

+ type Scanner interface

+ Scan func(src interface{}) error

+ type SetOpOp struct

+ func NewSetOpOp(plan *planner.PhysicalSetOp, left, right Operator) *SetOpOp

+ func (op *SetOpOp) Close() error

+ func (op *SetOpOp) Next() (Row, *planner.Schema, error)

+ func (op *SetOpOp) Open() error

+ type ShowColumnsOp struct

+ func NewShowColumnsOp(cat *catalog.Catalog, txn engine.Transaction, tableName string) *ShowColumnsOp

+ func (op *ShowColumnsOp) Close() error

+ func (op *ShowColumnsOp) Next() (Row, *planner.Schema, error)

+ func (op *ShowColumnsOp) Open() error

+ type ShowTablesOp struct

+ func NewShowTablesOp(cat *catalog.Catalog, txn engine.Transaction) *ShowTablesOp

+ func (op *ShowTablesOp) Close() error

+ func (op *ShowTablesOp) Next() (Row, *planner.Schema, error)

+ func (op *ShowTablesOp) Open() error

+ type TruncateTableOp struct

+ func NewTruncateTableOp(txn engine.Transaction, cat *catalog.Catalog, ...) *TruncateTableOp

+ func (op *TruncateTableOp) Close() error

+ func (op *TruncateTableOp) Next() (Row, *planner.Schema, error)

+ func (op *TruncateTableOp) Open() error

v1.1.4

Jul 21, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

Changes in this version

+ func CoerceAssignments(assignments map[int]types.Value, table *catalog.TableDesc) error

+ func CoerceRow(row []types.Value, table *catalog.TableDesc) error

v1.1.0

Jul 19, 2026

Changes in this version

+ func Eval(e expr.Expression, row Row, params []interface{}) (interface{}, error)

+ func ExecVM(prog *VMProgram, row Row, params []interface{}) (interface{}, error)

+ type AggOp struct

+ func NewAggOp(child Operator, plan *planner.PhysicalAgg, params []interface{}) *AggOp

+ func (op *AggOp) Close() error

+ func (op *AggOp) Next() (Row, *planner.Schema, error)

+ func (op *AggOp) Open() error

+ type AnalyzeOp struct

+ func NewAnalyzeOp(txn engine.Transaction, cat *catalog.Catalog, plan *planner.PhysicalAnalyze) *AnalyzeOp

+ func (op *AnalyzeOp) Close() error

+ func (op *AnalyzeOp) Next() (Row, *planner.Schema, error)

+ func (op *AnalyzeOp) Open() error

+ type CountStatsOp struct

+ func NewCountStatsOp(txn engine.Transaction, cat *catalog.Catalog, plan *planner.PhysicalCountStats) *CountStatsOp

+ func (op *CountStatsOp) Close() error

+ func (op *CountStatsOp) Next() (Row, *planner.Schema, error)

+ func (op *CountStatsOp) Open() error

+ type CreateIndexOp struct

+ func NewCreateIndexOp(txn engine.Transaction, cat *catalog.Catalog, ...) *CreateIndexOp

+ func (op *CreateIndexOp) Close() error

+ func (op *CreateIndexOp) Next() (Row, *planner.Schema, error)

+ func (op *CreateIndexOp) Open() error

+ type CreateTableOp struct

+ func NewCreateTableOp(txn engine.Transaction, cat *catalog.Catalog, ...) *CreateTableOp

+ func (op *CreateTableOp) Close() error

+ func (op *CreateTableOp) Next() (Row, *planner.Schema, error)

+ func (op *CreateTableOp) Open() error

+ type DeleteOp struct

+ func NewDeleteOp(txn engine.Transaction, cat *catalog.Catalog, child Operator, ...) *DeleteOp

+ func (op *DeleteOp) Close() error

+ func (op *DeleteOp) Next() (Row, *planner.Schema, error)

+ func (op *DeleteOp) Open() error

+ type DropIndexOp struct

+ func NewDropIndexOp(txn engine.Transaction, cat *catalog.Catalog, plan *planner.PhysicalDropIndex) *DropIndexOp

+ func (op *DropIndexOp) Close() error

+ func (op *DropIndexOp) Next() (Row, *planner.Schema, error)

+ func (op *DropIndexOp) Open() error

+ type DropTableOp struct

+ func NewDropTableOp(txn engine.Transaction, cat *catalog.Catalog, plan *planner.PhysicalDropTable) *DropTableOp

+ func (op *DropTableOp) Close() error

+ func (op *DropTableOp) Next() (Row, *planner.Schema, error)

+ func (op *DropTableOp) Open() error

+ type ExecContext struct

+ Cat *catalog.Catalog

+ Params []interface{}

+ Txn engine.Transaction

+ type FilterOp struct

+ func NewFilterOp(child Operator, plan *planner.PhysicalFilter, params []interface{}) *FilterOp

+ func (op *FilterOp) Close() error

+ func (op *FilterOp) Next() (Row, *planner.Schema, error)

+ func (op *FilterOp) Open() error

+ type IndexScanOp struct

+ func NewIndexScanOp(txn engine.Transaction, plan *planner.PhysicalIndexScan) *IndexScanOp

+ func (op *IndexScanOp) Close() error

+ func (op *IndexScanOp) Next() (Row, *planner.Schema, error)

+ func (op *IndexScanOp) Open() error

+ type InsertOp struct

+ func NewInsertOp(txn engine.Transaction, cat *catalog.Catalog, plan *planner.PhysicalInsert, ...) *InsertOp

+ func (op *InsertOp) Close() error

+ func (op *InsertOp) Next() (Row, *planner.Schema, error)

+ func (op *InsertOp) Open() error

+ type LimitOp struct

+ func NewLimitOp(child Operator, plan *planner.PhysicalLimit) *LimitOp

+ func (op *LimitOp) Close() error

+ func (op *LimitOp) Next() (Row, *planner.Schema, error)

+ func (op *LimitOp) Open() error

+ type MultiGetOp struct

+ func NewMultiGetOp(txn engine.Transaction, plan *planner.PhysicalMultiGet) *MultiGetOp

+ func (op *MultiGetOp) Close() error

+ func (op *MultiGetOp) Next() (Row, *planner.Schema, error)

+ func (op *MultiGetOp) Open() error

+ type NLJOp struct

+ func NewNLJOp(left, right Operator, plan *planner.PhysicalNLJ, params []interface{}) *NLJOp

+ func (op *NLJOp) Close() error

+ func (op *NLJOp) Next() (Row, *planner.Schema, error)

+ func (op *NLJOp) Open() error

+ type Operator interface

+ Close func() error

+ Next func() (Row, *planner.Schema, error)

+ Open func() error

+ func Build(ctx *ExecContext, plan planner.PhysicalPlan) (Operator, error)

+ type ProjectOp struct

+ func NewProjectOp(child Operator, plan *planner.PhysicalProject, params []interface{}) *ProjectOp

+ func (op *ProjectOp) Close() error

+ func (op *ProjectOp) Next() (Row, *planner.Schema, error)

+ func (op *ProjectOp) Open() error

+ type Row []interface

+ func (r Row) Bool(idx int) bool

+ func (r Row) Bytes(idx int) []byte

+ func (r Row) Float(idx int) float64

+ func (r Row) Int(idx int) int64

+ func (r Row) IsNull(idx int) bool

+ func (r Row) Scan(dest ...interface{}) error

+ func (r Row) Str(idx int) string

+ type SortOp struct

+ func NewSortOp(child Operator, plan *planner.PhysicalSort, params []interface{}) *SortOp

+ func (op *SortOp) Close() error

+ func (op *SortOp) Next() (Row, *planner.Schema, error)

+ func (op *SortOp) Open() error

+ type TableScanOp struct

+ func NewTableScanOp(txn engine.Transaction, plan *planner.PhysicalTableScan) *TableScanOp

+ func (op *TableScanOp) Close() error

+ func (op *TableScanOp) Next() (Row, *planner.Schema, error)

+ func (op *TableScanOp) Open() error

+ type UpdateOp struct

+ func NewUpdateOp(txn engine.Transaction, child Operator, plan *planner.PhysicalUpdate, ...) *UpdateOp

+ func (op *UpdateOp) Close() error

+ func (op *UpdateOp) Next() (Row, *planner.Schema, error)

+ func (op *UpdateOp) Open() error

+ type VMInstruction struct

+ Arg int

+ Op vmOp

+ type VMProgram struct

+ func Compile(e expr.Expression) (*VMProgram, error)

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