Removing streaming visibility from getRDDCreationCallSite in DStream

mubarak · mubarak · commit 491a1eb23aa9 · 2014-08-20T01:07:05.000-07:00
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala
@@ -116,7 +116,7 @@ abstract class DStream[T: ClassTag] (
   }
 
   /* Return the current callSite */
-  private[streaming] def getRDDCreationCallSite(): CallSite = {
+  private def getRDDCreationCallSite(): CallSite = {
     CallSite(ssc.sparkContext.getLocalProperty(Utils.CALL_SITE_SHORT),
              ssc.sparkContext.getLocalProperty(Utils.CALL_SITE_LONG))
   }

Original file line number	Diff line number	Diff line change
`@@ -116,7 +116,7 @@ abstract class DStream[T: ClassTag] (`
`116`	`116`	`}`
`117`	`117`
`118`	`118`	`/* Return the current callSite */`
`119`		`- private[streaming] def getRDDCreationCallSite(): CallSite = {`
	`119`	`+ private def getRDDCreationCallSite(): CallSite = {`
`120`	`120`	`CallSite(ssc.sparkContext.getLocalProperty(Utils.CALL_SITE_SHORT),`
`121`	`121`	`ssc.sparkContext.getLocalProperty(Utils.CALL_SITE_LONG))`
`122`	`122`	`}`