分布式查询处理是数据集成系统实现的关键技术之一。优化查询处理方式,提高执行效率并缩短查询响应时间,一直是数据集成系统研究的重要主题。　　暨南大学信息科学技术学院高性能数据库开发实验室前已开发面向大数据分析环境事务数据在线集成的通用中间件系统II_SERVICE。它支持对跨组织及网域的异构信息源实现虚拟方式与实体化方式相结合的数据集成,从而屏蔽底层数据源差异，向应用提供基于全局模式的透明数据访问支持。　　本文在此基础上，致力于研究在网络传输速率难以预测的前提下，如何提高集成端的汇总处理的执行效率，并缩短查询响应时间。主要内容包括:　　(1)对实现SQL查询的代数运算深入分析其阻塞性及运算分解与组合,以形成尽可能佳的流水线组织及计算节点间数据传递方式。　　(2)研究查询运算的状态性，对查询语法树中可以进行存储流水计算的节点进行优化，通过减少输入元组与历史元组的匹配量，进而提高流水线的执行效率，所提出的流水线双哈希连接算法利用双哈希策略可以有效地缓解X-join算法中历史元组的聚集现象。　　(3)在查询计划的执行粒度上，尽量把能够使用流水线计算的相邻节点合并成一个动作，进而形成大粒度流水线计算。在查询计划的执行控制上，采用ECA判定规则，以此判断当前动作是否可以与其他动作参与并发执行。