Module org.elasticsearch.compute

Package org.elasticsearch.compute.data.sort

Class BytesRefBucketedSort

java.lang.Object

org.elasticsearch.compute.data.sort.BytesRefBucketedSort

All Implemented Interfaces:

Closeable, AutoCloseable, Releasable

public class BytesRefBucketedSort
extends Object
implements Releasable

Aggregates the top N BytesRef values per bucket. See BucketedSort for more information. This class is generated. Edit @{code X-BucketedSort.java.st} instead of this file.

Constructor Summary

Constructors

Constructor	Description
BytesRefBucketedSort(BigArrays bigArrays, SortOrder order, int bucketSize)

Method Summary

Modifier and Type	Method	Description
final void	close()
void	collect(org.apache.lucene.util.BytesRef value, int bucket)	Collects a value into a bucket.
int	getBucketSize()	The number of values to store per bucket.
SortOrder	getOrder()	The order of the sort.
void	merge(int groupId, BytesRefBucketedSort other, int otherGroupId)	Merge the values from other's otherGroupId into groupId.
Block	toBlock(BlockFactory blockFactory, IntVector selected)	Creates a block with the values from the selected groups.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BytesRefBucketedSort

public BytesRefBucketedSort(BigArrays bigArrays,
 SortOrder order,
 int bucketSize)

Method Details

collect

public void collect(org.apache.lucene.util.BytesRef value,
 int bucket)

Collects a value into a bucket.

It may or may not be inserted in the heap, depending on if it is better than the current root.

getOrder

public SortOrder getOrder()

The order of the sort.

getBucketSize

public int getBucketSize()

The number of values to store per bucket.

merge

public void merge(int groupId,
 BytesRefBucketedSort other,
 int otherGroupId)

Merge the values from other's otherGroupId into groupId.

toBlock

public Block toBlock(BlockFactory blockFactory,
 IntVector selected)

Creates a block with the values from the selected groups.

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Releasable