Package io.opentelemetry.sdk.metrics.internal.aggregator

Class DoubleSumAggregator

java.lang.Object

io.opentelemetry.sdk.metrics.internal.aggregator.AbstractSumAggregator<DoublePointData,DoubleExemplarData>

io.opentelemetry.sdk.metrics.internal.aggregator.DoubleSumAggregator

All Implemented Interfaces:

Aggregator<DoublePointData,DoubleExemplarData>

public final class DoubleSumAggregator
extends AbstractSumAggregator<DoublePointData,DoubleExemplarData>

Sum aggregator that keeps values as doubles.

This class is internal and is hence not for public use. Its APIs are unstable and can change at any time.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	DoubleSumAggregator.Handle

Field Summary

Fields

Modifier and Type	Field	Description
private final MemoryMode	memoryMode
private final Supplier<ExemplarReservoir<DoubleExemplarData>>	reservoirSupplier

Constructor Summary

Constructors

Constructor	Description
DoubleSumAggregator(InstrumentDescriptor instrumentDescriptor, Supplier<ExemplarReservoir<DoubleExemplarData>> reservoirSupplier, MemoryMode memoryMode)	Constructs a sum aggregator.

Method Summary

Modifier and Type	Method	Description
void	copyPoint(DoublePointData point, DoublePointData toReusablePoint)	Copies point into toReusablePoint.
AggregatorHandle<DoublePointData,DoubleExemplarData>	createHandle()	Returns a new AggregatorHandle.
DoublePointData	createReusablePoint()	Creates a new reusable point.
DoublePointData	diff(DoublePointData previousPoint, DoublePointData currentPoint)	Returns a new DELTA point by computing the difference between two cumulative points.
void	diffInPlace(DoublePointData previousReusablePoint, DoublePointData currentPoint)	Resets one reusable point to be a DELTA point by computing the difference between two cumulative points.
MetricData	toMetricData(Resource resource, InstrumentationScopeInfo instrumentationScopeInfo, MetricDescriptor descriptor, Collection<DoublePointData> points, AggregationTemporality temporality)	Returns the MetricData that this Aggregation will produce.
DoublePointData	toPoint(Measurement measurement)	Return a new point representing the measurement.
void	toPoint(Measurement measurement, DoublePointData reusablePoint)	Resets reusablePoint to represent the measurement.

Methods inherited from class io.opentelemetry.sdk.metrics.internal.aggregator.AbstractSumAggregator

isMonotonic

Methods inherited from class java.lang.Object

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

Field Details

reservoirSupplier

private final Supplier<ExemplarReservoir<DoubleExemplarData>> reservoirSupplier

memoryMode

private final MemoryMode memoryMode

Constructor Details

DoubleSumAggregator

public DoubleSumAggregator(InstrumentDescriptor instrumentDescriptor,
 Supplier<ExemplarReservoir<DoubleExemplarData>> reservoirSupplier,
 MemoryMode memoryMode)

Constructs a sum aggregator.

Parameters:

instrumentDescriptor - The instrument being recorded, used to compute monotonicity.

reservoirSupplier - Supplier of exemplar reservoirs per-stream.

memoryMode - The memory mode to use.

Method Details

createHandle

public AggregatorHandle<DoublePointData,DoubleExemplarData> createHandle()

Description copied from interface: Aggregator

Returns a new AggregatorHandle. This MUST by used by the synchronous to aggregate recorded measurements during the collection cycle.

Returns:

a new AggregatorHandle.

diff

public DoublePointData diff(DoublePointData previousPoint,
 DoublePointData currentPoint)

Description copied from interface: Aggregator

Returns a new DELTA point by computing the difference between two cumulative points.

Aggregators MUST implement diff if it can be used with asynchronous instruments.

Parameters:

previousPoint - the previously captured point.

currentPoint - the newly captured (cumulative) point.

Returns:

The resulting delta point.

diffInPlace

public void diffInPlace(DoublePointData previousReusablePoint,
 DoublePointData currentPoint)

Description copied from interface: Aggregator

Resets one reusable point to be a DELTA point by computing the difference between two cumulative points.

The delta between the two points is set on previousCumulativeReusable

Aggregators MUST implement diff if it can be used with asynchronous instruments.

Parameters:

previousReusablePoint - the previously captured point.

currentPoint - the newly captured (cumulative) point.

toPoint

public DoublePointData toPoint(Measurement measurement)

Description copied from interface: Aggregator

Return a new point representing the measurement.

Aggregators MUST implement diff if it can be used with asynchronous instruments.

toPoint

public void toPoint(Measurement measurement,
 DoublePointData reusablePoint)

Description copied from interface: Aggregator

Resets reusablePoint to represent the measurement.

Aggregators MUST implement diff if it can be used with asynchronous instruments.

createReusablePoint

public DoublePointData createReusablePoint()

Description copied from interface: Aggregator

Creates a new reusable point.

copyPoint

public void copyPoint(DoublePointData point,
 DoublePointData toReusablePoint)

Description copied from interface: Aggregator

Copies point into toReusablePoint.

toMetricData

public MetricData toMetricData(Resource resource,
 InstrumentationScopeInfo instrumentationScopeInfo,
 MetricDescriptor descriptor,
 Collection<DoublePointData> points,
 AggregationTemporality temporality)

Description copied from interface: Aggregator

Returns the MetricData that this Aggregation will produce.

Parameters:

resource - the resource producing the metric.

instrumentationScopeInfo - the scope that instrumented the metric.

descriptor - the name, description and unit of the metric.

points - list of points

temporality - the temporality of the metric.

Returns:

the MetricDataType that this Aggregation will produce.