练习: 有状态的增强(车程及车费)

本练习的目标是将每次车程的 TaxiRide 和 TaxiFare 记录连接在一起。

对于每个不同的 rideId，恰好有三个事件：

最终的结果应该是 DataStream<RideAndFare>，每个不同的 rideId 都产生一个 RideAndFare 记录。每个 RideAndFare 都应该将某个 rideId 的 TaxiRide START 事件与其匹配的 TaxiFare 配对。

在练习中，你将使用两个数据流，一个使用由 TaxiRideSource 生成的 TaxiRide 事件，另一个使用由 TaxiFareSource 生成的 TaxiFare 事件。有关如何使用这些流生成器的信息，请参阅使用出租车数据流。

所希望的结果是一个 RideAndFare 记录的数据流，每个不同的 rideId 都有一条这样的记录。本练习设置为忽略 END 事件，你应该连接每次乘车的 START 事件及其相应的车费事件。

一旦具有了相互关联的车程和车费事件，你可以使用 new RideAndFare(ride, fare) 方法为输出流创建所需的对象。

流将会被打印到标准输出。

入门指南

:information_source: 最好在 IDE 的 flink-training 项目中找到这些类，而不是使用本节中源文件的链接。

可以使用 RichCoFlatMap 来实现连接操作。请注意，你无法控制每个 rideId 的车程和车费记录的到达顺序，因此需要存储其中一个事件，直到与其匹配的另一事件到达。此时你可以创建并发出 RideAndFare 以将两条记录连接在一起。

应该使用由 Flink 管理的、按键值分割(keyed)的状态来缓冲想要暂时保存的数据，直到匹配事件到达，并确保在不再需要时清除该状态。

出于练习的目的，可以假设 START 和 fare 事件完美配对。但是在现实世界的应用程序中，你应该担心每当一个事件丢失时，同一个 rideId 的另一个事件的状态将被永远保持。在稍后的练习中，我们将看到 ProcessFunction 和定时器，它们将有助于处理这样的情况。

项目中提供了参考解决方案：