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

1. 发明授权

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.

2. 发明授权

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.
摘要翻译：可以在第一个操作员处接收检查点标记。第一个操作员可以通过将检查点标记发送到第二个操作符来处理检查点标记，并将表示第一个操作符的状态的状态检查点信息发送到检查点编写器。检查点信息可用于对一个或多个操作员的状态进行补水。例如，在系统故障，系统关机等之后，可以在第一运营商的检查点信息输入队列处从读取单元接收检查点信息。可以使用检查点信息对第一操作者的状态进行再水化。当使用检查点信息来补充第一操作者的状态时，可以暂停处理第一操作者的数据输入队列中的信息。具有第一操作者（例如，第二操作者）的系统中的其他操作者可以以与第一操作者相同的方式进行检查点和再水化。

3. 发明申请

US20130166712A1 CLOUD-EDGE TOPOLOGIES 有权
公开(公告)号：US20130166712A1
公开(公告)日：2013-06-27
申请号：US13337291
申请日：2011-12-27
申请人： Badrish Chandramouli , Suman K. Nath , Wenchao Zhou
发明人： Badrish Chandramouli , Suman K. Nath , Wenchao Zhou
IPC分类号： G06F15/173
CPC分类号： H04L67/10 , G06F9/505 , G06F9/5072 , G06F17/30516 , H04L43/045 , H04L43/065 , H04L47/70 , H04L67/24 , H04W4/023
摘要： The description relates to cloud-edge topologies. Some aspects relate to cloud-edge applications and resource usage in various cloud-edge topologies. Another aspect of the present cloud-edge topologies can relate to the specification of cloud-edge applications using a temporal language. A further aspect can involve an architecture that runs data stream management systems (DSMSs) engines on the cloud and cloud-edge computers to run query parts.

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. 发明申请

US20120166417A1 ASYNCHRONOUS TRANSFER OF STATE INFORMATION BETWEEN CONTINUOUS QUERY PLANS 有权
标题翻译：连续查询计划之间的状态信息异步传输
公开(公告)号：US20120166417A1
公开(公告)日：2012-06-28
申请号：US12977107
申请日：2010-12-23
申请人： Badrish Chandramouli , Jonathan David Goldstein , Peter Alfred Zabback , David Eugene Maier , Di Wang
发明人： Badrish Chandramouli , Jonathan David Goldstein , Peter Alfred Zabback , David Eugene Maier , Di Wang
IPC分类号： G06F7/00
CPC分类号： G06F17/30463 , G06F17/30516
摘要： Described herein are technologies pertaining to migrating state information of operators in a first continuous query plan to a second continuous query plan in an asynchronous manner, such that the first continuous query plan need not cease executing during the migrating of the state information. State information pertaining to stateful operators, such as join operators, is migrated from the first continuous query plan to the second continuous query plan by way of a transformation plan. State matching is utilized to generate the transformation plan.
摘要翻译：这里描述的是涉及将第一连续查询计划中的运营商的状态信息以异步方式迁移到第二连续查询计划的技术，使得在迁移状态信息期间第一连续查询计划不需要停止执行。通过转换方案，将有状态运算符（例如加入运算符）的状态信息从第一个连续查询计划迁移到第二个连续查询计划。利用状态匹配来生成转换计划。

6. 发明申请

US20110313844A1 REAL-TIME-READY BEHAVIORAL TARGETING IN A LARGE-SCALE ADVERTISEMENT SYSTEM 有权
标题翻译：大规模广告系统中的实时行为指标
公开(公告)号：US20110313844A1
公开(公告)日：2011-12-22
申请号：US12818100
申请日：2010-06-17
申请人： Badrish Chandramouli , Jonathan Goldstein , Xin Jin , Balan Sethu Raman , Songyun Duan
发明人： Badrish Chandramouli , Jonathan Goldstein , Xin Jin , Balan Sethu Raman , Songyun Duan
IPC分类号： G06Q30/00 , G06F17/30
CPC分类号： G06Q30/0241 , G06F17/30516 , G06F17/30551 , G06Q30/0242 , G06Q30/0243
摘要： A “Real-Time-Ready Analyzer” combines a data stream management system (DSMS) with a map-reduce (M-R) framework to construct a streaming map-reduce framework that is suitable for real-time Behavioral Targeting (BT) (or other temporal queries). The Real-Time-Ready Analyzer allows users to write “dual-intent” temporal analysis queries for BT. These queries are succinct and easy to express, scale well on large-scale offline data, and can also work over real-time data. Further, the Real-Time-Ready Analyzer uses the aforementioned streaming map-reduce framework to provide dual-intent algorithms for end-to-end BT phases. Experiments using real data from an advertisement system show that the Real-Time-Ready Analyzer is very efficient and incurs orders-of-magnitude lower development effort than conventional systems.
摘要翻译： “实时就绪分析器”将数据流管理系统（DSMS）与地图缩减（MR）框架相结合，构建适用于实时行为定位（BT）（或其他）的流映射缩减框架时间查询）。实时就绪分析器允许用户为BT写入“双重意图”时间分析查询。这些查询简洁易懂，在大型离线数据上可以很好地扩展，也可以处理实时数据。此外，实时就绪分析器使用上述流映射缩减框架来提供端到端BT阶段的双重意图算法。使用广告系统的实际数据的实验表明，实时就绪分析器非常有效，并且比传统系统产生了比数字级更低的开发工作。

7. 发明授权

US08478743B2 Asynchronous transfer of state information between continuous query plans 有权
标题翻译：连续查询计划之间的异步传输状态信息
公开(公告)号：US08478743B2
公开(公告)日：2013-07-02
申请号：US12977107
申请日：2010-12-23
申请人： Badrish Chandramouli , Jonathan David Goldstein , Peter Alfred Zabback , David Eugene Maier , Di Wang
发明人： Badrish Chandramouli , Jonathan David Goldstein , Peter Alfred Zabback , David Eugene Maier , Di Wang
IPC分类号： G06F7/00 , G06F17/30
CPC分类号： G06F17/30463 , G06F17/30516
摘要： Described herein are technologies pertaining to migrating state information of operators in a first continuous query plan to a second continuous query plan in an asynchronous manner, such that the first continuous query plan need not cease executing during the migrating of the state information. State information pertaining to stateful operators, such as join operators, is migrated from the first continuous query plan to the second continuous query plan by way of a transformation plan. State matching is utilized to generate the transformation plan.
摘要翻译：这里描述的是涉及将第一连续查询计划中的运营商的状态信息以异步方式迁移到第二连续查询计划的技术，使得在迁移状态信息期间第一连续查询计划不需要停止执行。通过转换方案，将有状态运算符（例如加入运算符）的状态信息从第一个连续查询计划迁移到第二个连续查询计划。利用状态匹配来生成转换计划。

8. 发明申请

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.
摘要翻译：本文描述的主题的方面涉及流操作员。在方面，接收流事件。基于与流事件相关联的时间戳和要求在时间戳之前或时间戳处被激活的流运算符的数量，零或多个流对象被通知一个或多个时间事件，并且如果不再需要则被拆除。另外，如果需要，将目的地流运算符进行实例化，将与流事件相对应的数据（例如，时间戳和分组，如果有的话）提供给流运算符，则从流运算符接收输出数据（如果有的话）如果流操作员不再需要调用之间的状态数据，则该流操作符将被拆除。

9. 发明申请

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

10. 发明授权

US08442863B2 Real-time-ready behavioral targeting in a large-scale advertisement system 有权
标题翻译：在大规模广告系统中实时就绪的行为定位
公开(公告)号：US08442863B2
公开(公告)日：2013-05-14
申请号：US12818100
申请日：2010-06-17
申请人： Badrish Chandramouli , Jonathan Goldstein , Xin Jin , Balan Sethu Raman , Songyun Duan
发明人： Badrish Chandramouli , Jonathan Goldstein , Xin Jin , Balan Sethu Raman , Songyun Duan
IPC分类号： G06Q30/00
CPC分类号： G06Q30/0241 , G06F17/30516 , G06F17/30551 , G06Q30/0242 , G06Q30/0243
摘要： A “Real-Time-Ready Analyzer” combines a data stream management system (DSMS) with a map-reduce (M-R) framework to construct a streaming map-reduce framework that is suitable for real-time Behavioral Targeting (BT) (or other temporal queries). The Real-Time-Ready Analyzer allows users to write “dual-intent” temporal analysis queries for BT. These queries are succinct and easy to express, scale well on large-scale offline data, and can also work over real-time data. Further, the Real-Time-Ready Analyzer uses the aforementioned streaming map-reduce framework to provide dual-intent algorithms for end-to-end BT phases. Experiments using real data from an advertisement system show that the Real-Time-Ready Analyzer is very efficient and incurs orders-of-magnitude lower development effort than conventional systems.
摘要翻译： “实时就绪分析器”将数据流管理系统（DSMS）与地图缩减（MR）框架相结合，构建适用于实时行为定位（BT）（或其他）的流映射缩小框架时间查询）。实时就绪分析器允许用户为BT写入“双重意图”时间分析查询。这些查询简洁易懂，在大型离线数据上可以很好地扩展，也可以处理实时数据。此外，实时就绪分析器使用上述流映射缩减框架来提供端到端BT阶段的双重意图算法。使用广告系统的实际数据的实验表明，实时就绪分析器非常有效，并且比传统系统产生了比数字级更低的开发工作。

你已经成功收藏专利！

检索式保存成功!

IPRDB

热门服务

关于我们

友情链接

联系方式