shuffle

Documentation

Index

• type Argument
  • func NewArgument() *Argument
  • func (arg *Argument) Call(proc *process.Process) (vm.CallResult, error)
  • func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error)
  • func (arg *Argument) GetOperatorBase() *vm.OperatorBase
  • func (arg *Argument) Prepare(proc *process.Process) error
  • func (arg *Argument) Release()
  • func (arg *Argument) String(buf *bytes.Buffer)
  • func (arg Argument) TypeName() string

Types

type Argument

type Argument struct {
	ShuffleColIdx      int32
	ShuffleType        int32
	AliveRegCnt        int32
	ShuffleColMin      int64
	ShuffleColMax      int64
	ShuffleRangeUint64 []uint64
	ShuffleRangeInt64  []int64

	vm.OperatorBase
	// contains filtered or unexported fields
}

func NewArgument

func NewArgument() *Argument

func (*Argument) Call

func (arg *Argument) Call(proc *process.Process) (vm.CallResult, error)

there are two ways for shuffle to send a batch if a batch belongs to one bucket, send this batch directly, and shuffle need to do nothing else split this batch into pieces, write data into pool. if one bucket is full, send this bucket. next time, set this bucket rowcount to 0 and reuse it for now, we shuffle null to the first bucket

func (*Argument) Free

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

func (*Argument) GetOperatorBase

func (arg *Argument) GetOperatorBase() *vm.OperatorBase

func (*Argument) Prepare

func (arg *Argument) Prepare(proc *process.Process) error

func (*Argument) Release

func (arg *Argument) Release()

func (*Argument) String

func (arg *Argument) String(buf *bytes.Buffer)

func (Argument) TypeName

func (arg Argument) TypeName() string