spark去重计数操作（代码示例）

val cityUserNoAppTypeDStream = CitySummaryBolt.noAppType(cleanBoltData)
  .map(x => (x, 0)).reduceByKey(_ + _).map(x => x._1).map(x => (x._1, 1l)).reduceByKey(_ + _)