mergeutil

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.