一种基于动态修正值的分布数据流Top-K查询处理算法

对分布式数据流进行查询,得到数值最大的K个对象(Top-K观测查询),最直接的解决方法是由中心结点处理分布式数据流,但这种方法导致中心结点和网络负载较大。提出一种基于动态修正值的查询算法,通过对观测数据进行计算得到修正值,并利用该修正值对不同结点处的对象数据进行操作,从而无需将结点数据流全部发送到中心结点就能完成Top-K观测查询。因而可以减少对网络带宽的要求和降低中心结点的负载,同时还能保持查询结果的完全准确。