Method and system for continuous query processing

    公开(公告)号:US09652502B2

    公开(公告)日:2017-05-16

    申请号:US13435756

    申请日:2012-03-30

    IPC分类号: G06F17/30

    摘要: The invention relates to a method and system that provide a continuous querying mechanism that analyses real-time data streams to generate relevant results. It leverages data grid and event processing technology to provide a high performance and extremely scalable continuous querying solution. An embodiment of the invention provides a flexible querying language and data storage to allow users to register their interest in specific types of data, e.g. processes. The users are notified of matching results using an event-based mechanism. In order to efficiently analyze a large amount of data, the embodiment uses a grid infrastructure that allows storage of the data across many grid nodes and distributes the query execution workload, avoiding the bottleneck represented by constantly querying a database. Continuous queries are stored in a Continuous Query Registry and that Registry is invoked every time an insert or update event occurs on the triple store.

    METHOD AND SYSTEM FOR CONTINUOUS QUERY PROCESSING
    3.
    发明申请
    METHOD AND SYSTEM FOR CONTINUOUS QUERY PROCESSING 有权
    连续查询处理方法与系统

    公开(公告)号:US20130262502A1

    公开(公告)日:2013-10-03

    申请号:US13435756

    申请日:2012-03-30

    IPC分类号: G06F17/30

    摘要: The invention relates to a method and system that provide a continuous querying mechanism that analyses real-time data streams to generate relevant results. It leverages data grid and event processing technology to provide a high performance and extremely scalable continuous querying solution. An embodiment of the invention provides a flexible querying language and data storage to allow users to register their interest in specific types of data, e.g. processes. The users are notified of matching results using an event-based mechanism. In order to efficiently analyse a large amount of data, the embodiment uses a grid infrastructure that allows storage of the data across many grid nodes and distributes the query execution workload, avoiding the bottleneck represented by constantly querying a database. Continuous queries are stored in a Continuous Query Registry and that Registry is invoked every time an insert or update event occurs on the triple store.

    摘要翻译: 本发明涉及提供分析实时数据流以产生相关结果的连续查询机制的方法和系统。 它利用数据网格和事件处理技术提供高性能和极其可扩展的连续查询解决方案。 本发明的实施例提供了一种灵活的查询语言和数据存储,以允许用户向特定类型的数据注册他们的兴趣,例如。 过程。 使用基于事件的机制向用户通知匹配结果。 为了有效地分析大量的数据,本实施例使用允许跨多个网格节点存储数据的网格基础设施,并分发查询执行工作负载,避免由不断查询数据库所表示的瓶颈。 连续查询存储在连续查询注册表中,并且每次在三重存储上发生插入或更新事件时都会调用该注册表。

    Method and system for processing data queries

    公开(公告)号:US09639575B2

    公开(公告)日:2017-05-02

    申请号:US13435747

    申请日:2012-03-30

    IPC分类号: G06F17/00 G06F17/30

    CPC分类号: G06F17/30427 G06F17/30448

    摘要: The invention relates to a method and system that provide a high performance and extremely scalable triple store within the Resource Description Framework (or alternative data models), with optimized query execution. An embodiment of the invention provides a data storage and analysis system to support scalable monitoring and analysis of business processes along multiple configurable perspectives and levels of granularity. This embodiment analyses data from processes that have been already executed and from ongoing processes, as a continuous flow of information. This embodiment provides defining and monitoring processes based on no initial domain knowledge about the process and such that the process will be built only from the incoming flow of information. Another embodiment of the invention provides a grid infrastructure that allows storage of data across many grid nodes and distribution of the workload, avoiding the bottleneck represented by constantly querying a database.

    METHOD AND SYSTEM FOR PROCESSING DATA QUERIES
    5.
    发明申请
    METHOD AND SYSTEM FOR PROCESSING DATA QUERIES 有权
    用于处理数据查询的方法和系统

    公开(公告)号:US20130262443A1

    公开(公告)日:2013-10-03

    申请号:US13435747

    申请日:2012-03-30

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30427 G06F17/30448

    摘要: The invention relates to a method and system that provide a high performance and extremely scalable triple store within the Resource Description Framework (or alternative data models), with optimized query execution. An embodiment of the invention provides a data storage and analysis system to support scalable monitoring and analysis of business processes along multiple configurable perspectives and levels of granularity. This embodiment analyses data from processes that have been already executed and from ongoing processes, as a continuous flow of information. This embodiment provides defining and monitoring processes based on no initial domain knowledge about the process and such that the process will be built only from the incoming flow of information. Another embodiment of the invention provides a grid infrastructure that allows storage of data across many grid nodes and distribution of the workload, avoiding the bottleneck represented by constantly querying a database.

    摘要翻译: 本发明涉及一种在资源描述框架(或替代数据模型)中提供优化的查询执行的高性能和极其可扩展的三重存储的方法和系统。 本发明的一个实施例提供了一种数据存储和分析系统,以便沿着多个可配置的观点和粒度级别来支持业务流程的可扩展监控和分析。 该实施例分析来自已经执行的进程的数据和来自正在进行的进程的数据作为连续的信息流。 该实施例提供了基于没有关于过程的初始域知识的定义和监视过程,并且使得该过程将仅从输入的信息流构建。 本发明的另一实施例提供了一种网格基础设施,其允许跨多个网格节点存储数据并分配工作负载,从而避免了不断查询数据库所表示的瓶颈。