style: Apply scalafix and scalafmt changes

piyush-zlai · piyush-zlai · commit 581fddc5bd39 · 2025-01-13T10:14:19.000-05:00
diff --git a/cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp/DataprocSubmitter.scala b/cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp/DataprocSubmitter.scala
@@ -181,10 +181,10 @@ object DataprocSubmitter {
     val a = DataprocSubmitter(submitterConf)
 
     val jobId = a.submit(
-        TypeSparkJob,
-        Map(MainClass -> "ai.chronon.spark.Driver", JarURI -> chrononJarUri),
-        gcsFiles.toList,
-        userArgs: _*
+      TypeSparkJob,
+      Map(MainClass -> "ai.chronon.spark.Driver", JarURI -> chrononJarUri),
+      gcsFiles.toList,
+      userArgs: _*
     )
     println("Dataproc submitter job id: " + jobId)
   }
diff --git a/flink/src/main/scala/ai/chronon/flink/FlinkJob.scala b/flink/src/main/scala/ai/chronon/flink/FlinkJob.scala
@@ -9,7 +9,8 @@ import ai.chronon.flink.window.FlinkRowAggProcessFunction
 import ai.chronon.flink.window.FlinkRowAggregationFunction
 import ai.chronon.flink.window.KeySelector
 import ai.chronon.flink.window.TimestampedTile
-import ai.chronon.online.{Api, GroupByServingInfoParsed, SparkConversions}
+import ai.chronon.online.Api
+import ai.chronon.online.GroupByServingInfoParsed
 import ai.chronon.online.KVStore.PutRequest
 import ai.chronon.online.SparkConversions
 import org.apache.flink.api.scala._

Original file line number	Diff line number	Diff line change
`@@ -181,10 +181,10 @@ object DataprocSubmitter {`
`181`	`181`	`val a = DataprocSubmitter(submitterConf)`
`182`	`182`
`183`	`183`	`val jobId = a.submit(`
`184`		`- TypeSparkJob,`
`185`		`- Map(MainClass -> "ai.chronon.spark.Driver", JarURI -> chrononJarUri),`
`186`		`- gcsFiles.toList,`
`187`		`- userArgs: _*`
	`184`	`+ TypeSparkJob,`
	`185`	`+ Map(MainClass -> "ai.chronon.spark.Driver", JarURI -> chrononJarUri),`
	`186`	`+ gcsFiles.toList,`
	`187`	`+ userArgs: _*`
`188`	`188`	`)`
`189`	`189`	`println("Dataproc submitter job id: " + jobId)`
`190`	`190`	`}`