专利快速检索-快速检索全球专利，免费商用专利数据库-IPRDB

1. 发明授权

US08392936B2 Complex event processing (CEP) adapters for CEP systems for receiving objects from a source and outputing objects to a sink 有权
标题翻译：用于CEP系统的复杂事件处理（CEP）适配器，用于从源接收对象并将对象输出到接收器
公开(公告)号：US08392936B2
公开(公告)日：2013-03-05
申请号：US13360548
申请日：2012-01-27
申请人： Ciprian Gerea , Ramkumar Krishnan , Tomer Verona , Balan Sethu Raman , Beysim Sezgin
发明人： Ciprian Gerea , Ramkumar Krishnan , Tomer Verona , Balan Sethu Raman , Beysim Sezgin
IPC分类号： G06F13/00
CPC分类号： G06F9/542
摘要： Methods, systems, and computer-readable media are disclosed for implementing adapters for event processing systems. A particular system includes an input adapter configured to store event objects received from a source at an input queue. The system also includes a query engine configured to remove event objects from the input queue, to perform a query with respect to the removed event objects to generate result objects, and to insert result objects into an output queue. The system also includes an output adapter configured to remove result objects from the output queue and to transmit the result objects to a sink.
摘要翻译：公开了用于实现事件处理系统的适配器的方法，系统和计算机可读介质。特定系统包括被配置为存储在输入队列处从源接收的事件对象的输入适配器。该系统还包括配置为从输入队列中移除事件对象的查询引擎，以便相对于删除的事件对象执行查询以生成结果对象，并将结果对象插入到输出队列中。该系统还包括一个输出适配器，配置为从输出队列中删除结果对象，并将结果对象传送到接收器。

2. 发明授权

US08195648B2 Partitioned query execution in event processing systems 有权
标题翻译：在事件处理系统中执行分区查询
公开(公告)号：US08195648B2
公开(公告)日：2012-06-05
申请号：US12603385
申请日：2009-10-21
申请人： Peter Zabback , Tihomir Tarnavski , Beysim Sezgin , Tomer Verona
发明人： Peter Zabback , Tihomir Tarnavski , Beysim Sezgin , Tomer Verona
IPC分类号： G06F17/30
CPC分类号： G06F17/30451
摘要： Methods, systems, and computer-readable media are disclosed for partitioned query execution in event processing systems. A particular method includes receiving a plurality of events via an input stream. The plurality of events is partitioned into one or more groups, and a query application module is instantiated for each of the one or more groups based on a compiled query application plan. Each particular query application module for a particular group is configured to apply a query to events of the particular group to generate partial results. The method includes merging the partial results of each of the query application modules to generate merged output results and providing the output results to an output stream.
摘要翻译：公开了用于事件处理系统中的分区查询执行的方法，系统和计算机可读介质。一种特定方法包括经由输入流接收多个事件。多个事件被划分成一个或多个组，并且基于编译的查询应用程序计划为一个或多个组中的每一个实例化查询应用程序模块。针对特定组的每个特定查询应用模块被配置为对特定组的事件应用查询以生成部分结果。该方法包括合并每个查询应用模块的部分结果以产生合并的输出结果并将输出结果提供给输出流。

3. 发明申请

US20120131599A1 COMPLEX EVENT PROCESSING (CEP) ADAPTERS FOR CEP SYSTEMS FOR RECEIVING OBJECTS FROM A SOURCE AND OUTPUTING OBJECTS TO A SINK 有权
标题翻译：用于从源头接收对象的CEP系统的复杂事件处理（CEP）适配器，并将输出对象传输到一个SINK
公开(公告)号：US20120131599A1
公开(公告)日：2012-05-24
申请号：US13360548
申请日：2012-01-27
申请人： Ciprian Gerea , Ramkumar Krishnan , Tomer Verona , Balan Sethu Raman , Beysim Sezgin
发明人： Ciprian Gerea , Ramkumar Krishnan , Tomer Verona , Balan Sethu Raman , Beysim Sezgin
IPC分类号： G06F9/46
CPC分类号： G06F9/542
摘要： Methods, systems, and computer-readable media are disclosed for implementing adapters for event processing systems. A particular system includes an input adapter configured to store event objects received from a source at an input queue. The system also includes a query engine configured to remove event objects from the input queue, to perform a query with respect to the removed event objects to generate result objects, and to insert result objects into an output queue. The system also includes an output adapter configured to remove result objects from the output queue and to transmit the result objects to a sink.
摘要翻译：公开了用于实现事件处理系统的适配器的方法，系统和计算机可读介质。特定系统包括被配置为存储在输入队列处从源接收的事件对象的输入适配器。该系统还包括配置为从输入队列中移除事件对象的查询引擎，以便相对于删除的事件对象执行查询以生成结果对象，并将结果对象插入到输出队列中。该系统还包括一个输出适配器，配置为从输出队列中删除结果对象，并将结果对象传送到接收器。

4. 发明申请

US20130031567A1 LOCAL EVENT PROCESSING 审中-公开
标题翻译：本地活动处理
公开(公告)号：US20130031567A1
公开(公告)日：2013-01-31
申请号：US13189566
申请日：2011-07-25
申请人： Olivier Nano , Ivo Santos , Marcel Tilly , Tomer Verona
发明人： Olivier Nano , Ivo Santos , Marcel Tilly , Tomer Verona
IPC分类号： G06F9/46
CPC分类号： G05B21/02 , G05B23/0264
摘要： The claimed subject matter provides a method for processing a stream of events. The method includes receiving a stream of events at a local device. The stream of events is associated with the local device. Further, the stream of events includes one or more out-of-order events. The method also includes executing a first complex event processing query against the stream of events. The stream of events is processed based on multiple levels of consistency defined by a set of operators. Additionally, the method includes correcting the out-of-order events based on the set of operators. A first output is generated in which consistency is guaranteed based on the corrected out-of-order events. The method also includes sending the first output to a server that performs complex event processing on the output.
摘要翻译：所要求保护的主题提供了一种处理事件流的方法。该方法包括在本地设备处接收事件流。事件流与本地设备相关联。此外，事件流包括一个或多个无序事件。该方法还包括针对事件流执行第一复杂事件处理查询。基于由一组运算符定义的多个一致性来处理事件流。另外，该方法包括基于该组运算符来校正无序事件。产生第一输出，其中基于校正的无序事件来保证一致性。该方法还包括将第一输出发送到对输出执行复杂事件处理的服务器。

5. 发明申请

US20120297080A1 Stream Operator 有权
标题翻译：流操作员
公开(公告)号：US20120297080A1
公开(公告)日：2012-11-22
申请号：US13108005
申请日：2011-05-16
申请人： Colin Joseph Meek , Mohamed Hassan Ali , Galex Sunyul Yen , Ciprian Gerea , Balan Sethu Raman , Jonathan David Goldstein , Badrish Chandramouli , Tomer Verona , Torsten Walther Grabs
发明人： Colin Joseph Meek , Mohamed Hassan Ali , Galex Sunyul Yen , Ciprian Gerea , Balan Sethu Raman , Jonathan David Goldstein , Badrish Chandramouli , Tomer Verona , Torsten Walther Grabs
IPC分类号： G06F15/16
CPC分类号： G06F9/542
摘要： Aspects of the subject matter described herein relate to stream operators. In aspects, a stream event is received. Based on a timestamp associated with the stream event and the number of stream operators that have asked to be activated prior to or at the timestamp, zero or more stream objects are informed of one or more time events and torn down if no longer needed. In addition, a destination stream operator is instantiated, if needed, data (e.g., the timestamp and packet, if any) corresponding to the stream event is provided to a stream operator, output data, if any, is received from the stream operator, and the stream operator is torn down if it no longer needs state data between invocations.
摘要翻译：本文描述的主题的方面涉及流操作员。在方面，接收流事件。基于与流事件相关联的时间戳和要求在时间戳之前或时间戳处被激活的流运算符的数量，零或多个流对象被通知一个或多个时间事件，并且如果不再需要则被拆除。另外，如果需要，将目的地流运算符进行实例化，将与流事件相对应的数据（例如，时间戳和分组，如果有的话）提供给流运算符，则从流运算符接收输出数据（如果有的话）如果流操作员不再需要调用之间的状态数据，则该流操作符将被拆除。

6. 发明申请

US20110283295A1 EXTENSIBILITY MODEL FOR STREAM-BASED OPERATORS AND AGGREGATES 有权
标题翻译：基于流水线算子和集合的可扩展模型
公开(公告)号：US20110283295A1
公开(公告)日：2011-11-17
申请号：US12777259
申请日：2010-05-11
申请人： Mohamed H. Ali , Tomer Verona , Balan Sethu Raman , Beysim Sezgin , Jonathan D. Goldstein , Badrish Chandramouli , Ping Wang , Roman Schindlauer , Asvin Ananthanarayan
发明人： Mohamed H. Ali , Tomer Verona , Balan Sethu Raman , Beysim Sezgin , Jonathan D. Goldstein , Badrish Chandramouli , Ping Wang , Roman Schindlauer , Asvin Ananthanarayan
IPC分类号： G06F9/46
CPC分类号： G06F9/542 , G06F8/24
摘要： An extensibility framework that allows a user to write user-defined modules that include user-defined operators (UDO) and user-defined aggregators (UDA) in a non-temporal fashion without the need to worry about temporal attributes of events (or event types). The temporal domain is managed on behalf of the user, and allows the user to write operators and aggregates in the temporal data streaming domain as well as to port existing libraries of non-temporal UDOs/UDAs to the temporal data streaming domain. Temporal attributes and event types are managed for non-temporal UDOs/UDAs by the extensibility framework on behalf of the UDO/UDA writer. Windows can be employed to bridge the gap between the non-temporal domains and temporal domains. Support for complex event processing (CEP) is provided in UDOs/UDAs for base classes related to a CEP operator, CEP aggregate, CEP time sensitive operator, and CEP time sensitive aggregate.
摘要翻译：一种可扩展性框架，允许用户以非时间方式编写包含用户定义的运算符（UDO）和用户定义聚合器（UDA）的用户定义模块，而无需担心事件（或事件类型）的时间属性）。时域是代表用户管理的，并允许用户在时间数据流域中编写运算符和聚合，并将现有的非时间UDO / UDA库链接到时间数据流域。代表UDO / UDA作者的可扩展性框架为非时间UDO / UDAs管理时间属性和事件类型。 Windows可用于弥合非时间域和时域之间的差距。对于与CEP运算符，CEP聚合，CEP时间敏感运算符和CEP时间敏感聚合相关的基类，在UDO / UDA中提供了对复杂事件处理（CEP）的支持。

7. 发明申请

US20110093631A1 ADAPTERS FOR EVENT PROCESSING SYSTEMS 有权
标题翻译：事件处理系统的适配器
公开(公告)号：US20110093631A1
公开(公告)日：2011-04-21
申请号：US12603416
申请日：2009-10-21
申请人： Ciprian Gerea , Ramkumar Krishnan , Tomer Verona , Balan Sethu Raman , Beysim Sezgin
发明人： Ciprian Gerea , Ramkumar Krishnan , Tomer Verona , Balan Sethu Raman , Beysim Sezgin
IPC分类号： G06F13/00
CPC分类号： G06F9/542
摘要： Methods, systems, and computer-readable media are disclosed for implementing adapters for event processing systems. A particular system includes an input adapter configured to store event objects received from a source at an input queue. The system also includes a query engine configured to remove event objects from the input queue, to perform a query with respect to the removed event objects to generate result objects, and to insert result objects into an output queue. The system also includes an output adapter configured to remove result objects from the output queue and to transmit the result objects to a sink.
摘要翻译：公开了用于实现事件处理系统的适配器的方法，系统和计算机可读介质。特定系统包括被配置为存储在输入队列处从源接收的事件对象的输入适配器。该系统还包括配置为从输入队列中移除事件对象的查询引擎，以便相对于删除的事件对象执行查询以生成结果对象，并将结果对象插入到输出队列中。该系统还包括一个输出适配器，配置为从输出队列中删除结果对象，并将结果对象传送到接收器。

8. 发明申请

US20110093491A1 PARTITIONED QUERY EXECUTION IN EVENT PROCESSING SYSTEMS 有权
标题翻译：事件处理系统中的分类查询执行
公开(公告)号：US20110093491A1
公开(公告)日：2011-04-21
申请号：US12603385
申请日：2009-10-21
申请人： Peter Zabback , Tihomir Tarnavski , Beysim Sezgin , Tomer Verona
发明人： Peter Zabback , Tihomir Tarnavski , Beysim Sezgin , Tomer Verona
IPC分类号： G06F17/30
CPC分类号： G06F17/30451
摘要： Methods, systems, and computer-readable media are disclosed for partitioned query execution in event processing systems. A particular method includes receiving a plurality of events via an input stream. The plurality of events is partitioned into one or more groups, and a query application module is instantiated for each of the one or more groups based on a compiled query application plan. Each particular query application module for a particular group is configured to apply a query to events of the particular group to generate partial results. The method includes merging the partial results of each of the query application modules to generate merged output results and providing the output results to an output stream.
摘要翻译：公开了用于事件处理系统中的分区查询执行的方法，系统和计算机可读介质。一种特定方法包括经由输入流接收多个事件。多个事件被划分成一个或多个组，并且基于编译的查询应用程序计划为一个或多个组中的每一个实例化查询应用程序模块。针对特定组的每个特定查询应用模块被配置为对特定组的事件应用查询以生成部分结果。该方法包括合并每个查询应用模块的部分结果以产生合并的输出结果并将输出结果提供给输出流。

9. 发明授权

US08683074B2 Stream operator 有权
标题翻译：流操作员
公开(公告)号：US08683074B2
公开(公告)日：2014-03-25
申请号：US13108005
申请日：2011-05-16
申请人： Colin Joseph Meek , Mohamed Hassan Ali , Galex Sunyul Yen , Ciprian Gerea , Balan Sethu Raman , Jonathan David Goldstein , Badrish Chandramouli , Tomer Verona , Torsten Walther Grabs
发明人： Colin Joseph Meek , Mohamed Hassan Ali , Galex Sunyul Yen , Ciprian Gerea , Balan Sethu Raman , Jonathan David Goldstein , Badrish Chandramouli , Tomer Verona , Torsten Walther Grabs
IPC分类号： G06F15/16
CPC分类号： G06F9/542
摘要： Aspects of the subject matter described herein relate to stream operators. In aspects, a stream event is received. Based on a timestamp associated with the stream event and the number of stream operators that have asked to be activated prior to or at the timestamp, zero or more stream objects are informed of one or more time events and torn down if no longer needed. In addition, a destination stream operator is instantiated, if needed, data (e.g., the timestamp and packet, if any) corresponding to the stream event is provided to a stream operator, output data, if any, is received from the stream operator, and the stream operator is torn down if it no longer needs state data between invocations.
摘要翻译：本文描述的主题的方面涉及流操作员。在方面，接收流事件。基于与流事件相关联的时间戳和要求在时间戳之前或时间戳处被激活的流运算符的数量，零或多个流对象被通知一个或多个时间事件，并且如果不再需要则被拆除。另外，如果需要，将目的地流运算符进行实例化，将与流事件相对应的数据（例如，时间戳和分组，如果有的话）提供给流运算符，则从流运算符接收输出数据（如果有的话）如果流操作员不再需要调用之间的状态数据，则该流操作符将被拆除。

10. 发明授权

US08381233B2 Extensibility model for stream-based operators and aggregates 有权
标题翻译：基于流的运算符和聚合的可扩展性模型
公开(公告)号：US08381233B2
公开(公告)日：2013-02-19
申请号：US12777259
申请日：2010-05-11
申请人： Mohamed H. Ali , Tomer Verona , Balan Sethu Raman , Beysim Sezgin , Jonathan D. Goldstein , Badrish Chandramouli , Ping Wang , Roman Schindlauer , Asvin Ananthanarayan
发明人： Mohamed H. Ali , Tomer Verona , Balan Sethu Raman , Beysim Sezgin , Jonathan D. Goldstein , Badrish Chandramouli , Ping Wang , Roman Schindlauer , Asvin Ananthanarayan
IPC分类号： G06F3/00
CPC分类号： G06F9/542 , G06F8/24
摘要： An extensibility framework that allows a user to write user-defined modules that include user-defined operators (UDO) and user-defined aggregators (UDA) in a non-temporal fashion without the need to worry about temporal attributes of events (or event types). The temporal domain is managed on behalf of the user, and allows the user to write operators and aggregates in the temporal data streaming domain as well as to port existing libraries of non-temporal UDOs/UDAs to the temporal data streaming domain. Temporal attributes and event types are managed for non-temporal UDOs/UDAs by the extensibility framework on behalf of the UDO/UDA writer. Windows can be employed to bridge the gap between the non-temporal domains and temporal domains. Support for complex event processing (CEP) is provided in UDOs/UDAs for base classes related to a CEP operator, CEP aggregate, CEP time sensitive operator, and CEP time sensitive aggregate.
摘要翻译：一种可扩展性框架，允许用户以非时间方式编写包含用户定义的运算符（UDO）和用户定义聚合器（UDA）的用户定义模块，而无需担心事件（或事件类型）的时间属性）。时域是代表用户管理的，并允许用户在时间数据流域中编写运算符和聚合，并将现有的非时间UDO / UDA库链接到时间数据流域。代表UDO / UDA作者的可扩展性框架为非时间UDO / UDAs管理时间属性和事件类型。 Windows可用于弥合非时间域和时域之间的差距。对于与CEP运算符，CEP聚合，CEP时间敏感运算符和CEP时间敏感聚合相关的基类，在UDO / UDA中提供了对复杂事件处理（CEP）的支持。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式