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
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.
Source Files