案例来源https://github.com/apache/flink-training/blob/release-1.14/hourly-tips/README_zh.md案例介绍基于出租车付费事件流计算出每小时赚取最多小费的司机，最简单的方法是通过两个步骤来解决这个问题：首先使用一个小时长的窗口来计算每个司机在一小时内的总小费，然后从该窗口结果流中找到每小时总小费最多的司机。结果输出：每小时产生一个HourlyTip对象记录的数据流。这个记录应包含该小时结束时的时间戳、该小时内获得小费最多的司机的driverId以及他的实际小费总数。publicclassHourlyTip{/***小时结

案例来源https://github.com/apache/flink-training/blob/release-1.14/hourly-tips/README_zh.md案例介绍基于出租车付费事件流计算出每小时赚取最多小费的司机，最简单的方法是通过两个步骤来解决这个问题：首先使用一个小时长的窗口来计算每个司机在一小时内的总小费，然后从该窗口结果流中找到每小时总小费最多的司机。结果输出：每小时产生一个HourlyTip对象记录的数据流。这个记录应包含该小时结束时的时间戳、该小时内获得小费最多的司机的driverId以及他的实际小费总数。publicclassHourlyTip{/***小时结

案例来源：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

案例来源：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