Small chang to existing constructor

pwendell · pwendell · commit d6b0afdd2daf · 2014-04-06T12:16:45.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala
@@ -104,9 +104,11 @@ class SparkContext(config: SparkConf)
       appName: String,
       sparkHome: String = null,
       jars: Seq[String] = Nil,
-      environment: Map[String, String] = Map()) =
+      environment: Map[String, String] = Map(),
+      preferredNodeLocationData: Map[String, Set[SplitInfo]] = Map()) =
   {
     this(SparkContext.updatedConf(new SparkConf(), master, appName, sparkHome, jars, environment))
+    this.preferredNodeLocationData = preferredNodeLocationData
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -104,9 +104,11 @@ class SparkContext(config: SparkConf)`
`104`	`104`	`appName: String,`
`105`	`105`	`sparkHome: String = null,`
`106`	`106`	`jars: Seq[String] = Nil,`
`107`		`- environment: Map[String, String] = Map()) =`
	`107`	`+ environment: Map[String, String] = Map(),`
	`108`	`+ preferredNodeLocationData: Map[String, Set[SplitInfo]] = Map()) =`
`108`	`109`	`{`
`109`	`110`	`this(SparkContext.updatedConf(new SparkConf(), master, appName, sparkHome, jars, environment))`
	`111`	`+ this.preferredNodeLocationData = preferredNodeLocationData`
`110`	`112`	`}`
`111`	`113`
`112`	`114`	`/**`