We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ec99701 commit f26eafcCopy full SHA for f26eafc
cloud_aws/src/main/scala/ai/chronon/integrations/aws/LivySubmitter.scala
@@ -0,0 +1,15 @@
1
+package ai.chronon.integrations.aws
2
+
3
+import ai.chronon.spark.{JobSubmitter, JobType}
4
5
+class LivySubmitter extends JobSubmitter {
6
7
+ override def submit(jobType: JobType,
8
+ jobProperties: Map[String, String],
9
+ files: List[String],
10
+ args: String*): String = ???
11
12
+ override def status(jobId: String): Unit = ???
13
14
+ override def kill(jobId: String): Unit = ???
15
+}
0 commit comments