Fix scala style

TQJADE · Aug 23, 2024 · b4ae2df · b4ae2df
1 parent baed5c2
commit b4ae2df
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/...rc/main/scala/org/apache/spark/metrics/sink/opentelemetry/OpenTelemetryPushReporter.scala b/...rc/main/scala/org/apache/spark/metrics/sink/opentelemetry/OpenTelemetryPushReporter.scala
@@ -43,13 +43,13 @@ private[spark] class OpenTelemetryPushReporter(
     trustedCertificatesPath: String,
     privateKeyPemPath: String,
     certificatePemPath: String)
-    extends ScheduledReporter(
+  extends ScheduledReporter (
       registry,
       "opentelemetry-push-reporter",
       MetricFilter.ALL,
       TimeUnit.SECONDS,
       TimeUnit.MILLISECONDS)
-    with MetricRegistryListener {
+  with MetricRegistryListener {
 
   val FIFTEEN_MINUTE_RATE = "_fifteen_minute_rate"
   val FIVE_MINUTE_RATE = "_five_minute_rate"
@@ -100,9 +100,9 @@ private[spark] class OpenTelemetryPushReporter(
     .merge(Resource.create(arrtributesBuilder.build()));
 
   val metricReader = PeriodicMetricReader
-      .builder(otlpGrpcMetricExporterBuilder.build())
-      .setInterval(pollInterval, pollUnit)
-      .build()
+    .builder(otlpGrpcMetricExporterBuilder.build())
+    .setInterval(pollInterval, pollUnit)
+    .build()
 
   val sdkMeterProvider: SdkMeterProvider = SdkMeterProvider
     .builder()

diff --git a/core/src/main/scala/org/apache/spark/metrics/sink/opentelemetry/OpenTelemetryPushSink.scala b/core/src/main/scala/org/apache/spark/metrics/sink/opentelemetry/OpenTelemetryPushSink.scala
@@ -46,8 +46,7 @@ private[spark] object OpenTelemetryPushSink {
 }
 
 private[spark] class OpenTelemetryPushSink(val property: Properties, val registry: MetricRegistry)
-    extends Sink
-    with Logging {
+  extends Sink with Logging {
 
   val OPEN_TELEMETRY_KEY_PERIOD = "period"
   val OPEN_TELEMETRY_KEY_UNIT = "unit"