外地车分布情况分析

需求：实时车辆分布情况，每隔5秒统计最近1分钟时间内整个城市中每个区分布多少量外地车。这里要注意车辆的去重，因为在1分钟内一定会有很多的车，经过不同的卡口。这些车牌相同的车，我们只统计一次。其实就是根据车牌号去重。

这个功能和前面的一样，实时统计外地车在一段时间内，整个城市的分布情况，整个城市中每个区多少分布多少量外地车，即统计每个区域实时外地车分布。

核心代码如下：

xxxxxxxxxx
//按照区域进行分组
val keyedStream: KeyedStream[TrafficLog, String] = 
  //过滤掉京牌车辆
  trafficLogDS.filter(!_.car.startsWith("京"))
  .keyBy(_.areaId)