2424 */
2525public class AggVersionedDaVinciRecordTransformerStats
2626 extends AbstractVeniceAggVersionedStats <DaVinciRecordTransformerStats , DaVinciRecordTransformerStatsReporter > {
27- private final boolean emitOtelMetrics ;
2827 private final VeniceOpenTelemetryMetricsRepository otelRepository ;
2928 private final Map <VeniceMetricsDimensions , String > baseDimensionsMap ;
3029
@@ -55,7 +54,6 @@ public AggVersionedDaVinciRecordTransformerStats(
5554
5655 OpenTelemetryMetricsSetup .OpenTelemetryMetricsSetupInfo otelData =
5756 OpenTelemetryMetricsSetup .builder (metricsRepository ).setClusterName (serverConfig .getClusterName ()).build ();
58- this .emitOtelMetrics = otelData .emitOpenTelemetryMetrics ();
5957 this .otelRepository = otelData .getOtelRepository ();
6058 this .baseDimensionsMap = otelData .getBaseDimensionsMap ();
6159 }
@@ -72,34 +70,26 @@ public void handleStoreDeleted(String storeName) {
7270
7371 public void recordPutLatency (String storeName , int version , double value , long timestamp ) {
7472 recordVersionedAndTotalStat (storeName , version , stat -> stat .recordPutLatency (value , timestamp ));
75- if (emitOtelMetrics ) {
76- getOrCreateMetric (latencyPerStore , storeName , RECORD_TRANSFORMER_LATENCY )
77- .record (value , VeniceRecordTransformerOperation .PUT );
78- }
73+ getOrCreateMetric (latencyPerStore , storeName , RECORD_TRANSFORMER_LATENCY )
74+ .record (value , VeniceRecordTransformerOperation .PUT );
7975 }
8076
8177 public void recordDeleteLatency (String storeName , int version , double value , long timestamp ) {
8278 recordVersionedAndTotalStat (storeName , version , stat -> stat .recordDeleteLatency (value , timestamp ));
83- if (emitOtelMetrics ) {
84- getOrCreateMetric (latencyPerStore , storeName , RECORD_TRANSFORMER_LATENCY )
85- .record (value , VeniceRecordTransformerOperation .DELETE );
86- }
79+ getOrCreateMetric (latencyPerStore , storeName , RECORD_TRANSFORMER_LATENCY )
80+ .record (value , VeniceRecordTransformerOperation .DELETE );
8781 }
8882
8983 public void recordPutError (String storeName , int version , long timestamp ) {
9084 recordVersionedAndTotalStat (storeName , version , stat -> stat .recordPutError (timestamp ));
91- if (emitOtelMetrics ) {
92- getOrCreateMetric (errorCountPerStore , storeName , RECORD_TRANSFORMER_ERROR_COUNT )
93- .record (1 , VeniceRecordTransformerOperation .PUT );
94- }
85+ getOrCreateMetric (errorCountPerStore , storeName , RECORD_TRANSFORMER_ERROR_COUNT )
86+ .record (1 , VeniceRecordTransformerOperation .PUT );
9587 }
9688
9789 public void recordDeleteError (String storeName , int version , long timestamp ) {
9890 recordVersionedAndTotalStat (storeName , version , stat -> stat .recordDeleteError (timestamp ));
99- if (emitOtelMetrics ) {
100- getOrCreateMetric (errorCountPerStore , storeName , RECORD_TRANSFORMER_ERROR_COUNT )
101- .record (1 , VeniceRecordTransformerOperation .DELETE );
102- }
91+ getOrCreateMetric (errorCountPerStore , storeName , RECORD_TRANSFORMER_ERROR_COUNT )
92+ .record (1 , VeniceRecordTransformerOperation .DELETE );
10393 }
10494
10595 private MetricEntityStateOneEnum <VeniceRecordTransformerOperation > getOrCreateMetric (
0 commit comments