1 .一种分布式数据连接处理方法,其特征在于,包括:
读取本端的数据集合过程中,周期性地生成第一布隆过滤器并发送给对端;
周期性地接收所述对端发送的第二布隆过滤器,所述第二布隆过滤器是由所述对端根
据所述对端的数据集合生成的;
每接收到一个第二布隆过滤器,合并当前接收到的第二布隆过滤器与最近一次生成的
第一布隆过滤器或合并当前接收到的第二布隆过滤器与当前进行布隆过滤所使用的双边
布隆过滤器,利用最新的双边布隆过滤器对本端的所述数据集合中的数据进行过滤,其中,
合并之后的布隆过滤器为双边布隆过滤器;
将过滤不成功的数据写入到第三端中。
2.据权利要求1所述的方法,其特征在于,该方法还包括:
缓存过滤成功的数据;
利用后续合并的双边布隆过滤器对缓存的数据再次进行过滤。
3.根据权利要求2所述的方法,其特征在于,所述利用后续合并的双边布隆过滤器对缓
存的数据再次进行布隆过滤,包括:
利用最后一次合并的双边布隆过滤器对所述本端的所述数据集合中的数据进行布隆
过滤。
4 .根据权利要求1
~
3任一项所述的方法,其特征在于,该方法还包括:
在读取完所述本端的所述数据集合中的全部数据,且未接收到所述对端发送的第二扫
描结束指令时,向所述对端发送第一扫描结束指令;
在接收到所述对端发送的所述第二扫描结束指令后,利用最近一次生成的第一布隆过
滤器对所述本端的所述数据集合的数据进行过滤。
5.一种分布式数据连接处理装置,其特征在于,包括:
第一布隆过滤器模块,用于读取本端的数据集合过程中,周期性地生成第一布隆过滤
器并发送给对端;
第二布隆过滤器模块,用于周期性地接收所述对端发送的第二布隆过滤器,所述第二
布隆过滤器是由所述对端根据所述对端的数据集合生成的;
布隆过滤执行模块,用于每接收到一个第二布隆过滤器,合并当前接收到的第二布隆
过滤器与最近一次生成的第一布隆过滤器或合并当前接收到的第二布隆过滤器与当前进
行布隆过滤所使用的双边布隆过滤器,利用最新的双边布隆过滤器对本端的所述数据集合
中的数据进行过滤,其中,合并之后的布隆过滤器为双边布隆过滤器;
数据连接操作模块,用于将过滤不成功的数据写入到第三端中。
6.根据权利要求5所述的装置,其特征在于,还包括缓存模块,用于:缓存过滤成功的数
据;
所述布隆过滤执行模块还用于:利用后续合并的双边布隆过滤器对缓存的数据再次进
行过滤。
7 .根据权利要求5
~
6任一项所述的装置,其特征在于,还包括扫描结束指令发送模块,
用于在读取完所述本端的所述数据集合中的全部数据,且未接收到所述对端发送的第二扫
描结束指令时,向所述对端发送第一扫描结束指令;
所述布隆过滤执行模块还用于:在接收到所述对端发送的所述第二扫描结束指令后,
权 利 要 求 书
1/2 页
2
评论