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 Object
implements ReservoirCellSelector

Field Summary

Fields

Modifier and Type	Field	Description
private final LongAdder	numMeasurements
private final Supplier<Random>	randomSupplier

Constructor Summary

Constructors

Modifier	Constructor	Description
private	RandomCellSelector(Supplier<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 Details

numMeasurements

private final LongAdder numMeasurements

randomSupplier

private final Supplier<Random> randomSupplier

Constructor Details

RandomCellSelector

private RandomCellSelector(Supplier<Random> randomSupplier)

Method Details

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