executor

Documentation

Index

• func CalHashKey(es []*planner.ExpressionNode, rg *row.RowsGroup) (string, error)
• func Delete(name string)
• func ShuffleHash(s string) int
• type Executor
  • func Get(name string) (*Executor, error)
  • func New(name string) *Executor
  • func (e *Executor) AddLogInfo(info interface{}, level pb.LogLevel)
  • func (e *Executor) CalAggregateFuncGlobal(job *stage.AggregateFuncGlobalJob, rg *row.RowsGroup, ...) error
  • func (e *Executor) CalAggregateFuncLocal(job *stage.AggregateFuncLocalJob, rg *row.RowsGroup, ...) error
  • func (e *Executor) CalSelectItems(job *stage.SelectJob, rg *row.RowsGroup) (*row.RowsGroup, error)
  • func (e *Executor) CalSortKey(job *stage.OrderByLocalJob, rg *row.RowsGroup) ([]interface{}, error)
  • func (e *Executor) Clear()
  • func (e *Executor) GetOrder(job *stage.OrderByJob) []datatype.OrderType
  • func (e *Executor) GetOrderLocal(job *stage.OrderByLocalJob) []datatype.OrderType
  • func (e *Executor) Run(ctx context.Context) error
  • func (e *Executor) RunAggregate() error
  • func (e *Executor) RunAggregateFuncGlobal() error
  • func (e *Executor) RunAggregateFuncLocal() error
  • func (e *Executor) RunBalance() error
  • func (e *Executor) RunDistinctGlobal() error
  • func (e *Executor) RunDistinctLocal() (err error)
  • func (e *Executor) RunDuplicate() error
  • func (e *Executor) RunFilter() (err error)
  • func (e *Executor) RunGroupBy() error
  • func (e *Executor) RunHashJoin() error
  • func (e *Executor) RunInsert() error
  • func (e *Executor) RunInserted() error
  • func (e *Executor) RunJoin() error
  • func (e *Executor) RunLimit() error
  • func (e *Executor) RunOrderBy() error
  • func (e *Executor) RunOrderByLocal() error
  • func (e *Executor) RunScan() error
  • func (e *Executor) RunSelect() error
  • func (e *Executor) RunShow() error
  • func (e *Executor) RunShuffle() error
  • func (e *Executor) RunUnion() error
  • func (e *Executor) SendInstruction(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionAggregate(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionAggregateFuncGlobal(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionAggregateFuncLocal(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionBalance(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionDistinctGlobal(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionDistinctLocal(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionDuplicate(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionFilter(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionGroupBy(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionHashJoin(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionInsert(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionInserted(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionJoin(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionLimit(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionOrderBy(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionOrderByLocal(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionScan(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionSelect(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetInstructionShow(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionShuffle(instruction *pb.Instruction) error
  • func (e *Executor) SetInstructionUnion(instruction *pb.Instruction) (err error)
  • func (e *Executor) SetupPipe() error

Functions

func CalHashKey

func CalHashKey(es []*planner.ExpressionNode, rg *row.RowsGroup) (string, error)

func Delete

func Delete(name string)

func ShuffleHash

func ShuffleHash(s string) int

Types

type Executor

type Executor struct {
	sync.Mutex
	Name string

	Instruction *pb.Instruction
	StageJob    stage.Job
	Readers     []io.Reader
	Writers     []io.Writer

	Status          pb.TaskStatus
	IsStatusChanged bool
	Infos           []*pb.LogInfo
}

func Get

func Get(name string) (*Executor, error)

func New

func New(name string) *Executor

func (*Executor) AddLogInfo

func (e *Executor) AddLogInfo(info interface{}, level pb.LogLevel)

func (*Executor) CalAggregateFuncGlobal

func (e *Executor) CalAggregateFuncGlobal(job *stage.AggregateFuncGlobalJob, rg *row.RowsGroup, res *[]map[string]interface{}) error

func (*Executor) CalAggregateFuncLocal

func (e *Executor) CalAggregateFuncLocal(job *stage.AggregateFuncLocalJob, rg *row.RowsGroup, res *[]map[string]interface{}) error

func (*Executor) CalSelectItems

func (e *Executor) CalSelectItems(job *stage.SelectJob, rg *row.RowsGroup) (*row.RowsGroup, error)

func (*Executor) CalSortKey

func (e *Executor) CalSortKey(job *stage.OrderByLocalJob, rg *row.RowsGroup) ([]interface{}, error)

func (*Executor) Clear

func (e *Executor) Clear()

func (*Executor) GetOrder

func (e *Executor) GetOrder(job *stage.OrderByJob) []datatype.OrderType

func (*Executor) GetOrderLocal

func (e *Executor) GetOrderLocal(job *stage.OrderByLocalJob) []datatype.OrderType

func (*Executor) Run

func (e *Executor) Run(ctx context.Context) error

func (*Executor) RunAggregate

func (e *Executor) RunAggregate() error

func (*Executor) RunAggregateFuncGlobal

func (e *Executor) RunAggregateFuncGlobal() error

func (*Executor) RunAggregateFuncLocal

func (e *Executor) RunAggregateFuncLocal() error

func (*Executor) RunBalance

func (e *Executor) RunBalance() error

func (*Executor) RunDistinctGlobal

func (e *Executor) RunDistinctGlobal() error

func (*Executor) RunDistinctLocal

func (e *Executor) RunDistinctLocal() (err error)

func (*Executor) RunDuplicate

func (e *Executor) RunDuplicate() error

func (*Executor) RunFilter

func (e *Executor) RunFilter() (err error)

func (*Executor) RunGroupBy

func (e *Executor) RunGroupBy() error

func (*Executor) RunHashJoin

func (e *Executor) RunHashJoin() error

func (*Executor) RunInsert

func (e *Executor) RunInsert() error

func (*Executor) RunInserted

func (e *Executor) RunInserted() error

func (*Executor) RunJoin

func (e *Executor) RunJoin() error

func (*Executor) RunLimit

func (e *Executor) RunLimit() error

func (*Executor) RunOrderBy

func (e *Executor) RunOrderBy() error

func (*Executor) RunOrderByLocal

func (e *Executor) RunOrderByLocal() error

func (*Executor) RunScan

func (e *Executor) RunScan() error

func (*Executor) RunSelect

func (e *Executor) RunSelect() error

func (*Executor) RunShow

func (e *Executor) RunShow() error

func (*Executor) RunShuffle

func (e *Executor) RunShuffle() error

func (*Executor) RunUnion

func (e *Executor) RunUnion() error

func (*Executor) SendInstruction

func (e *Executor) SendInstruction(instruction *pb.Instruction) error

func (*Executor) SetInstructionAggregate

func (e *Executor) SetInstructionAggregate(instruction *pb.Instruction) error

func (*Executor) SetInstructionAggregateFuncGlobal

func (e *Executor) SetInstructionAggregateFuncGlobal(instruction *pb.Instruction) error

func (*Executor) SetInstructionAggregateFuncLocal

func (e *Executor) SetInstructionAggregateFuncLocal(instruction *pb.Instruction) error

func (*Executor) SetInstructionBalance

func (e *Executor) SetInstructionBalance(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionDistinctGlobal

func (e *Executor) SetInstructionDistinctGlobal(instruction *pb.Instruction) error

func (*Executor) SetInstructionDistinctLocal

func (e *Executor) SetInstructionDistinctLocal(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionDuplicate

func (e *Executor) SetInstructionDuplicate(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionFilter

func (e *Executor) SetInstructionFilter(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionGroupBy

func (e *Executor) SetInstructionGroupBy(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionHashJoin

func (e *Executor) SetInstructionHashJoin(instruction *pb.Instruction) error

func (*Executor) SetInstructionInsert

func (e *Executor) SetInstructionInsert(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionInserted

func (e *Executor) SetInstructionInserted(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionJoin

func (e *Executor) SetInstructionJoin(instruction *pb.Instruction) error

func (*Executor) SetInstructionLimit

func (e *Executor) SetInstructionLimit(instruction *pb.Instruction) error

func (*Executor) SetInstructionOrderBy

func (e *Executor) SetInstructionOrderBy(instruction *pb.Instruction) error

func (*Executor) SetInstructionOrderByLocal

func (e *Executor) SetInstructionOrderByLocal(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionScan

func (e *Executor) SetInstructionScan(instruction *pb.Instruction) error

func (*Executor) SetInstructionSelect

func (e *Executor) SetInstructionSelect(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionShow

func (e *Executor) SetInstructionShow(instruction *pb.Instruction) error

func (*Executor) SetInstructionShuffle

func (e *Executor) SetInstructionShuffle(instruction *pb.Instruction) error

func (*Executor) SetInstructionUnion

func (e *Executor) SetInstructionUnion(instruction *pb.Instruction) (err error)

func (*Executor) SetupPipe

func (e *Executor) SetupPipe() error