卡口车辆采集数据

卡口数据通过Flume采集过来之后存入Kafka中，其中数据的格式为：

action_time long, --摄像头拍摄时间戳，精确到秒 monitor_id string, --卡口号 camera_id string, --摄像头编号 car string, --车牌号码 speed double, --通过卡扣的速度 road_id string, --道路id area_id string, --区域id

数据如：

1975026431000,0094,17287,京U83345,22.1,383,03 1975089057000,0049,08122,鲁E06431,102.1,918,00

其中每个字段之间使用逗号隔开。

区域ID代表：一个城市的行政区域。

摄像头编号：一个卡口往往会有多个摄像头，每个摄像头都有一个唯一编号。

道路ID：城市中每一条道路都有名字，比如：蔡锷路。交通部门会给蔡锷路一个唯一编号。

xxxxxxxxxx
package com.itbaizhan.traffic.util

import org.apache.flink.api.common.state.MapStateDescriptor

//项目中全局的常量
object GlobalConstant {
}
/**车辆经过卡口的日志数据对应的样例类
 * @param actionTime 摄像头拍摄时间戳，精确到秒
 * @param monitorId  卡口号
 * @param cameraId 摄像头编号
 * @param car 车牌号码
 * @param speed 通过卡扣的速度
 * @param roadId 道路id
 * @param areaId 区域id
 */
case class TrafficLog(actionTime:Long,monitorId:String,
  cameraId:String,car:String,speed:Double,roadId:String,
  areaId:String)