File tree 2 files changed +6
-5
lines changed
cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp
flink/src/main/scala/ai/chronon/flink 2 files changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -185,10 +185,10 @@ object DataprocSubmitter {
185
185
val a = DataprocSubmitter (submitterConf)
186
186
187
187
val jobId = a.submit(
188
- TypeSparkJob ,
189
- Map (MainClass -> " ai.chronon.spark.Driver" , JarURI -> chrononJarUri),
190
- gcsFiles.toList,
191
- userArgs : _*
188
+ TypeSparkJob ,
189
+ Map (MainClass -> " ai.chronon.spark.Driver" , JarURI -> chrononJarUri),
190
+ gcsFiles.toList,
191
+ userArgs : _*
192
192
)
193
193
println(" Dataproc submitter job id: " + jobId)
194
194
}
Original file line number Diff line number Diff line change @@ -9,7 +9,8 @@ import ai.chronon.flink.window.FlinkRowAggProcessFunction
9
9
import ai .chronon .flink .window .FlinkRowAggregationFunction
10
10
import ai .chronon .flink .window .KeySelector
11
11
import ai .chronon .flink .window .TimestampedTile
12
- import ai .chronon .online .{Api , GroupByServingInfoParsed , SparkConversions }
12
+ import ai .chronon .online .Api
13
+ import ai .chronon .online .GroupByServingInfoParsed
13
14
import ai .chronon .online .KVStore .PutRequest
14
15
import ai .chronon .online .SparkConversions
15
16
import org .apache .flink .api .scala ._
You can’t perform that action at this time.
0 commit comments