dispatch

type Argument struct {

	// IsSink means this is a Sink Node
	IsSink 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
	ShuffleColIdx       int32
	ShuffleType         int32
	ShuffleColMin       int64
	ShuffleColMax       int64
	ShuffleRegIdxLocal  []int
	ShuffleRegIdxRemote []int
	// contains filtered or unexported fields
}

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