Module org.elasticsearch.compute

Package org.elasticsearch.compute.aggregation

Class TDigestStates.SeenGroupingState

java.lang.Object

org.elasticsearch.compute.aggregation.TDigestStates.SeenGroupingState

All Implemented Interfaces:

Closeable, AutoCloseable, GroupingAggregatorState, Releasable

Enclosing class:

TDigestStates

public static final class TDigestStates.SeenGroupingState
extends Object
implements GroupingAggregatorState

A grouping state holding a single TDigestHolder per group, without a sort key. The intermediate state contains two values: the tdigest, then a boolean seen flag.

Method Summary

Modifier and Type	Method	Description
void	close()
void	enableGroupIdTracking(SeenGroupIds seenGroupIds)
Block	evaluateFinalTDigests(IntVector selected, DriverContext driverContext)
boolean	seen(int groupId)
void	set(int groupId, TDigestHolder tdigest)
void	toIntermediate(Block[] blocks, int offset, IntVector selected, DriverContext driverContext)

Methods inherited from class java.lang.Object

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

Method Details

set

public void set(int groupId,
 TDigestHolder tdigest)

toIntermediate

public void toIntermediate(Block[] blocks,
 int offset,
 IntVector selected,
 DriverContext driverContext)

seen

public boolean seen(int groupId)

evaluateFinalTDigests

public Block evaluateFinalTDigests(IntVector selected,
 DriverContext driverContext)

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Releasable

enableGroupIdTracking

public void enableGroupIdTracking(SeenGroupIds seenGroupIds)

Specified by:

enableGroupIdTracking in interface GroupingAggregatorState