Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v1.2.0
func NewArgument() *Argument
func (*Argument) Call ¶ added in v1.1.0
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) GetOperatorBase ¶ added in v1.2.0
func (arg *Argument) GetOperatorBase() *vm.OperatorBase
Source Files
Click to show internal directories.
Click to hide internal directories.