会员体验
专利管家(专利管理)
工作空间(专利管理)
风险监控(情报监控)
数据分析(专利分析)
侵权分析(诉讼无效)
联系我们
交流群
官方交流:
QQ群: 891211   
微信请扫码    >>>
现在联系顾问~
热词
    • 1. 发明申请
    • PARALLEL PROCESSING OF CONTINUOUS QUERIES ON DATA STREAMS
    • 数据流连续查询并行处理
    • US20110314019A1
    • 2011-12-22
    • US13112628
    • 2011-05-20
    • Ricardo Jimenez PerisMarta Patiño Martinez
    • Ricardo Jimenez PerisMarta Patiño Martinez
    • G06F17/30
    • G06F16/24568G06F9/5066G06F9/5088G06F16/24532
    • A continuous query parallel engine on data streams provides scalability and increases the throughput by the addition of new nodes. The parallel processing can be applied to data stream processing and complex events processing. The continuous query parallel engine receives the query to be deployed and splits the original query into subqueries, obtaining at least one subquery; each subquery is executed in at least in one node. Tuples produced by each operator of each subquery are labeled with timestamps. A load balancer is interposed at the output of each node that executes each one of the instances of the source subquery and an input merger is interposed in each node that executes each one of the instances of a destination subquery. After checks are performed, further load balancers or input managers may be added.
    • 数据流上的连续查询并行引擎提供可扩展性,并通过添加新节点来增加吞吐量。 并行处理可以应用于数据流处理和复杂事件处理。 连续查询并行引擎接收要部署的查询,并将原始查询拆分为子查询,获取至少一个子查询; 每个子查询至少在一个节点中执行。 每个子查询的每个运算符生成的元组都标记有时间戳。 在每个节点的输出处插入负载平衡器,该输出执行源子查询的每个实例,并且在执行目标子查询的每个实例的每个节点中插入输入合并。 执行检查后,可以添加进一步的负载平衡器或输入管理器。