Module org.elasticsearch.compute

Package org.elasticsearch.compute.aggregation

Class TemporalityAccessor

java.lang.Object

org.elasticsearch.compute.aggregation.TemporalityAccessor

public class TemporalityAccessor
extends Object

Helper class for efficiently resolving metric temporality (CUMULATIVE or DELTA) from a BytesRefBlock. Optimizes for common access patterns by detecting constant blocks, ordinal-based blocks, or falling back to dynamic per-position lookups.

Constructor Summary

Constructors

Constructor	Description
TemporalityAccessor(org.elasticsearch.compute.aggregation.TemporalityAccessor.Mode mode, Temporality constantOrDefaultTemporality, BytesRefBlock temporalityBlock, org.apache.lucene.util.BytesRef scratch, Function<org.apache.lucene.util.BytesRef,Temporality> invalidTemporalityHandler)

Method Summary

Modifier and Type	Method	Description
BytesRefBlock	block()
static TemporalityAccessor	constant(Temporality constantTemporality)	Creates an accessor that always returns the given constant temporality.
static TemporalityAccessor	create(BytesRefBlock temporalityBlock, Temporality defaultTemporality)	Creates an accessor for the given temporality block that throws InvalidTemporalityException when an unrecognized temporality value is encountered.
static TemporalityAccessor	create(BytesRefBlock temporalityBlock, Temporality defaultTemporality, Function<org.apache.lucene.util.BytesRef,Temporality> invalidTemporalityHandler)	Creates an accessor for the given temporality block, automatically selecting the most efficient access mode.
Temporality	get(int position)	Returns the temporality for the given position.

Methods inherited from class java.lang.Object

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

Constructor Details

TemporalityAccessor

public TemporalityAccessor(org.elasticsearch.compute.aggregation.TemporalityAccessor.Mode mode,
 Temporality constantOrDefaultTemporality,
 @Nullable
 BytesRefBlock temporalityBlock,
 @Nullable
 org.apache.lucene.util.BytesRef scratch,
 @Nullable
 Function<org.apache.lucene.util.BytesRef,Temporality> invalidTemporalityHandler)

Method Details

constant

public static TemporalityAccessor constant(Temporality constantTemporality)

Creates an accessor that always returns the given constant temporality.

create

public static TemporalityAccessor create(BytesRefBlock temporalityBlock,
 Temporality defaultTemporality)

Creates an accessor for the given temporality block that throws InvalidTemporalityException when an unrecognized temporality value is encountered.

Parameters:

temporalityBlock - the block containing temporality values as BytesRef strings ("cumulative" or "delta")

defaultTemporality - the temporality to use for null values

create

public static TemporalityAccessor create(BytesRefBlock temporalityBlock,
 Temporality defaultTemporality,
 Function<org.apache.lucene.util.BytesRef,Temporality> invalidTemporalityHandler)

Creates an accessor for the given temporality block, automatically selecting the most efficient access mode.

Parameters:

temporalityBlock - the block containing temporality values as BytesRef strings ("cumulative" or "delta")

defaultTemporality - the temporality to use for null values

invalidTemporalityHandler - called when an unrecognized temporality value is encountered

block

public BytesRefBlock block()

get

public Temporality get(int position)

Returns the temporality for the given position.