Type specific exemplar reservoirs

docs/apidiffs/current_vs_latest/opentelemetry-api.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-api-1.56.0-SNAPSHOT.jar against opentelemetry-api-1.54.1.jar
+Comparing source compatibility of opentelemetry-api-1.56.0-SNAPSHOT.jar against opentelemetry-api-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-common.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-common-1.56.0-SNAPSHOT.jar against opentelemetry-common-1.54.1.jar
+Comparing source compatibility of opentelemetry-common-1.56.0-SNAPSHOT.jar against opentelemetry-common-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-context.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-context-1.56.0-SNAPSHOT.jar against opentelemetry-context-1.54.1.jar
+Comparing source compatibility of opentelemetry-context-1.56.0-SNAPSHOT.jar against opentelemetry-context-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-common.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-common-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-common-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-common-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-common-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-logging-otlp.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-logging-otlp-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-logging-otlp-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-logging-otlp-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-logging-otlp-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-logging.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-logging-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-logging-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-logging-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-logging-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-otlp-common.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-otlp-common-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-otlp-common-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-otlp-common-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-otlp-common-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-otlp.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-otlp-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-otlp-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-otlp-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-otlp-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-sender-grpc-managed-channel.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-sender-grpc-managed-channel-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-sender-grpc-managed-channel-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-sender-grpc-managed-channel-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-sender-grpc-managed-channel-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-sender-jdk.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-sender-jdk-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-sender-jdk-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-sender-jdk-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-sender-jdk-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-sender-okhttp.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-sender-okhttp-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-sender-okhttp-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-sender-okhttp-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-sender-okhttp-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-exporter-zipkin.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-exporter-zipkin-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-zipkin-1.54.1.jar
+Comparing source compatibility of opentelemetry-exporter-zipkin-1.56.0-SNAPSHOT.jar against opentelemetry-exporter-zipkin-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-extension-kotlin.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-extension-kotlin-1.56.0-SNAPSHOT.jar against opentelemetry-extension-kotlin-1.54.1.jar
+Comparing source compatibility of opentelemetry-extension-kotlin-1.56.0-SNAPSHOT.jar against opentelemetry-extension-kotlin-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-extension-trace-propagators.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-extension-trace-propagators-1.56.0-SNAPSHOT.jar against opentelemetry-extension-trace-propagators-1.54.1.jar
+Comparing source compatibility of opentelemetry-extension-trace-propagators-1.56.0-SNAPSHOT.jar against opentelemetry-extension-trace-propagators-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-opentracing-shim.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-opentracing-shim-1.56.0-SNAPSHOT.jar against opentelemetry-opentracing-shim-1.54.1.jar
+Comparing source compatibility of opentelemetry-opentracing-shim-1.56.0-SNAPSHOT.jar against opentelemetry-opentracing-shim-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk-common.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-common-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-common-1.54.1.jar
+Comparing source compatibility of opentelemetry-sdk-common-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-common-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk-extension-autoconfigure-spi.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-extension-autoconfigure-spi-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-extension-autoconfigure-spi-1.54.1.jar
+Comparing source compatibility of opentelemetry-sdk-extension-autoconfigure-spi-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-extension-autoconfigure-spi-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk-extension-autoconfigure.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-extension-autoconfigure-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-extension-autoconfigure-1.54.1.jar
+Comparing source compatibility of opentelemetry-sdk-extension-autoconfigure-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-extension-autoconfigure-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk-extension-jaeger-remote-sampler.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-extension-jaeger-remote-sampler-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-extension-jaeger-remote-sampler-1.54.1.jar
+Comparing source compatibility of opentelemetry-sdk-extension-jaeger-remote-sampler-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-extension-jaeger-remote-sampler-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk-logs.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-logs-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-logs-1.54.1.jar
+Comparing source compatibility of opentelemetry-sdk-logs-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-logs-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk-metrics.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-metrics-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-metrics-1.54.1.jar
+Comparing source compatibility of opentelemetry-sdk-metrics-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-metrics-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk-testing.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-testing-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-testing-1.54.1.jar
+Comparing source compatibility of opentelemetry-sdk-testing-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-testing-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk-trace.txt

@@ -1,2 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-trace-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-trace-1.54.1.jar
+Comparing source compatibility of opentelemetry-sdk-trace-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-trace-1.55.0.jar
 No changes.

docs/apidiffs/current_vs_latest/opentelemetry-sdk.txt

@@ -1,10 +1,2 @@
-Comparing source compatibility of opentelemetry-sdk-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-1.54.1.jar
-***  MODIFIED CLASS: PUBLIC NON_FINAL (<- FINAL) io.opentelemetry.sdk.OpenTelemetrySdk  (not serializable)
-	===  CLASS FILE FORMAT VERSION: 52.0 <- 52.0
-	***  MODIFIED METHOD: PUBLIC FINAL (<- NON_FINAL) io.opentelemetry.api.logs.LoggerProvider getLogsBridge()
-	***  MODIFIED METHOD: PUBLIC FINAL (<- NON_FINAL) io.opentelemetry.api.metrics.MeterProvider getMeterProvider()
-	***  MODIFIED METHOD: PUBLIC FINAL (<- NON_FINAL) io.opentelemetry.context.propagation.ContextPropagators getPropagators()
-	***  MODIFIED METHOD: PUBLIC FINAL (<- NON_FINAL) io.opentelemetry.sdk.logs.SdkLoggerProvider getSdkLoggerProvider()
-	***  MODIFIED METHOD: PUBLIC FINAL (<- NON_FINAL) io.opentelemetry.sdk.metrics.SdkMeterProvider getSdkMeterProvider()
-	***  MODIFIED METHOD: PUBLIC FINAL (<- NON_FINAL) io.opentelemetry.sdk.trace.SdkTracerProvider getSdkTracerProvider()
-	***  MODIFIED METHOD: PUBLIC FINAL (<- NON_FINAL) io.opentelemetry.api.trace.TracerProvider getTracerProvider()
+Comparing source compatibility of opentelemetry-sdk-1.56.0-SNAPSHOT.jar against opentelemetry-sdk-1.55.0.jar
+No changes.

sdk/metrics/src/jmh/java/io/opentelemetry/sdk/metrics/internal/aggregator/HistogramAggregationParam.java

@@ -7,7 +7,7 @@
 
 import static io.opentelemetry.sdk.common.export.MemoryMode.IMMUTABLE_DATA;
 
-import io.opentelemetry.sdk.metrics.internal.exemplar.ExemplarReservoir;
+import io.opentelemetry.sdk.metrics.internal.exemplar.ExemplarReservoirFactory;
 import java.util.Collections;
 
 /** The types of histogram aggregation to benchmark. */
@@ -17,27 +17,27 @@ public enum HistogramAggregationParam {
       new DoubleExplicitBucketHistogramAggregator(
           ExplicitBucketHistogramUtils.createBoundaryArray(
               ExplicitBucketHistogramUtils.DEFAULT_HISTOGRAM_BUCKET_BOUNDARIES),
-          ExemplarReservoir::doubleNoSamples,
+          ExemplarReservoirFactory.noSamples(),
           IMMUTABLE_DATA)),
   EXPLICIT_SINGLE_BUCKET(
       new DoubleExplicitBucketHistogramAggregator(
           ExplicitBucketHistogramUtils.createBoundaryArray(Collections.emptyList()),
-          ExemplarReservoir::doubleNoSamples,
+          ExemplarReservoirFactory.noSamples(),
           IMMUTABLE_DATA)),
   EXPONENTIAL_SMALL_CIRCULAR_BUFFER(
       new DoubleBase2ExponentialHistogramAggregator(
-          ExemplarReservoir::doubleNoSamples, 20, 0, IMMUTABLE_DATA)),
+          ExemplarReservoirFactory.noSamples(), 20, 0, IMMUTABLE_DATA)),
   EXPONENTIAL_CIRCULAR_BUFFER(
       new DoubleBase2ExponentialHistogramAggregator(
-          ExemplarReservoir::doubleNoSamples, 160, 0, IMMUTABLE_DATA));
+          ExemplarReservoirFactory.noSamples(), 160, 0, IMMUTABLE_DATA));
 
-  private final Aggregator<?, ?> aggregator;
+  private final Aggregator<?> aggregator;
 
-  HistogramAggregationParam(Aggregator<?, ?> aggregator) {
+  HistogramAggregationParam(Aggregator<?> aggregator) {
     this.aggregator = aggregator;
   }
 
-  public Aggregator<?, ?> getAggregator() {
+  public Aggregator<?> getAggregator() {
     return this.aggregator;
   }
 }

sdk/metrics/src/jmh/java/io/opentelemetry/sdk/metrics/internal/aggregator/HistogramBenchmark.java

@@ -5,6 +5,8 @@
 
 package io.opentelemetry.sdk.metrics.internal.aggregator;
 
+import io.opentelemetry.api.common.Attributes;
+import io.opentelemetry.context.Context;
 import java.util.concurrent.TimeUnit;
 import java.util.function.DoubleSupplier;
 import org.openjdk.jmh.annotations.Benchmark;
@@ -33,7 +35,7 @@ public class HistogramBenchmark {
   public static class ThreadState {
     @Param HistogramValueGenerator valueGen;
     @Param HistogramAggregationParam aggregation;
-    private AggregatorHandle<?, ?> aggregatorHandle;
+    private AggregatorHandle<?> aggregatorHandle;
     private DoubleSupplier valueSupplier;
 
     @Setup(Level.Trial)
@@ -45,7 +47,8 @@ public final void setup() {
     public void record() {
       // Record a number of samples.
       for (int i = 0; i < 2000; i++) {
-        this.aggregatorHandle.recordDouble(valueSupplier.getAsDouble());
+        this.aggregatorHandle.recordDouble(
+            valueSupplier.getAsDouble(), Attributes.empty(), Context.current());
       }
     }
   }

sdk/metrics/src/jmh/java/io/opentelemetry/sdk/metrics/internal/aggregator/HistogramScaleBenchmark.java

@@ -5,6 +5,8 @@
 
 package io.opentelemetry.sdk.metrics.internal.aggregator;
 
+import io.opentelemetry.api.common.Attributes;
+import io.opentelemetry.context.Context;
 import java.util.concurrent.TimeUnit;
 import java.util.function.DoubleSupplier;
 import org.openjdk.jmh.annotations.Benchmark;
@@ -39,7 +41,7 @@ public class HistogramScaleBenchmark {
   public static class ThreadState {
     @Param HistogramValueGenerator valueGen;
     @Param HistogramAggregationParam aggregation;
-    private AggregatorHandle<?, ?> aggregatorHandle;
+    private AggregatorHandle<?> aggregatorHandle;
     private DoubleSupplier valueSupplier;
 
     @Setup(Level.Invocation)
@@ -51,7 +53,8 @@ public final void setup() {
     public void record() {
       // Record a number of samples.
       for (int i = 0; i < 20000; i++) {
-        this.aggregatorHandle.recordDouble(valueSupplier.getAsDouble());
+        this.aggregatorHandle.recordDouble(
+            valueSupplier.getAsDouble(), Attributes.empty(), Context.current());
       }
     }
   }

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/SdkMeter.java

@@ -304,7 +304,7 @@ WriteableMetricStorage registerSynchronousMetricStorage(InstrumentDescriptor ins
   /** Register new asynchronous storage associated with a given instrument. */
   SdkObservableMeasurement registerObservableMeasurement(
       InstrumentDescriptor instrumentDescriptor) {
-    List<AsynchronousMetricStorage<?, ?>> registeredStorages = new ArrayList<>();
+    List<AsynchronousMetricStorage<?>> registeredStorages = new ArrayList<>();
     for (Map.Entry<RegisteredReader, MetricStorageRegistry> entry :
         readerStorageRegistries.entrySet()) {
       RegisteredReader reader = entry.getKey();

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/aggregator/AbstractSumAggregator.java

@@ -11,7 +11,7 @@
 import io.opentelemetry.sdk.metrics.internal.descriptor.InstrumentDescriptor;
 
 abstract class AbstractSumAggregator<T extends PointData, U extends ExemplarData>
-    implements Aggregator<T, U> {
+    implements Aggregator<T> {
   private final boolean isMonotonic;
 
   AbstractSumAggregator(InstrumentDescriptor instrumentDescriptor) {

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/aggregator/Aggregator.java

@@ -7,8 +7,6 @@
 
 import io.opentelemetry.sdk.common.InstrumentationScopeInfo;
 import io.opentelemetry.sdk.metrics.data.AggregationTemporality;
-import io.opentelemetry.sdk.metrics.data.DoubleExemplarData;
-import io.opentelemetry.sdk.metrics.data.ExemplarData;
 import io.opentelemetry.sdk.metrics.data.MetricData;
 import io.opentelemetry.sdk.metrics.data.MetricDataType;
 import io.opentelemetry.sdk.metrics.data.PointData;
@@ -25,9 +23,9 @@
  * at any time.
  */
 @Immutable
-public interface Aggregator<T extends PointData, U extends ExemplarData> {
+public interface Aggregator<T extends PointData> {
   /** Returns the drop aggregator, an aggregator that drops measurements. */
-  static Aggregator<?, DoubleExemplarData> drop() {
+  static Aggregator<?> drop() {
     return DropAggregator.INSTANCE;
   }
 
@@ -37,7 +35,7 @@ static Aggregator<?, DoubleExemplarData> drop() {
    *
    * @return a new {@link AggregatorHandle}.
    */
-  AggregatorHandle<T, U> createHandle();
+  AggregatorHandle<T> createHandle();
 
   /**
    * Returns a new DELTA point by computing the difference between two cumulative points.

sdk/metrics/src/main/java/io/opentelemetry/sdk/metrics/internal/aggregator/AggregatorFactory.java

@@ -6,7 +6,6 @@
 package io.opentelemetry.sdk.metrics.internal.aggregator;
 
 import io.opentelemetry.sdk.common.export.MemoryMode;
-import io.opentelemetry.sdk.metrics.data.ExemplarData;
 import io.opentelemetry.sdk.metrics.data.PointData;
 import io.opentelemetry.sdk.metrics.internal.descriptor.InstrumentDescriptor;
 import io.opentelemetry.sdk.metrics.internal.exemplar.ExemplarFilter;
@@ -31,7 +30,7 @@ public interface AggregatorFactory {
    * @return a new {@link Aggregator}. {@link Aggregator#drop()} indicates no measurements should be
    *     recorded.
    */
-  <T extends PointData, U extends ExemplarData> Aggregator<T, U> createAggregator(
+  <T extends PointData> Aggregator<T> createAggregator(
       InstrumentDescriptor instrumentDescriptor,
       ExemplarFilter exemplarFilter,
       MemoryMode memoryMode);