Skip to content

Commit ff0bff8

Browse files
committed
Make InputDStream.name private[streaming]
1 parent cc392c5 commit ff0bff8

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

streaming/src/main/scala/org/apache/spark/streaming/dstream/InputDStream.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ abstract class InputDStream[T: ClassTag] (@transient ssc_ : StreamingContext)
4747
/**
4848
* The name of this InputDStream. By default, it's the class name with its id.
4949
*/
50-
def name: String = s"${getClass.getSimpleName}-$id"
50+
private[streaming] def name: String = s"${getClass.getSimpleName}-$id"
5151

5252
/**
5353
* Checks whether the 'time' is valid wrt slideDuration for generating RDD.

0 commit comments

Comments
 (0)