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

1. 发明授权

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）的支持。

2. 发明申请

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）的支持。

3. 发明申请

US20110282812A1 DYNAMIC PATTERN MATCHING OVER ORDERED AND DISORDERED DATA STREAMS 有权
标题翻译：动态模式匹配超过订单和异常数据流
公开(公告)号：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，在转换图中直接建模具有任意周期的复杂模式连续查询。该架构可以表示在模式检测期间忽略某些事件的愿望，并且还可以检测不存在数据作为模式的一部分。该架构有助于有效支持基于谓词标点符号的否定，可忽略事件和状态清理。

4. 发明授权

US08762297B2 Dynamic pattern matching over ordered and disordered data streams 有权
标题翻译：有序和无序数据流的动态模式匹配
公开(公告)号：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，在转换图中直接建模具有任意周期的复杂模式连续查询。该架构可以表示在模式检测期间忽略某些事件的愿望，并且还可以检测不存在数据作为模式的一部分。该架构有助于有效支持基于谓词标点符号的否定，可忽略事件和状态清理。

5. 发明申请

US20120324453A1 EFFICIENT LOGICAL MERGING OVER PHYSICALLY DIVERGENT STREAMS 有权
标题翻译：通过物理多边形流程进行有效的逻辑整合
公开(公告)号：US20120324453A1
公开(公告)日：2012-12-20
申请号：US13162973
申请日：2011-06-17
申请人： Badrish Chandramouli , David E. Maier , Jonathan D. Goldstein , Peter A. Zabback
发明人： Badrish Chandramouli , David E. Maier , Jonathan D. Goldstein , Peter A. Zabback
IPC分类号： G06F9/46
CPC分类号： G06F17/30516 , G06F7/00 , G06F9/46
摘要： A logical merge module is described herein for producing an output stream which is logically compatible with two or more physically divergent input streams. Representative applications of the logical merge module are also set forth herein.
摘要翻译：本文描述了逻辑合并模块，用于产生逻辑上与两个或多个物理上不同的输入流兼容的输出流。本文还阐述了逻辑合并模块的代表性应用。

6. 发明申请

US20120304003A1 OPERATOR STATE CHECKPOINTS 有权
标题翻译：操作员状态检查
公开(公告)号：US20120304003A1
公开(公告)日：2012-11-29
申请号：US13117165
申请日：2011-05-27
申请人： Jonathan D. Goldstein , Peter A. Zabback , Badrish Chandramouli
发明人： Jonathan D. Goldstein , Peter A. Zabback , Badrish Chandramouli
IPC分类号： G06F11/14
CPC分类号： G06F11/1438 , G06F11/1471
摘要： A checkpoint marker can be received at a first operator. The first operator can process the checkpoint marker by sending the checkpoint marker to a second operator and sending state checkpoint information representing a state of the first operator to a checkpoint writer. The checkpoint information can be used to rehydrate the state of one or more operators. For example, after a system failure, system shutdown, etc., checkpoint information can be received from a reader unit at a checkpoint information input queue of the first operator. A state of the first operator can be rehydrated using the checkpoint information. Processing of information in a data input queue of the first operator can be suspended while the checkpoint information is used to rehydrate the state of the first operator. Other operators in a system with the first operator (e.g., the second operator) may be checkpointed and rehydrated in the same manner as the first operator.
摘要翻译：可以在第一个操作员处接收检查点标记。第一个操作员可以通过将检查点标记发送到第二个操作符来处理检查点标记，并将表示第一个操作符的状态的状态检查点信息发送到检查点编写器。检查点信息可用于对一个或多个操作员的状态进行补水。例如，在系统故障，系统关机等之后，可以在第一运营商的检查点信息输入队列处从读取单元接收检查点信息。可以使用检查点信息对第一操作者的状态进行再水化。当使用检查点信息来补充第一操作者的状态时，可以暂停处理第一操作者的数据输入队列中的信息。具有第一操作者（例如，第二操作者）的系统中的其他操作者可以以与第一操作者相同的方式进行检查点和再水化。

7. 发明授权

US09965520B2 Efficient logical merging over physically divergent streams 有权
公开(公告)号：US09965520B2
公开(公告)日：2018-05-08
申请号：US13162973
申请日：2011-06-17
申请人： Badrish Chandramouli , David E. Maier , Jonathan D. Goldstein , Peter A. Zabback
发明人： Badrish Chandramouli , David E. Maier , Jonathan D. Goldstein , Peter A. Zabback
IPC分类号： H04J3/04 , G06F17/30 , G06F9/46 , G06F7/00
CPC分类号： G06F17/30516 , G06F7/00 , G06F9/46
摘要： A logical merge module is described herein for producing an output stream which is logically compatible with two or more physically divergent input streams. Representative applications of the logical merge module are also set forth herein.

8. 发明授权

US08726076B2 Operator state checkpoint markers and rehydration 有权
标题翻译：操作员状态检查点标记和补液
公开(公告)号：US08726076B2
公开(公告)日：2014-05-13
申请号：US13117165
申请日：2011-05-27
申请人： Jonathan D. Goldstein , Peter A. Zabback , Badrish Chandramouli
发明人： Jonathan D. Goldstein , Peter A. Zabback , Badrish Chandramouli
IPC分类号： G06F11/00 , G06F11/16
CPC分类号： G06F11/1438 , G06F11/1471
摘要： A checkpoint marker can be received at a first operator. The first operator can process the checkpoint marker by sending the checkpoint marker to a second operator and sending state checkpoint information representing a state of the first operator to a checkpoint writer. The checkpoint information can be used to rehydrate the state of one or more operators. For example, after a system failure, system shutdown, etc., checkpoint information can be received from a reader unit at a checkpoint information input queue of the first operator. A state of the first operator can be rehydrated using the checkpoint information. Processing of information in a data input queue of the first operator can be suspended while the checkpoint information is used to rehydrate the state of the first operator. Other operators in a system with the first operator (e.g., the second operator) may be checkpointed and rehydrated in the same manner as the first operator.
摘要翻译：可以在第一个操作员处接收检查点标记。第一个操作员可以通过将检查点标记发送到第二个操作符来处理检查点标记，并将表示第一个操作符的状态的状态检查点信息发送到检查点编写器。检查点信息可用于对一个或多个操作员的状态进行补水。例如，在系统故障，系统关机等之后，可以在第一运营商的检查点信息输入队列处从读取单元接收检查点信息。可以使用检查点信息对第一操作者的状态进行再水化。当使用检查点信息来补充第一操作者的状态时，可以暂停处理第一操作者的数据输入队列中的信息。具有第一操作者（例如，第二操作者）的系统中的其他操作者可以以与第一操作者相同的方式进行检查点和再水化。

9. 发明授权

US06941315B2 Multidimensional data object searching using bit vector indices 失效
公开(公告)号：US06941315B2
公开(公告)日：2005-09-06
申请号：US10602438
申请日：2003-06-23
申请人： Jonathan D. Goldstein , John C. Platt , Christopher J. C. Burges
发明人： Jonathan D. Goldstein , John C. Platt , Christopher J. C. Burges
IPC分类号： G06F17/00 , G06F17/30 , H04Q20060101
CPC分类号： G06F17/30333 , G06F17/30023 , G06F17/30592 , Y10S707/957 , Y10S707/99933 , Y10S707/99942 , Y10S707/99943 , Y10S707/99945 , Y10S707/99948
摘要： Prior to searching a multidimensional feature space populated with data objects, each dimension in the feature space is divided into a number of intervals. When a query is received, a single interval that is overlapped by the query is selected from each dimension. A reduced set of data objects is then selected that includes only those data objects that overlap the selected intervals. This reduced set of data objects, rather than the entire set of data objects in the feature space, is then used to determine matches for the query.

10. 发明授权

US08060614B2 Streaming operator placement for distributed stream processing 有权
标题翻译：用于分布式流处理的流式操作员位置
公开(公告)号：US08060614B2
公开(公告)日：2011-11-15
申请号：US12141914
申请日：2008-06-19
申请人： Jonathan D. Goldstein , Roger S. Barga , Mirek Riedewald , Mingsheng Hong
发明人： Jonathan D. Goldstein , Roger S. Barga , Mirek Riedewald , Mingsheng Hong
IPC分类号： G06F15/16
CPC分类号： G06F9/5083
摘要： A streaming operator assignment system and method for determining a streaming operator assignment that minimizes overload in a data processing system. Embodiments of the streaming operator assignment system include an optimization goals definition module, which defines optimization goals in terms of fundamental quantities that system administrators and application writers want to control, such as minimizing the worst case latency over all periods of time, or minimizing how much the system is backlogged with work. Embodiments of the streaming operator assignment system also include an optimization goals solution module that optimizes and solves a selected optimization goal. A specialized optimization technique is used to find the best operator (or load) assignment using the optimization goals to measure of the value of the assignment. This technique minimizes an optimization goal by iterating over all possible operators assignments over all possible nodes to find the operator assignment that minimizes the desired optimization goal.
摘要翻译：一种用于确定使数据处理系统中的过载最小化的流操作员分配的流操作员分配系统和方法。流操作者分配系统的实施例包括优化目标定义模块，其定义系统管理员和应用程序编写者想要控制的基本量的优化目标，例如最小化所有时间段内的最坏情况延迟，或最小化多少系统用工作积压。流式操作员分配系统的实施例还包括优化和解决所选优化目标的优化目标解决方案模块。使用专门的优化技术来使用优化目标来找到最佳的运算符（或加载）分配，以度量分配值。该技术通过遍历所有可能节点上的所有可能的运算符分配来最小化优化目标，以找到最小化期望的优化目标的运算符分配。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式