From ff0bff81072b5acf04f75424a5d5c30d512b826b Mon Sep 17 00:00:00 2001 From: zsxwing Date: Mon, 4 May 2015 17:02:03 -0700 Subject: [PATCH] Make InputDStream.name private[streaming] --- .../scala/org/apache/spark/streaming/dstream/InputDStream.scala | 2 +- 1 file changed, 1 insertion(+), 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 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.