DseSparkContextFactory

class DseSparkContextFactory extends SparkContextFactory {
  import SparkJobUtils._

  type C = SparkContext with ContextLike

  def makeContext(config: Config, contextConfig: Config, contextName: String): C = {
    val conf = configToSparkConf(config, contextConfig, contextName)

    val sparkMaster = "dsetool sparkmaster".!!.trim
    conf.set("spark.master",sparkMaster)

    new SparkContext(conf) with ContextLike {
      def sparkContext: SparkContext = this
      def isValidJob(job: SparkJobBase): Boolean = job.isInstanceOf[SparkJob]
    }
  }
}