公开(公告)号：US20110282812A1

公开(公告)日：2011-11-17

申请号：US12780939

申请日：2010-05-17

申请人： Badrish Chandramouli ,  Jonathan D. Goldstein ,  David Maier ,  Mohamed H. Ali ,  Roman Schindlauer

发明人： Badrish Chandramouli ,  Jonathan D. Goldstein ,  David Maier ,  Mohamed H. Ali ,  Roman Schindlauer

IPC分类号： G06N5/02 ,  G06F15/18

CPC分类号： G06F17/30522 ,  G06F9/542 ,  G06N99/005

摘要： Architecture introduces a new pattern operator referred to as called an augmented transition network (ATN), which is a streaming adaptation of non-reentrant, fixed-state ATNs for dynamic patterns. Additional user-defined information is associated with automaton states and is accessible to transitions during execution. ATNs are created that directly model complex pattern continuous queries with arbitrary cycles in a transition graph. The architecture can express the desire to ignore some events during pattern detection, and can also detect the absence of data as part of a pattern. The architecture facilitates efficient support for negation, ignorable events, and state cleanup based on predicate punctuations.

摘要翻译： 架构引入了称为增强转换网络（ATN）的新的模式运算符，其是用于动态模式的非可重入固定状态ATN的流适配。 其他用户定义的信息与自动机状态相关联，并且在执行期间可以转换。 创建ATN，在转换图中直接建模具有任意周期的复杂模式连续查询。 该架构可以表示在模式检测期间忽略某些事件的愿望，并且还可以检测不存在数据作为模式的一部分。 该架构有助于有效支持基于谓词标点符号的否定，可忽略事件和状态清理。

公开(公告)号：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）的支持。

公开(公告)号：US08977643B2

公开(公告)日：2015-03-10

申请号：US12826689

申请日：2010-06-30

申请人： Roman Schindlauer ,  Balan Sethu Raman ,  Torsten W. Grabs ,  Beysim Sezgin

发明人： Roman Schindlauer ,  Balan Sethu Raman ,  Torsten W. Grabs ,  Beysim Sezgin

IPC分类号： G06F17/30

CPC分类号： G06F17/30424 ,  G06F17/30516 ,  G06F17/30545 ,  G06F17/30569

摘要： The disclosed architecture leverages realtime continuous event processing (CEP) to address using a general input interface framework to import a dynamic set of event types (e.g., assets), and using a declarative, expressive query model to implement monitoring and management tasks on an asset level. This is in contrast to looking separately at single values from static databases and/or realtime streams as is common conventionally. The architecture uses the CEP data model to model assets as realtime event types. Thus, queries can be formulated per asset and not just per single stream. The architecture uses the query capabilities of CEP to formulate asset management and monitoring tasks as standing, declarative queries, and uses the input interface of a CEP platform to correlate data from different data sources with different dynamic properties.

摘要翻译： 所公开的体系结构利用实时连续事件处理（CEP）来解决使用一般输入接口框架来导入一组动态事件类型（例如资产），并使用声明性表达式查询模型来实现对资产的监控和管理任务 水平。 这与传统上常规地从静态数据库和/或实时流中分离出的单个值是相反的。 该架构使用CEP数据模型将资产建模为实时事件类型。 因此，可以为每个资产制定查询，而不仅仅是单个流。 该架构使用CEP的查询功能，将资产管理和监控任务作为站点，声明性查询进行配置，并使用CEP平台的输入界面将来自不同数据源的数据与不同的动态属性相关联。

公开(公告)号：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）的支持。

公开(公告)号：US08752072B2

公开(公告)日：2014-06-10

申请号：US12893775

申请日：2010-09-29

申请人： Jonathan Goldstein ,  Ping Wang ,  Roman Schindlauer ,  Balan Sethu Raman

发明人： Jonathan Goldstein ,  Ping Wang ,  Roman Schindlauer ,  Balan Sethu Raman

IPC分类号： G06F9/44 ,  G06F15/16

CPC分类号： G06F9/542

摘要： The present invention extends to methods, systems, and computer program products for altering event lifetimes. Embodiments of the invention include using operators in an event-processing framework (algebra) to shorten (or “clip”) the duration of events. An operator can receive a primary event stream, a clip event stream, and condition as parameters. The operator clips the lifetime of an event in the primary stream to the next event in the clip stream that fulfills the condition. Altering event lifetimes can be used to facilitate cleaning event stream state, converting point events to a continuous signal, and creating and annotating session events.

摘要翻译： 本发明扩展到用于改变事件寿命的方法，系统和计算机程序产品。 本发明的实施例包括在事件处理框架（代数）中使用操作符来缩短（或“剪切”）事件持续时间。 操作员可以接收主事件流，剪辑事件流和条件作为参数。 操作员将主流中的事件的生存期剪辑到满足条件的剪辑流中的下一个事件。 改变事件生命周期可以用于促进清除事件流状态，将点事件转换为连续信号，以及创建和注释会话事件。

公开(公告)号：US20110093490A1

公开(公告)日：2011-04-21

申请号：US12603308

申请日：2009-10-21

申请人： Roman Schindlauer ,  Beysim Sezgin ,  Torsten Grabs

发明人： Roman Schindlauer ,  Beysim Sezgin ,  Torsten Grabs

IPC分类号： G06F17/30 ,  G06F7/00

CPC分类号： G06F17/30477 ,  G06F17/30929

摘要： Methods, systems, and computer-readable media are disclosed for event processing with a query based on a reusable XML query template. A particular method includes receiving a plurality of events from a source and generating a plurality of event objects based on the plurality of events. A query represented by an XML file based on a reusable XML query template is executed with respect to the plurality of event objects to produce a plurality of result objects. Each result object is produced based on an application of at least one operator of the query. A plurality of results is generated based on the plurality of result objects, and the plurality of results is transmitted to a sink.

摘要翻译： 公开了用于基于可重用XML查询模板的查询的事件处理的方法，系统和计算机可读介质。 一种特定的方法包括从源接收多个事件并基于多个事件生成多个事件对象。 针对多个事件对象执行基于可重用XML查询模板的由XML文件表示的查询，以产生多个结果对象。 每个结果对象基于查询的至少一个运算符的应用来生成。 基于多个结果对象生成多个结果，并将多个结果发送到汇点。

公开(公告)号：US09158816B2

公开(公告)日：2015-10-13

申请号：US12603308

申请日：2009-10-21

申请人： Roman Schindlauer ,  Beysim Sezgin ,  Torsten Grabs

发明人： Roman Schindlauer ,  Beysim Sezgin ,  Torsten Grabs

IPC分类号： G06F17/30

CPC分类号： G06F17/30477 ,  G06F17/30929

摘要： Methods, systems, and computer-readable media are disclosed for event processing with a query based on a reusable XML query template. A particular method includes receiving a plurality of events from a source and generating a plurality of event objects based on the plurality of events. A query represented by an XML file based on a reusable XML query template is executed with respect to the plurality of event objects to produce a plurality of result objects. Each result object is produced based on an application of at least one operator of the query. A plurality of results is generated based on the plurality of result objects, and the plurality of results is transmitted to a sink.

摘要翻译： 公开了用于基于可重用XML查询模板的查询的事件处理的方法，系统和计算机可读介质。 一种特定的方法包括从源接收多个事件并基于多个事件生成多个事件对象。 针对多个事件对象执行基于可重用XML查询模板的由XML文件表示的查询，以产生多个结果对象。 每个结果对象基于查询的至少一个运算符的应用来生成。 基于多个结果对象生成多个结果，并将多个结果发送到汇点。

公开(公告)号：US08762297B2

公开(公告)日：2014-06-24

申请号：US12780939

申请日：2010-05-17

申请人： Badrish Chandramouli ,  Jonathan D. Goldstein ,  David Maier ,  Mohamed H. Ali ,  Roman Schindlauer

发明人： Badrish Chandramouli ,  Jonathan D. Goldstein ,  David Maier ,  Mohamed H. Ali ,  Roman Schindlauer

IPC分类号： G06N5/00

CPC分类号： G06F17/30522 ,  G06F9/542 ,  G06N99/005

摘要： Architecture introduces a new pattern operator referred to as called an augmented transition network (ATN), which is a streaming adaptation of non-reentrant, fixed-state ATNs for dynamic patterns. Additional user-defined information is associated with automaton states and is accessible to transitions during execution. ATNs are created that directly model complex pattern continuous queries with arbitrary cycles in a transition graph. The architecture can express the desire to ignore some events during pattern detection, and can also detect the absence of data as part of a pattern. The architecture facilitates efficient support for negation, ignorable events, and state cleanup based on predicate punctuations.

摘要翻译： 架构引入了称为增强转换网络（ATN）的新的模式运算符，其是用于动态模式的非可重入固定状态ATN的流适配。 其他用户定义的信息与自动机状态相关联，并且在执行期间可以转换。 创建ATN，在转换图中直接建模具有任意周期的复杂模式连续查询。 该架构可以表示在模式检测期间忽略某些事件的愿望，并且还可以检测不存在数据作为模式的一部分。 该架构有助于有效支持基于谓词标点符号的否定，可忽略事件和状态清理。

公开(公告)号：US20120079506A1

公开(公告)日：2012-03-29

申请号：US12893775

申请日：2010-09-29

申请人： Jonathan Goldstein ,  Ping Wang ,  Roman Schindlauer ,  Balan Sethu Raman

发明人： Jonathan Goldstein ,  Ping Wang ,  Roman Schindlauer ,  Balan Sethu Raman

IPC分类号： G06F9/46

CPC分类号： G06F9/542

摘要： The present invention extends to methods, systems, and computer program products for altering event lifetimes. Embodiments of the invention include using operators in an event-processing framework (algebra) to shorten (or “clip”) the duration of events. An operator can receive a primary event stream, a clip event stream, and condition as parameters. The operator clips the lifetime of an event in the primary stream to the next event in the clip stream that fulfills the condition. Altering event lifetimes can be used to facilitate cleaning event stream state, converting point events to a continuous signal, and creating and annotating session events.

摘要翻译： 本发明扩展到用于改变事件寿命的方法，系统和计算机程序产品。 本发明的实施例包括在事件处理框架（代数）中使用操作符来缩短（或“剪切”）事件持续时间。 操作员可以接收主事件流，剪辑事件流和条件作为参数。 操作员将主流中的事件的生存期剪辑到满足条件的剪辑流中的下一个事件。 改变事件生命周期可以用于促进清除事件流状态，将点事件转换为连续信号，以及创建和注释会话事件。

公开(公告)号：US20120005220A1

公开(公告)日：2012-01-05

申请号：US12826689

申请日：2010-06-30

申请人： Roman Schindlauer ,  Balan Sethu Raman ,  Torsten W. Grabs ,  Beysim Sezgin

发明人： Roman Schindlauer ,  Balan Sethu Raman ,  Torsten W. Grabs ,  Beysim Sezgin

IPC分类号： G06F17/30

CPC分类号： G06F17/30424 ,  G06F17/30516 ,  G06F17/30545 ,  G06F17/30569

摘要： The disclosed architecture leverages realtime continuous event processing (CEP) to address using a general input interface framework to import a dynamic set of event types (e.g., assets), and using a declarative, expressive query model to implement monitoring and management tasks on an asset level. This is in contrast to looking separately at single values from static databases and/or realtime streams as is common conventionally. The architecture uses the CEP data model to model assets as realtime event types. Thus, queries can be formulated per asset and not just per single stream. The architecture uses the query capabilities of CEP to formulate asset management and monitoring tasks as standing, declarative queries, and uses the input interface of a CEP platform to correlate data from different data sources with different dynamic properties.

摘要翻译： 所公开的体系结构利用实时连续事件处理（CEP）来解决使用一般输入接口框架来导入一组动态事件类型（例如资产），并使用声明性表达式查询模型来实现对资产的监控和管理任务 水平。 这与传统上常规地从静态数据库和/或实时流中分离出的单个值是相反的。 该架构使用CEP数据模型将资产建模为实时事件类型。 因此，可以为每个资产制定查询，而不仅仅是单个流。 该架构使用CEP的查询功能，将资产管理和监控任务作为站点，声明性查询进行配置，并使用CEP平台的输入界面将来自不同数据源的数据与不同的动态属性相关联。