shuffleV2

package

v0.0.0-debug-20260702 Latest Latest Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/matrixorigin/matrixone

Links

Open Source Insights

Documentation ¶

Index ¶

type ShufflePoolV2
- func NewShufflePool(bucketNum int32, maxHolders int32) *ShufflePoolV2
- func (sp *ShufflePoolV2) DebugPrint()
- func (sp *ShufflePoolV2) Reset(m *mpool.MPool)
type ShuffleV2
- func NewArgument() *ShuffleV2

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ShufflePoolV2 ¶

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

func NewShufflePool ¶

func NewShufflePool(bucketNum int32, maxHolders int32) *ShufflePoolV2

func (*ShufflePoolV2) DebugPrint ¶

func (sp *ShufflePoolV2) DebugPrint()

func (*ShufflePoolV2) Reset ¶

func (sp *ShufflePoolV2) Reset(m *mpool.MPool)

type ShuffleV2 ¶

type ShuffleV2 struct {
	CurrentShuffleIdx  int32
	ShuffleColIdx      int32
	ShuffleType        int32
	BucketNum          int32
	ShuffleColMin      int64
	ShuffleColMax      int64
	ShuffleRangeUint64 []uint64
	ShuffleRangeInt64  []int64
	ShuffleExpr        *plan.Expr
	IsDebug            bool //used for unit test
	vm.OperatorBase
	// contains filtered or unexported fields
}

func NewArgument ¶

func NewArgument() *ShuffleV2

func (*ShuffleV2) Call ¶

func (shuffle *ShuffleV2) Call(proc *process.Process) (vm.CallResult, error)

func (*ShuffleV2) ExecProjection ¶

func (shuffle *ShuffleV2) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)

func (*ShuffleV2) Free ¶

func (shuffle *ShuffleV2) Free(proc *process.Process, pipelineFailed bool, err error)

func (*ShuffleV2) GetOperatorBase ¶

func (shuffle *ShuffleV2) GetOperatorBase() *vm.OperatorBase

func (*ShuffleV2) GetShufflePool ¶

func (shuffle *ShuffleV2) GetShufflePool() *ShufflePoolV2

func (*ShuffleV2) OpType ¶

func (shuffle *ShuffleV2) OpType() vm.OpType

func (*ShuffleV2) Prepare ¶

func (shuffle *ShuffleV2) Prepare(proc *process.Process) error

func (*ShuffleV2) Release ¶

func (shuffle *ShuffleV2) Release()

func (*ShuffleV2) Reset ¶

func (shuffle *ShuffleV2) Reset(proc *process.Process, pipelineFailed bool, err error)

func (*ShuffleV2) SetShufflePool ¶

func (shuffle *ShuffleV2) SetShufflePool(sp *ShufflePoolV2)

func (*ShuffleV2) String ¶

func (shuffle *ShuffleV2) String(buf *bytes.Buffer)

func (ShuffleV2) TypeName ¶

func (shuffle ShuffleV2) TypeName() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL