This question should be directed to the `spark-jobserver` group:
https://github.com/spark-jobserver/spark-jobserver#contact
They also have a gitter chat.
Also include the errors you get once you're going to be asking them a
question
On Wed, Mar 14, 2018 at 1:37 PM, sujeet jog <sujeet....@gmail.com> wrote:
>
> 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())
> }
>
>
--
Sent from my iPhone
