@@ -86,40 +86,40 @@ public void execute(
8686 int staleReadSeconds ) {
8787 // setup open telemetry metrics and traces
8888 // setup open telemetry metrics and traces
89- SpanExporter traceExporter = TraceExporter .createWithDefaultConfiguration ();
90- SdkTracerProvider tracerProvider =
91- SdkTracerProvider .builder ()
92- .addSpanProcessor (BatchSpanProcessor .builder (traceExporter ).build ())
93- .setResource (
94- Resource .create (
95- Attributes .of (
96- AttributeKey .stringKey ("service.name" ),
97- "Java-MultiplexedSession-Benchmark" )))
98- .setSampler (Sampler .alwaysOn ())
99- .build ();
100- MetricExporter cloudMonitoringExporter =
101- GoogleCloudMetricExporter .createWithDefaultConfiguration ();
102- SdkMeterProvider sdkMeterProvider =
103- SdkMeterProvider .builder ()
104- .registerMetricReader (PeriodicMetricReader .create (cloudMonitoringExporter ))
105- .build ();
106- OpenTelemetry openTelemetry =
107- OpenTelemetrySdk .builder ()
108- .setMeterProvider (sdkMeterProvider )
109- .setTracerProvider (tracerProvider )
110- .setPropagators (ContextPropagators .create (W3CTraceContextPropagator .getInstance ()))
111- .buildAndRegisterGlobal ();
89+ // SpanExporter traceExporter = TraceExporter.createWithDefaultConfiguration();
90+ // SdkTracerProvider tracerProvider =
91+ // SdkTracerProvider.builder()
92+ // .addSpanProcessor(BatchSpanProcessor.builder(traceExporter).build())
93+ // .setResource(
94+ // Resource.create(
95+ // Attributes.of(
96+ // AttributeKey.stringKey("service.name"),
97+ // "Java-MultiplexedSession-Benchmark")))
98+ // .setSampler(Sampler.alwaysOn())
99+ // .build();
100+ // MetricExporter cloudMonitoringExporter =
101+ // GoogleCloudMetricExporter.createWithDefaultConfiguration();
102+ // SdkMeterProvider sdkMeterProvider =
103+ // SdkMeterProvider.builder()
104+ // .registerMetricReader(PeriodicMetricReader.create(cloudMonitoringExporter))
105+ // .build();
106+ // OpenTelemetry openTelemetry =
107+ // OpenTelemetrySdk.builder()
108+ // .setMeterProvider(sdkMeterProvider)
109+ // .setTracerProvider(tracerProvider)
110+ // .setPropagators(ContextPropagators.create(W3CTraceContextPropagator.getInstance()))
111+ // .buildAndRegisterGlobal();
112112 SessionPoolOptions sessionPoolOptions =
113113 SessionPoolOptionsHelper .setUseMultiplexedSession (
114114 SessionPoolOptions .newBuilder (), useMultiplexedSession )
115115 .build ();
116- SpannerOptions .enableOpenTelemetryMetrics ();
117- SpannerOptions .enableOpenTelemetryTraces ();
116+ // SpannerOptions.enableOpenTelemetryMetrics();
117+ // SpannerOptions.enableOpenTelemetryTraces();
118118
119119 SpannerOptions options =
120120 SpannerOptions .newBuilder ()
121- .setOpenTelemetry (openTelemetry )
122- .setEnableEndToEndTracing (true )
121+ // .setOpenTelemetry(openTelemetry)
122+ // .setEnableEndToEndTracing(true)
123123 .setProjectId (databaseId .getInstanceId ().getProject ())
124124 .setSessionPoolOption (sessionPoolOptions )
125125 .setHost (SERVER_URL )
@@ -139,7 +139,7 @@ public void execute(
139139 throw SpannerExceptionFactory .asSpannerException (t );
140140 }
141141
142- sdkMeterProvider .close ();
142+ // sdkMeterProvider.close();
143143 }
144144
145145 private void executeBenchmarkAndPrintResults (
0 commit comments