diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-08-19 18:59:16 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-08-19 18:59:16 -0700 |
| commit | 25a6a39e6d6db1264ab7633d1dcfe886415fbf1a (patch) | |
| tree | a7e0df66919b8fdf2d60f6df568f924317312bfc /core/src | |
| parent | 9a0c128feceb63685513ce9c1022ef2d4de43fbf (diff) | |
| download | spark-25a6a39e6d6db1264ab7633d1dcfe886415fbf1a.tar.gz spark-25a6a39e6d6db1264ab7633d1dcfe886415fbf1a.tar.bz2 spark-25a6a39e6d6db1264ab7633d1dcfe886415fbf1a.zip | |
Added other SparkContext constructors to JavaSparkContext
Diffstat (limited to 'core/src')
| -rw-r--r-- | core/src/main/scala/spark/api/java/JavaSparkContext.scala | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/core/src/main/scala/spark/api/java/JavaSparkContext.scala b/core/src/main/scala/spark/api/java/JavaSparkContext.scala index 08c92b145e..4a7d945a8d 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] = { |