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 index 2e9308f25d7b6..9716adb62817c 100644 --- 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.