前面提到AntDB流式处理系统为实时计算提供了3种时间，即事件时间、入库时间和处理时间。在进行窗口计算，理想情况下事件时间和处理时间一致，但是在实际应用中，由于网络或者系统等外部因素影响，事件数据往往不能及时到达流式处理系统，从而造成数据乱序或者延迟到达等问题。针对这两个问题，流式数据库主要采用了以水位线（Watermater）为核心的机制来应对。正确地处理乱序事件，通常是结合窗口和水位线这两种机制来实现的。
在流处理过程中，从时间产生，到流经数据库，到流经算子，中间是有一个过程和时间的。虽然在大部分情况下，流到算子的数据都是按照事件产生的时间顺序到达的，但是也不排除由于网络、系统等原因，导致乱序的产生和迟到数据。但是对于迟到数据，不能无限期地等下去，必须要有个机制来保证在经过一个特定的时间后，触发窗口计算。此时就是水位线发挥作用，它表示当达到水位线后，在水位线之前的数据已经全部到达（即使后面还有延迟的数据），系统可以触发相应的窗口计算。也就是说，只有水位线越过窗口对应的结束时间，窗口才会关闭和计算。只有以下两个条件同时成立，才会触发窗口计算。
l 条件T1：水位线时间>=窗口结束时间。
l 条件T2：在[窗口开始时间，窗口结束时间)中有数据存在。
在理想情况下，水位线应该与处理时间一致，并且处理时间与事件时间只相差常数时间甚至为0。当水位线与处理时间完全重合是，就意味着消息产生后马上被处理，不存在消息迟到的情况。然而，由于网络拥塞或系统原因，消息尝尝存在迟到的情况，因此，在设置水位线时，总是考虑一定的延时，从而给予迟到的数据一些机会。具体的延迟大小由用户根据业务情况在流处理SQL语句中指定。
关于AntDB数据库
AntDB数据库始于2008年，在运营商的核心系统上，为全国24个省份的10亿多用户提供在线服务，具备高性能、弹性扩展、高可靠等产品特性，峰值每秒可处理百万笔通信核心交易，保障系统持续稳定运行近十年，并在通信、金融、交通、能源、物联网等行业成功商用落地。
更多详情，欢迎访问官方：www.antdb.net
