mergeutil

Documentation

Index

• func MergeSortBatches(batches []*batch.Batch, sortKeyIdx int, buffer *batch.Batch, sinker SinkerT, ...) (*batch.Batch, error)
• func SortColumnsByIndex(cols []*vector.Vector, sortIdx int, mp *mpool.MPool) (err error)
• func SortColumnsByIndexWithBuf(cols []*vector.Vector, sortIdx int, mp *mpool.MPool, idxBuf *[]int64, ...) (err error)
• type SinkerT

Functions

func MergeSortBatches

func MergeSortBatches(
	batches []*batch.Batch,
	sortKeyIdx int,
	buffer *batch.Batch,
	sinker SinkerT,
	mp *mpool.MPool,
	putBack func(int),
) (*batch.Batch, error)

func SortColumnsByIndex

func SortColumnsByIndex(
	cols []*vector.Vector, sortIdx int, mp *mpool.MPool,
) (err error)

func SortColumnsByIndexWithBuf

func SortColumnsByIndexWithBuf(
	cols []*vector.Vector, sortIdx int, mp *mpool.MPool, idxBuf *[]int64, shuffleBuf *[]byte,
) (err error)

SortColumnsByIndexWithBuf sorts all columns by the sort key column at sortIdx. idxBuf is a scratch buffer for the permutation index array; shuffleBuf is a scratch buffer for the shuffle operation. Both are grown as needed and retained across calls for reuse.

Types

type SinkerT

type SinkerT func(*batch.Batch) (*batch.Batch, error)

SinkerT takes ownership of the full buffer and returns a clean, empty replacement batch (with capacity retained) for MergeSortBatches to fill.