dispatch

Documentation

Index

• Constants
• func Call(idx int, proc *process.Process, arg any, isFirst bool, isLast bool) (process.ExecStatus, error)
• func Prepare(proc *process.Process, arg any) error
• func String(arg any, buf *bytes.Buffer)
• type Argument
  • func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)
• type WrapperClientSession

Constants

const (

	// send to all reg functions
	SendToAllLocalFunc = iota
	SendToAllRemoteFunc
	SendToAllFunc

	// send to any reg functions
	SendToAnyLocalFunc
	SendToAnyRemoteFunc
	SendToAnyFunc

	//shuffle to all reg functions
	ShuffleToAllFunc
)

Functions

func Call

func Call(idx int, proc *process.Process, arg any, isFirst bool, isLast bool) (process.ExecStatus, error)

func Prepare

func Prepare(proc *process.Process, arg any) error

func String

func String(arg any, buf *bytes.Buffer)

Types

type Argument

type Argument struct {

	// IsSink means this is a Sink Node
	IsSink bool
	// RecSink means this is a Recursive Sink Node
	RecSink bool
	// FuncId means the sendFunc you want to call
	FuncId int
	// LocalRegs means the local register you need to send to.
	LocalRegs []*process.WaitRegister
	// RemoteRegs specific the remote reg you need to send to.
	RemoteRegs []colexec.ReceiveInfo
	// for shuffle dispatch
	ShuffleType         int32
	ShuffleRegIdxLocal  []int
	ShuffleRegIdxRemote []int
	// contains filtered or unexported fields
}

func (*Argument) Free

func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)

type WrapperClientSession

type WrapperClientSession struct {
	// contains filtered or unexported fields
}