ApacheBeam中的事件时间处理是如何实现的

在Apache Beam中，事件时间处理是通过Timestamps和Watermarks来实现的。Timestamps：Timestamps用来表示事件发生的时间。在数据流中，每个元素都有一个对应的Timestamp，表示该元素的事件发生时间。可以通过TimestampAssigner来为每个元素分配Timestamp。在Apache Beam中，可以使用WithTimestamps或者WithT