group

package

v0.0.0-debug-20260702 Latest Latest Go to latest Published: Jul 2, 2026 License: Apache-2.0 Imports: 26 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 ¶

Constants
func GetKeyWidth(id types.T, width0 int32, nullable bool) (width int)
type Group
- func NewArgument() *Group
type MergeGroup
- func NewArgumentMergeGroup() *MergeGroup
type ResHashRelated

Constants ¶

View Source

const (
	H0 = iota
	H8
	HStr
)

Variables ¶

This section is empty.

Functions ¶

func GetKeyWidth ¶

func GetKeyWidth(id types.T, width0 int32, nullable bool) (width int)

Types ¶

type Group ¶

type Group struct {
	vm.OperatorBase
	colexec.Projection

	NeedEval bool
	SpillMem int64

	// group-by column.
	GroupBy      []*plan.Expr
	GroupingFlag []bool

	Aggs []aggexec.AggFuncExecExpression
	// contains filtered or unexported fields
}

Group the group operator using new implement.

func NewArgument ¶ added in v1.2.0

func NewArgument() *Group

func (*Group) AnyDistinctAgg ¶

func (group *Group) AnyDistinctAgg() bool

func (*Group) Call ¶

func (group *Group) Call(proc *process.Process) (vm.CallResult, error)

main entry of the group operator.

func (*Group) ExecProjection ¶

func (group *Group) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)

func (*Group) Free ¶

func (group *Group) Free(proc *process.Process, _ bool, _ error)

func (*Group) GetOperatorBase ¶

func (group *Group) GetOperatorBase() *vm.OperatorBase

func (*Group) OpType ¶

func (group *Group) OpType() vm.OpType

func (*Group) Prepare ¶

func (group *Group) Prepare(proc *process.Process) (err error)

func (*Group) Release ¶

func (group *Group) Release()

func (*Group) Reset ¶

func (group *Group) Reset(proc *process.Process, pipelineFailed bool, err error)

func (*Group) String ¶

func (group *Group) String(buf *bytes.Buffer)

func (Group) TypeName ¶

func (group Group) TypeName() string

type MergeGroup ¶

type MergeGroup struct {
	vm.OperatorBase
	colexec.Projection

	SpillMem int64

	Aggs []aggexec.AggFuncExecExpression

	PartialResults     []any
	PartialResultTypes []types.T
	// contains filtered or unexported fields
}

func NewArgumentMergeGroup ¶

func NewArgumentMergeGroup() *MergeGroup

func (*MergeGroup) Call ¶

func (mergeGroup *MergeGroup) Call(proc *process.Process) (vm.CallResult, error)

func (*MergeGroup) ExecProjection ¶

func (mergeGroup *MergeGroup) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)

func (*MergeGroup) Free ¶

func (mergeGroup *MergeGroup) Free(proc *process.Process, _ bool, _ error)

func (*MergeGroup) GetOperatorBase ¶

func (mergeGroup *MergeGroup) GetOperatorBase() *vm.OperatorBase

func (*MergeGroup) OpType ¶

func (mergeGroup *MergeGroup) OpType() vm.OpType

func (*MergeGroup) Prepare ¶

func (mergeGroup *MergeGroup) Prepare(proc *process.Process) error

func (*MergeGroup) Release ¶

func (mergeGroup *MergeGroup) Release()

func (*MergeGroup) Reset ¶

func (mergeGroup *MergeGroup) Reset(proc *process.Process, _ bool, _ error)

func (*MergeGroup) String ¶

func (mergeGroup *MergeGroup) String(buf *bytes.Buffer)

func (MergeGroup) TypeName ¶

func (mergeGroup MergeGroup) TypeName() string

type ResHashRelated ¶

type ResHashRelated struct {
	Hash hashmap.HashMap
	Itr  hashmap.Iterator
	// contains filtered or unexported fields
}

func (*ResHashRelated) BuildHashTable ¶

func (hr *ResHashRelated) BuildHashTable(
	ctx context.Context, mp *mpool.MPool,
	rebuild bool,
	isStrHash bool, keyNullable bool, preAllocated uint64) error

func (*ResHashRelated) Free0 ¶

func (hr *ResHashRelated) Free0()

func (*ResHashRelated) GetBinaryInsertList ¶

func (hr *ResHashRelated) GetBinaryInsertList(vals []uint64, before uint64) (insertList []uint8, insertCount uint64)

func (*ResHashRelated) IsEmpty ¶

func (hr *ResHashRelated) IsEmpty() bool

Source Files ¶

View all Source files

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