executor

package
v0.0.0-...-5265a8e Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2018 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CalHashKey 

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

func RunExecutor 

func RunExecutor(masterAddress string, address, name string)

/////////////////////////////

func ShuffleHash 

func ShuffleHash(s string) int

Types

type Channel 

type Channel struct {
	Name     string
	Port     int32
	IsClosed bool
	Piper    *util.Piper
}

func NewChannel 

func NewChannel() *Channel

type Executor 

type Executor struct {
	sync.Mutex
	AgentAddress string

	Address string
	Name    string

	Instruction                                   *pb.Instruction
	EPlanNode                                     eplan.ENode
	InputLocations, OutputLocations               []*pb.Location
	InputChannelLocations, OutputChannelLocations []*pb.Location
	Readers                                       []io.Reader
	Writers                                       []io.Writer

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

	DoneChan chan int
}

func NewExecutor 

func NewExecutor(agentAddress string, address, name string) *Executor

func (*Executor) AddLogInfo 

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

func (*Executor) CalAggregateFuncGlobal 

func (self *Executor) CalAggregateFuncGlobal(enode *eplan.EPlanAggregateFuncGlobalNode, rg *row.RowsGroup, res *[]map[string]interface{}) error

func (*Executor) CalAggregateFuncLocal 

func (self *Executor) CalAggregateFuncLocal(enode *eplan.EPlanAggregateFuncLocalNode, rg *row.RowsGroup, res *[]map[string]interface{}) error

func (*Executor) CalSelectItems 

func (self *Executor) CalSelectItems(enode *eplan.EPlanSelectNode, rg *row.RowsGroup) (*row.RowsGroup, error)

func (*Executor) CalSortKey 

func (self *Executor) CalSortKey(enode *eplan.EPlanOrderByLocalNode, rg *row.RowsGroup) ([]interface{}, error)

func (*Executor) Clear 

func (self *Executor) Clear()

func (*Executor) DoHeartbeat 

func (self *Executor) DoHeartbeat() error

func (*Executor) Duplicate 

func (self *Executor) Duplicate(ctx context.Context, em *pb.Empty) (*pb.Empty, error)

func (*Executor) GetOrder 

func (self *Executor) GetOrder(enode *eplan.EPlanOrderByNode) []gtype.OrderType

func (*Executor) GetOrderLocal 

func (self *Executor) GetOrderLocal(enode *eplan.EPlanOrderByLocalNode) []gtype.OrderType

func (*Executor) GetOutputChannelLocation 

func (self *Executor) GetOutputChannelLocation(ctx context.Context, location *pb.Location) (*pb.Location, error)

func (*Executor) Heartbeat 

func (self *Executor) Heartbeat()

func (*Executor) Quit 

func (self *Executor) Quit(ctx context.Context, em *pb.Empty) (*pb.Empty, error)

func (*Executor) Restart 

func (self *Executor) Restart(ctx context.Context, em *pb.Empty) (*pb.Empty, error)

func (*Executor) Run 

func (self *Executor) Run(ctx context.Context, empty *pb.Empty) (*pb.Empty, error)

func (*Executor) RunAggregate 

func (self *Executor) RunAggregate() (err error)

func (*Executor) RunAggregateFuncGlobal 

func (self *Executor) RunAggregateFuncGlobal() (err error)

func (*Executor) RunAggregateFuncLocal 

func (self *Executor) RunAggregateFuncLocal() (err error)

func (*Executor) RunBalance 

func (self *Executor) RunBalance() (err error)

func (*Executor) RunDistinctGlobal 

func (self *Executor) RunDistinctGlobal() (err error)

func (*Executor) RunDistinctLocal 

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

func (*Executor) RunDuplicate 

func (self *Executor) RunDuplicate() (err error)

func (*Executor) RunFilter 

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

func (*Executor) RunGroupBy 

func (self *Executor) RunGroupBy() (err error)

func (*Executor) RunHashJoin 

func (self *Executor) RunHashJoin() (err error)

func (*Executor) RunJoin 

func (self *Executor) RunJoin() (err error)

func (*Executor) RunLimit 

func (self *Executor) RunLimit() (err error)

func (*Executor) RunOrderBy 

func (self *Executor) RunOrderBy() (err error)

func (*Executor) RunOrderByLocal 

func (self *Executor) RunOrderByLocal() (err error)

func (*Executor) RunScan 

func (self *Executor) RunScan() (err error)

func (*Executor) RunSelect 

func (self *Executor) RunSelect() (err error)

func (*Executor) RunShow 

func (self *Executor) RunShow() (err error)

func (*Executor) RunShuffle 

func (self *Executor) RunShuffle() (err error)

func (*Executor) RunUnion 

func (self *Executor) RunUnion() (err error)

func (*Executor) SendInstruction 

func (self *Executor) SendInstruction(ctx context.Context, instruction *pb.Instruction) (*pb.Empty, error)

func (*Executor) SendOneHeartbeat 

func (self *Executor) SendOneHeartbeat(stream pb.GueryAgent_SendHeartbeatClient) error

func (*Executor) SetInstructionAggregate 

func (self *Executor) SetInstructionAggregate(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionAggregateFuncGlobal 

func (self *Executor) SetInstructionAggregateFuncGlobal(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionAggregateFuncLocal 

func (self *Executor) SetInstructionAggregateFuncLocal(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionBalance 

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

func (*Executor) SetInstructionDistinctGlobal 

func (self *Executor) SetInstructionDistinctGlobal(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionDistinctLocal 

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

func (*Executor) SetInstructionDuplicate 

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

func (*Executor) SetInstructionFilter 

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

func (*Executor) SetInstructionGroupBy 

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

func (*Executor) SetInstructionHashJoin 

func (self *Executor) SetInstructionHashJoin(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionJoin 

func (self *Executor) SetInstructionJoin(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionLimit 

func (self *Executor) SetInstructionLimit(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionOrderBy 

func (self *Executor) SetInstructionOrderBy(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionOrderByLocal 

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

func (*Executor) SetInstructionScan 

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

func (*Executor) SetInstructionSelect 

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

func (*Executor) SetInstructionShow 

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

func (*Executor) SetInstructionShuffle 

func (self *Executor) SetInstructionShuffle(instruction *pb.Instruction) (err error)

func (*Executor) SetInstructionUnion 

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

func (*Executor) SetRuntime 

func (self *Executor) SetRuntime(instruction *pb.Instruction) (err error)

func (*Executor) SetupReaders 

func (self *Executor) SetupReaders(ctx context.Context, empty *pb.Empty) (*pb.Empty, error)

func (*Executor) SetupWriters 

func (self *Executor) SetupWriters(ctx context.Context, empty *pb.Empty) (*pb.Empty, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.