Module org.elasticsearch.compute

Package org.elasticsearch.compute.operator

Class DistinctByOperator

java.lang.Object

org.elasticsearch.compute.operator.AbstractPageMappingOperator

org.elasticsearch.compute.operator.DistinctByOperator

All Implemented Interfaces:

Closeable, AutoCloseable, Operator, org.elasticsearch.core.Releasable

public class DistinctByOperator
extends AbstractPageMappingOperator

Operator that filters rows to keep only the first occurrence of each distinct key value. This is useful for deduplication by a key column (e.g., _tsid).

The operator maintains a hash of seen key values and only passes through rows where the key value hasn't been seen before.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	DistinctByOperator.Factory

Nested classes/interfaces inherited from class org.elasticsearch.compute.operator.AbstractPageMappingOperator

AbstractPageMappingOperator.Status

Nested classes/interfaces inherited from interface org.elasticsearch.compute.operator.Operator

Operator.OperatorFactory

Field Summary

Fields inherited from interface org.elasticsearch.compute.operator.Operator

MIN_TARGET_PAGE_SIZE, NOT_BLOCKED, TARGET_PAGE_SIZE

Constructor Summary

Constructors

Constructor	Description
DistinctByOperator(int keyChannel, BlockFactory blockFactory)

Method Summary

Modifier and Type	Method	Description
void	close()	notifies the operator that it won't be used anymore (i.e.
protected Page	process(Page page)
String	toString()

Methods inherited from class org.elasticsearch.compute.operator.AbstractPageMappingOperator

addInput, canProduceMoreDataWithoutExtraInput, finish, getOutput, isFinished, needsInput, status, status

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.compute.operator.Operator

isBlocked

Constructor Details

DistinctByOperator

public DistinctByOperator(int keyChannel,
 BlockFactory blockFactory)

Method Details

process

protected Page process(Page page)

Specified by:

process in class AbstractPageMappingOperator

toString

public String toString()

Specified by:

toString in class AbstractPageMappingOperator

close

public void close()

Description copied from interface: Operator

notifies the operator that it won't be used anymore (i.e. none of the other methods called), and its resources can be cleaned up

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Operator

Specified by:

close in interface org.elasticsearch.core.Releasable

Overrides:

close in class AbstractPageMappingOperator