草庐IT

TaxiRide

全部标签

Flink-出租车-车程事件流和付车费事件流connect

案例来源:https://github.com/apache/flink-training/blob/release-1.14/README_zh.md案例背景出租车车程(taxiride)事件结构1.每次车程都由两个事件表示:行程开始(tripstart)和行程结束(tripend)。2.每个事件都由十一个字段组成:rideId:Long//每次车程的唯一idtaxiId:Long//每一辆出租车的唯一iddriverId:Long//每一位司机的唯一idisStart:Boolean//行程开始事件为TRUE,行程结束事件为FALSEeventTime:Long//事件的时间戳startL

Flink-出租车-车程事件流和付车费事件流connect

案例来源:https://github.com/apache/flink-training/blob/release-1.14/README_zh.md案例背景出租车车程(taxiride)事件结构1.每次车程都由两个事件表示:行程开始(tripstart)和行程结束(tripend)。2.每个事件都由十一个字段组成:rideId:Long//每次车程的唯一idtaxiId:Long//每一辆出租车的唯一iddriverId:Long//每一位司机的唯一idisStart:Boolean//行程开始事件为TRUE,行程结束事件为FALSEeventTime:Long//事件的时间戳startL