Input is a json request, which would be decoded in myJob() & processed further.
Not sure what is wrong with below code, it emits errors as unimplemented methods (runJob/validate), any pointers on this would be helpful, jobserver-0.8.0 object MyJobServer extends SparkSessionJob { type JobData = String type JobOutput = Seq[String] def myJob(a : String) = { } def runJob(sc: SparkContext, runtime: JobEnvironment, data: JobData): JobOutput = { myJob(a) } def validate(sc: SparkContext, runtime: JobEnvironment, config: Config): JobData Or Every[ValidationProblem] = { Good(config.root().render()) }