Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator.mvdedupe

Class TopNMultivalueDedupeBytesRef

java.lang.Object

org.elasticsearch.compute.operator.mvdedupe.TopNMultivalueDedupeBytesRef

public class TopNMultivalueDedupeBytesRef
extends Object

Removes duplicate values from multivalued positions, and keeps only the ones that pass the predicate.

Clone of MultivalueDedupeBytesRef, but it accepts a predicate and nulls flag to filter the values in a top-N aggregation context. Values not in the top-N produce null group ids so the corresponding aggregator state is never allocated.

Constructor Summary

Constructors

Constructor	Description
TopNMultivalueDedupeBytesRef(BytesRefBlock block, boolean acceptNulls, Predicate<org.apache.lucene.util.BytesRef> isAcceptable)

Method Summary

Modifier and Type	Method	Description
MultivalueDedupe.HashResult	hashAdd(BlockFactory blockFactory, BytesRefHashTable hash)	Dedupe values, add them to the hash, and build an IntBlock of their hashes.
IntBlock	hashLookup(BlockFactory blockFactory, BytesRefHashTable hash)	Dedupe values and build an IntBlock of their hashes.

Methods inherited from class java.lang.Object

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

Constructor Details

TopNMultivalueDedupeBytesRef

public TopNMultivalueDedupeBytesRef(BytesRefBlock block,
 boolean acceptNulls,
 Predicate<org.apache.lucene.util.BytesRef> isAcceptable)

Method Details

hashAdd

public MultivalueDedupe.HashResult hashAdd(BlockFactory blockFactory,
 BytesRefHashTable hash)

Dedupe values, add them to the hash, and build an IntBlock of their hashes. This block is suitable for passing as the grouping block to a GroupingAggregatorFunction.

hashLookup

public IntBlock hashLookup(BlockFactory blockFactory,
 BytesRefHashTable hash)

Dedupe values and build an IntBlock of their hashes. This block is suitable for passing as the grouping block to a GroupingAggregatorFunction.