一种用于流计算的数据处理方法与设备

摘要

本申请的目的是提供一种用于流计算的数据处理方法与设备；获取流计算信息中的目标消息；通过布隆过滤器判断对应存储是否包括所述目标消息所对应的中间数据结果；当判断所述对应存储包括所述中间数据结果时，检验所述中间数据结果是否已存在；基于检验所得信息，对所述目标消息执行相应的数据计算。与现有技术相比，本申请通过布隆过滤器检测目标消息对应的中间结果信息是否已存在，以及对被判断为已存在的中间结果信息的进一步检测，实现对目标消息的流计算；由于布隆过滤器具有非常好的空间和时间效率，本申请显著减少了内存查询时间，在保障不影响内存工作的前提下有效地提高了流计算的实时性，减少了响应延迟，改善了用户的使用体验。

主权项

一种用于流计算的数据处理方法，其中，所述方法包括：获取流计算信息中的目标消息；通过布隆过滤器判断对应存储是否包括所述目标消息所对应的中间数据结果；当判断所述对应存储包括所述中间数据结果时，检验所述中间数据结果是否已存在；基于检验所得信息，对所述目标消息执行相应的数据计算。