spotless

Signed-off-by: Pavan Yekbote <[email protected]>

Author: pyek-bot

plugin/src/main/java/org/opensearch/ml/model/MLModelManager.java

@@ -141,8 +141,6 @@
 import org.opensearch.ml.stats.MLActionLevelStat;
 import org.opensearch.ml.stats.MLNodeLevelStat;
 import org.opensearch.ml.stats.MLStats;
-import org.opensearch.ml.stats.otel.counters.MLOperationalMetricsCounter;
-import org.opensearch.ml.stats.otel.metrics.OperationalMetric;
 import org.opensearch.ml.task.MLTaskManager;
 import org.opensearch.ml.utils.MLExceptionUtils;
 import org.opensearch.ml.utils.MLNodeUtils;

plugin/src/main/java/org/opensearch/ml/stats/otel/counters/AbstractMLMetricsCounter.java

@@ -88,5 +88,6 @@ private Histogram createMetricHistogram(T metric) {
     }
 
     protected abstract String getMetricDescription(T metric);
+
     protected abstract MetricType getMetricType(T metric);
 }

plugin/src/main/java/org/opensearch/ml/task/MLPredictTaskRunner.java

@@ -394,16 +394,13 @@ private void recordPredictMetrics(
             if (model != null) {
                 if (model.getConnector() == null && model.getConnectorId() != null) {
                     mlModelManager.getConnector(model.getConnectorId(), model.getTenantId(), ActionListener.wrap(connector -> {
-                        MLOperationalMetricsCounter.getInstance().incrementCounter(
-                            OperationalMetric.MODEL_PREDICT_COUNT,
-                            model.getTags(connector)
-                        );
+                        MLOperationalMetricsCounter
+                            .getInstance()
+                            .incrementCounter(OperationalMetric.MODEL_PREDICT_COUNT, model.getTags(connector));
 
-                        MLOperationalMetricsCounter.getInstance().recordHistogram(
-                            OperationalMetric.MODEL_PREDICT_LATENCY,
-                            durationInMs,
-                            model.getTags(connector)
-                        );
+                        MLOperationalMetricsCounter
+                            .getInstance()
+                            .recordHistogram(OperationalMetric.MODEL_PREDICT_LATENCY, durationInMs, model.getTags(connector));
 
                         internalListener.onResponse(output);
                     }, e -> {
@@ -413,15 +410,10 @@ private void recordPredictMetrics(
                     return;
                 }
 
-                MLOperationalMetricsCounter.getInstance().incrementCounter(
-                    OperationalMetric.MODEL_PREDICT_COUNT,
-                    model.getTags()
-                );
-                MLOperationalMetricsCounter.getInstance().recordHistogram(
-                    OperationalMetric.MODEL_PREDICT_LATENCY,
-                    durationInMs,
-                    model.getTags()
-                );
+                MLOperationalMetricsCounter.getInstance().incrementCounter(OperationalMetric.MODEL_PREDICT_COUNT, model.getTags());
+                MLOperationalMetricsCounter
+                    .getInstance()
+                    .recordHistogram(OperationalMetric.MODEL_PREDICT_LATENCY, durationInMs, model.getTags());
 
                 internalListener.onResponse(output);
             } else {
@@ -517,7 +509,8 @@ private void runPredict(
                         predictor.asyncPredict(mlInput, trackPredictDurationListener); // with listener
                     } else {
                         long startTime = System.nanoTime();
-                        MLOutput output = mlModelManager.trackPredictDuration(modelId, () -> predictor.predict(mlInput)); // without listener
+                        MLOutput output = mlModelManager.trackPredictDuration(modelId, () -> predictor.predict(mlInput)); // without
+                                                                                                                          // listener
                         if (output instanceof MLPredictionOutput) {
                             ((MLPredictionOutput) output).setStatus(MLTaskState.COMPLETED.name());
                         }