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())
}