operator

package
Version: v1.1.4 Latest Latest
Warning

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

Go to latest
Published: Jan 28, 2021 License: GPL-3.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ExecSubPlan

func ExecSubPlan(log *xlog.Log, node builder.PlanNode, ctx *xcontext.ResultContext) error

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.

Jump to

Keyboard shortcuts

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