指标统计方法、系统、设备及存储介质

摘要

本发明公开了一种基于大数据处理框架的滑动窗口的指标统计方法、系统、设备及存储介质，指标统计方法使用mapWithState算子中的State对象存储若干参数，参数包括时间链表、时间链表的最小值、时间链表的最大值和指标统计值；指标统计方法包括以下步骤：大数据处理框架接收数据，每条数据包括待统计指标字段和对应的时间戳，时间链表用于按时间顺序存储数据的时间戳；将接收的最新的一条数据作为当前数据；根据当前数据的时间戳、当前数据的待统计指标字段及预设的时间窗口值更新时间链表、最小值、最大值和指标统计值，指标统计值通过复用计算得到。本发明通过复用已经计算过的统计值进而减少计算量、提高计算速度、减小延迟，能够更快地响应业务的统计需求。