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 JoinExecutor ¶
type JoinExecutor struct {
// contains filtered or unexported fields
}
JoinExecutor tuple.
func NewJoinExecutor ¶
func NewJoinExecutor(log *xlog.Log, plan planner.Plan) *JoinExecutor
NewJoinExecutor creates new join executor.
func (*JoinExecutor) Execute ¶
func (executor *JoinExecutor) Execute(ctx *xcontext.ResultContext) error
Execute used to execute the 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 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 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 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