import io.hydrosphere.mist.lib.MistJob

object SimpleContext extends MistJob {
  /** Contains implementation of spark job with ordinary [[org.apache.spark.SparkContext]]
    * Abstract method must be overridden
    *
    * @param numbers list of int to process
    * @return result of the job
    */
  def doStuff(numbers: List[Int], multiplier: Int): Map[String, Any] = {
    val rdd = context.parallelize(numbers)
    Map("result" -> rdd.map(x => x * multiplier).collect())
  }
}

import io.hydrosphere.mist.lib.MistJob

object SimpleContext extends MistJob {
  /** Contains implementation of spark job with ordinary [[org.apache.spark.SparkContext]]
    * Abstract method must be overridden
    *
    * @param numbers list of int to process
    * @return result of the job
    */
  def doStuff(numbers: List[Int], multiplier: Option[Int]): Map[String, Any] = {
    val rdd = context.parallelize(numbers)
    Map("result" -> rdd.map(x => x * multiplier.getOrElse(2)).collect())
  }
}

Fix the simple example: optional multiplier
Fix the simple example: optional multiplier
