witterApp/src/main/scala/TwitterPopularTags.scala:35:
> error: value reduceByKeyAndWindow is not a member of
> org.apache.spark.streaming.dstream.DStream[(String, Int)]
> [INFO] val topCounts60 = hashTags.map((_,
> 1)).reduceByKeyAndWindow(_ + _, Seconds(60)).map{case (topic, count)
> => (count
/main/scala/TwitterPopularTags.scala:35:
error: value reduceByKeyAndWindow is not a member of
org.apache.spark.streaming.dstream.DStream[(String, Int)]
[INFO] val topCounts60 = hashTags.map((_,
1)).reduceByKeyAndWindow(_ + _, Seconds(60)).map{case (topic, count)
=> (count, topic)}.transform(_.s
