executor

package
Version: v1.0.7 Latest Latest
Warning

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

Go to latest
Published: Jul 20, 2019 License: GPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AggregateExecutor

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

AggregateExecutor represents aggregate executor. Including: COUNT/MAX/MIN/SUM/AVG/GROUPBY.

func NewAggregateExecutor

func NewAggregateExecutor(log *xlog.Log, plan planner.Plan) *AggregateExecutor

NewAggregateExecutor creates new AggregateExecutor.

func (*AggregateExecutor) Execute

func (executor *AggregateExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type DDLExecutor

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

DDLExecutor represents a CREATE, ALTER, DROP executor

func NewDDLExecutor

func NewDDLExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *DDLExecutor

NewDDLExecutor creates DDL executor.

func (*DDLExecutor) Execute

func (executor *DDLExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type DeleteExecutor

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

DeleteExecutor represents delete executor

func NewDeleteExecutor

func NewDeleteExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *DeleteExecutor

NewDeleteExecutor creates new delete executor.

func (*DeleteExecutor) Execute

func (executor *DeleteExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type Executor

type Executor interface {
	Execute(*xcontext.ResultContext) error
}

Executor interface.

type InsertExecutor

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

InsertExecutor represents insert executor

func NewInsertExecutor

func NewInsertExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *InsertExecutor

NewInsertExecutor creates new insert executor.

func (*InsertExecutor) Execute

func (executor *InsertExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type JoinEngine added in v1.0.7

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

JoinEngine represents join executor.

func NewJoinEngine added in v1.0.7

func NewJoinEngine(log *xlog.Log, node *planner.JoinNode, txn backend.Transaction) *JoinEngine

NewJoinEngine creates the new join executor.

type LimitExecutor

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

LimitExecutor represents limit executor.

func NewLimitExecutor

func NewLimitExecutor(log *xlog.Log, plan planner.Plan) *LimitExecutor

NewLimitExecutor creates the new limit executor.

func (*LimitExecutor) Execute

func (executor *LimitExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type MergeEngine added in v1.0.7

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

MergeEngine represents merge executor.

func NewMergeEngine added in v1.0.7

func NewMergeEngine(log *xlog.Log, node *planner.MergeNode, txn backend.Transaction) *MergeEngine

NewMergeEngine creates the new merge executor.

type OrderByExecutor

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

OrderByExecutor represents order by executor.

func NewOrderByExecutor

func NewOrderByExecutor(log *xlog.Log, plan planner.Plan) *OrderByExecutor

NewOrderByExecutor creates new orderby executor.

func (*OrderByExecutor) Execute

func (executor *OrderByExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type OthersExecutor added in v1.0.6

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

OthersExecutor -- represents special executor.

func NewOthersExecutor added in v1.0.6

func NewOthersExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *OthersExecutor

NewOthersExecutor -- creates new others executor.

func (*OthersExecutor) Execute added in v1.0.6

func (executor *OthersExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type PlanEngine added in v1.0.7

type PlanEngine interface {
	// contains filtered or unexported methods
}

PlanEngine interface.

type SelectExecutor

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

SelectExecutor represents select executor

func NewSelectExecutor

func NewSelectExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *SelectExecutor

NewSelectExecutor creates the new select executor.

func (*SelectExecutor) Execute

func (executor *SelectExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type Tree

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

Tree is a container for all executors

func NewTree

func NewTree(log *xlog.Log, planTree *planner.PlanTree, txn backend.Transaction) *Tree

NewTree creates the new execute tree.

func (*Tree) Add

func (et *Tree) Add(executor Executor) error

Add adds a executor to the tree

func (*Tree) Execute

func (et *Tree) Execute() (*sqltypes.Result, error)

Execute executes all Executor.Execute

type UnionEngine added in v1.0.7

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

UnionEngine represents merge executor.

func NewUnionEngine added in v1.0.7

func NewUnionEngine(log *xlog.Log, node *planner.UnionNode, txn backend.Transaction) *UnionEngine

NewUnionEngine creates the new union executor.

type UnionExecutor added in v1.0.7

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

UnionExecutor represents select executor

func NewUnionExecutor added in v1.0.7

func NewUnionExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *UnionExecutor

NewUnionExecutor creates the new select executor.

func (*UnionExecutor) Execute added in v1.0.7

func (executor *UnionExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

type UpdateExecutor

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

UpdateExecutor represents update executor

func NewUpdateExecutor

func NewUpdateExecutor(log *xlog.Log, plan planner.Plan, txn backend.Transaction) *UpdateExecutor

NewUpdateExecutor creates the new update executor.

func (*UpdateExecutor) Execute

func (executor *UpdateExecutor) Execute(ctx *xcontext.ResultContext) error

Execute used to execute the executor.

Jump to

Keyboard shortcuts

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