We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2a09ad6 commit ccde038Copy full SHA for ccde038
streaming/src/main/scala/org/apache/spark/streaming/dstream/MappedDStream.scala
@@ -20,7 +20,6 @@ package org.apache.spark.streaming.dstream
20
import org.apache.spark.streaming.{Duration, Time}
21
import org.apache.spark.rdd.RDD
22
import scala.reflect.ClassTag
23
-import org.apache.spark.util.Utils
24
25
private[streaming]
26
class MappedDStream[T: ClassTag, U: ClassTag] (
0 commit comments