时间窗口累计的实现方法

摘要

本发明公开一种时间窗口累计的实现方法，首先通过滑动时间窗口累计算法对交易数据信息进行统计分析，然后判断时间窗口的位置变换范围、窗体或步长的大小来选择适用加法引擎算法算法或减法引擎算法算法，最后在Redis Cluster数据库或Hbase数据库中完成交易数据累计值和获取值的统计分析与快速查询。本发明解决了多维度多场景组合下，SQL查询算法不灵活、查询吞吐量不高、查询粒度不够精确的问题，实现了获取时间窗口累计值的快速响应，提高了准确性。

主权项

一种时间窗口累计的实现方法，其特征在于，包括以下步骤：S1：实时获取交易数据信息并加以存储；S2：通过滑动时间窗口累计算法对所述交易数据信息进行统计分析；S3：判断时间窗口的位置交换范围、窗体或步长的大小，如果是大则执行步骤S4，否则执行步骤S5；S4：选择减法引擎算法计算Redis Cluster数据库中的数据累计值和获取值，如果Redis Cluster数据库异常则执行步骤S6，若否，则结束；S5：选择加法引擎算法计算Redis Cluster数据库中的数据累计值和获取值，如果Redis Cluster数据库异常则执行步骤S7，若否，则结束；S6：选择减法引擎算法计算Hbase数据库中的数据累计值和获取值；S7：选择加法引擎算法计算Hbase数据库中的数据累计值和获取值。