blob: da796e2acbca042d5fda19f4ce51aa5abcfaf877 [file] [log] [blame]
package org.example.vanilla
import org.apache.spark.{SparkConf, SparkContext}
import org.scalatest.{BeforeAndAfterAll, Suite}
trait SharedSingletonContext extends BeforeAndAfterAll {
this: Suite =>
private var _sparkContext: Option[SparkContext] = None
def sparkContext = _sparkContext.get
val sparkConf = new SparkConf(false)
override def beforeAll() {
_sparkContext = Some(new SparkContext("local", "test", sparkConf))
super.beforeAll()
}
override def afterAll() {
super.afterAll()
sparkContext.stop()
_sparkContext = None
System.clearProperty("spark.driver.port")
}
}