Package io.opentelemetry.sdk.metrics.internal.exemplar

Class RandomFixedSizeExemplarReservoir.RandomCellSelector

java.lang.Object

io.opentelemetry.sdk.metrics.internal.exemplar.RandomFixedSizeExemplarReservoir.RandomCellSelector

All Implemented Interfaces:

ReservoirCellSelector

Enclosing class:

RandomFixedSizeExemplarReservoir<T extends ExemplarData>

static class RandomFixedSizeExemplarReservoir.RandomCellSelector
extends java.lang.Object
implements ReservoirCellSelector

Field Summary

Fields

Modifier and Type	Field	Description
private LongAdder	numMeasurements
private java.util.function.Supplier<java.util.Random>	randomSupplier

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RandomCellSelector(java.util.function.Supplier<java.util.Random> randomSupplier)

Method Summary

Modifier and Type	Method	Description
private int	reservoirCellIndex(ReservoirCell[] cells)
int	reservoirCellIndexFor(ReservoirCell[] cells, double value, Attributes attributes, Context context)	Determine the index of the cells to record the measurement to.
int	reservoirCellIndexFor(ReservoirCell[] cells, long value, Attributes attributes, Context context)	Determine the index of the cells to record the measurement to.
void	reset()	Called when FixedSizeExemplarReservoir.collectAndReset(Attributes).

Methods inherited from class java.lang.Object

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

Field Detail

numMeasurements

private final LongAdder numMeasurements

randomSupplier

private final java.util.function.Supplier<java.util.Random> randomSupplier

Constructor Detail

RandomCellSelector

private RandomCellSelector(java.util.function.Supplier<java.util.Random> randomSupplier)

Method Detail

reservoirCellIndexFor

public int reservoirCellIndexFor(ReservoirCell[] cells,
                                 long value,
                                 Attributes attributes,
                                 Context context)

Description copied from interface: ReservoirCellSelector

Determine the index of the cells to record the measurement to.

Specified by:

reservoirCellIndexFor in interface ReservoirCellSelector

reservoirCellIndexFor

public int reservoirCellIndexFor(ReservoirCell[] cells,
                                 double value,
                                 Attributes attributes,
                                 Context context)

Description copied from interface: ReservoirCellSelector

Determine the index of the cells to record the measurement to.

Specified by:

reservoirCellIndexFor in interface ReservoirCellSelector

reservoirCellIndex

private int reservoirCellIndex(ReservoirCell[] cells)

reset

public void reset()

Description copied from interface: ReservoirCellSelector

Called when FixedSizeExemplarReservoir.collectAndReset(Attributes).

Specified by:

reset in interface ReservoirCellSelector