Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ExecSubPlan ¶
ExecSubPlan used to execute all the children plan.
Types ¶
type AggregateOperator ¶
type AggregateOperator struct {
// contains filtered or unexported fields
}
AggregateOperator represents aggregate operator. Including: COUNT/MAX/MIN/SUM/AVG/GROUPBY.
func NewAggregateOperator ¶
func NewAggregateOperator(log *xlog.Log, plan builder.ChildPlan) *AggregateOperator
NewAggregateOperator creates new AggregateOperator.
func (*AggregateOperator) Execute ¶
func (operator *AggregateOperator) Execute(ctx *xcontext.ResultContext) error
Execute used to execute the operator.
type LimitOperator ¶
type LimitOperator struct {
// contains filtered or unexported fields
}
LimitOperator represents limit operator.
func NewLimitOperator ¶
func NewLimitOperator(log *xlog.Log, plan builder.ChildPlan) *LimitOperator
NewLimitOperator creates the new limit operator.
func (*LimitOperator) Execute ¶
func (operator *LimitOperator) Execute(ctx *xcontext.ResultContext) error
Execute used to execute the operator.
type Operator ¶
type Operator interface {
Execute(*xcontext.ResultContext) error
}
Operator interface.
type OrderByOperator ¶
type OrderByOperator struct {
// contains filtered or unexported fields
}
OrderByOperator represents order by operator.
func NewOrderByOperator ¶
func NewOrderByOperator(log *xlog.Log, plan builder.ChildPlan) *OrderByOperator
NewOrderByOperator creates new orderby operator.
func (*OrderByOperator) Execute ¶
func (operator *OrderByOperator) Execute(ctx *xcontext.ResultContext) error
Execute used to execute the operator.
Source Files
Click to show internal directories.
Click to hide internal directories.