Make InputDStream.name private[streaming]

jeanlyn · May 5, 2015 · ff0bff8 · ff0bff8
1 parent cc392c5
commit ff0bff8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/InputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/InputDStream.scala
@@ -47,7 +47,7 @@ abstract class InputDStream[T: ClassTag] (@transient ssc_ : StreamingContext)
   /**
    * The name of this InputDStream. By default, it's the class name with its id.
    */
-  def name: String = s"${getClass.getSimpleName}-$id"
+  private[streaming] def name: String = s"${getClass.getSimpleName}-$id"
 
   /**
    * Checks whether the 'time' is valid wrt slideDuration for generating RDD.