diff --git a/core/src/main/scala/spark/api/java/JavaSparkContext.scala b/core/src/main/scala/spark/api/java/JavaSparkContext.scala index 08c92b145ea3f17deccb85fb5d580c031ad7ee75..4a7d945a8de657988c68eb11a47a79f57d25ffcd 100644 --- a/core/src/main/scala/spark/api/java/JavaSparkContext.scala +++ b/core/src/main/scala/spark/api/java/JavaSparkContext.scala @@ -20,6 +20,12 @@ class JavaSparkContext(val sc: SparkContext) extends JavaSparkContextVarargsWork def this(master: String, frameworkName: String) = this(new SparkContext(master, frameworkName)) + def this(master: String, frameworkName: String, sparkHome: String, jarFile: String) = + this(new SparkContext(master, frameworkName, sparkHome, Seq(jarFile))) + + def this(master: String, frameworkName: String, sparkHome: String, jars: Array[String]) = + this(new SparkContext(master, frameworkName, sparkHome, jars.toSeq)) + val env = sc.env def parallelize[T](list: java.util.List[T], numSlices: Int): JavaRDD[T] = {