Skip to content
Snippets Groups Projects
Commit 25a6a39e authored by Matei Zaharia's avatar Matei Zaharia
Browse files

Added other SparkContext constructors to JavaSparkContext

parent 9a0c128f
No related branches found
No related tags found
No related merge requests found
......@@ -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] = {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment