一种分布式数据流上的K-Skyband连续查询方法及系统

摘要

本申请提供了一种分布式数据流上的K-Skyband连续查询方法，由中央服务器接收不同数据源发送的数据，并由滑动窗口连续读取接收到的数据，然后依据滑动窗口中的数据确定初始全局K-Skyband点的结果集，并将初始全局K-Skyband点的结果集作为当前全局K-Skyband点的结果集，依据滑动窗口读取到新数据后产生的过期数据和所述新数据对所述当前全局K-Skyband点的结果集进行过期维护和更新维护，将过期维护和更新维护后的结果作为查询结果输出。因此，本申请实现了在分布式数据流环境下进行K-Skyband连续查询，扩展了K-Skyband连续查询查询方法的应用领域。