利索-全球专利检索

  1. 登录
  2. 注册

搜索结果

66 条记录 (耗时 0.025 秒)

    Processing of streaming data with a keyed delay
    1.
    发明授权
    Processing of streaming data with a keyed delay 有权
    用键控延迟处理流数据

    公开(公告)号：US08321865B2

    公开(公告)日：2012-11-27

    申请号：US12541435

    申请日：2009-08-14

    申请人： Lisa Amini ,  Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    发明人： Lisa Amini ,  Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    IPC分类号： G06F9/46 ,  G06F15/167 ,  G06F7/00 ,  G06F11/00

    CPC分类号： G06F9/542

    摘要： A keyed delay is used in the processing of streaming data to decrease the processing performed and the output provided. A first event, within a particular window, having a particular key starts a delay condition. Arriving events with the same key replace the previous arrival for that key until the delay condition is satisfied. In response thereto, the latest event with that key is output.

    摘要翻译： 在流数据的处理中使用密钥延迟来减少所执行的处理和提供的输出。 具有特定键的特定窗口内的第一个事件将启动延迟条件。 使用相同密钥到达事件将替换该密钥的先前到达，直到延迟条件得到满足为止。 响应于此，输出具有该键的最新事件。

    PROCESSING OF STREAMING DATA WITH A KEYED DELAY
    2.
    发明申请
    PROCESSING OF STREAMING DATA WITH A KEYED DELAY 有权
    用键盘延迟处理数据流

    公开(公告)号：US20110041133A1

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

    申请号：US12541435

    申请日：2009-08-14

    申请人： Lisa Amini ,  Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    发明人： Lisa Amini ,  Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    IPC分类号： G06F9/46

    CPC分类号： G06F9/542

    摘要： A keyed delay is used in the processing of streaming data to decrease the processing performed and the output provided. A first event, within a particular window, having a particular key starts a delay condition. Arriving events with the same key replace the previous arrival for that key until the delay condition is satisfied. In response thereto, the latest event with that key is output.

    摘要翻译： 在流数据的处理中使用密钥延迟来减少所执行的处理和提供的输出。 具有特定键的特定窗口内的第一个事件将启动延迟条件。 使用相同密钥到达事件将替换该密钥的先前到达，直到延迟条件得到满足为止。 响应于此，输出具有该键的最新事件。

    Dynamically composing data stream processing applications
    3.
    发明授权
    Dynamically composing data stream processing applications 有权
    动态组合数据流处理应用程序

    公开(公告)号：US08286191B2

    公开(公告)日：2012-10-09

    申请号：US12465910

    申请日：2009-05-14

    申请人： Lisa Amini ,  Henrique Andrade ,  Bugra Gedik ,  Nagui Halim ,  Srinivasan Parthasarathy

    发明人： Lisa Amini ,  Henrique Andrade ,  Bugra Gedik ,  Nagui Halim ,  Srinivasan Parthasarathy

    IPC分类号： G06F13/00

    CPC分类号： G06F9/544

    摘要： Techniques for dynamically modifying inter-connections between components in an application are provided. The techniques include receiving a data producer profile for each output port within a software application to be executed on one or more processors, receiving a data subscription profile for each input port of each component of the application, establishing connections between the output ports and the input ports of the components in the application based on a comparison of each data producer profile and each data subscription profile, executing the application on one or more processors to process streams of data, receiving either or both of a new data producer profile or a new data subscription profile during the execution of the application, and establishing at least one new connection between an output port and an input port based upon a revised comparison of the received data profiles that include the new data profile.

    摘要翻译： 提供了用于动态修改应用程序中组件之间的连接的技术。 这些技术包括：接收用于在一个或多个处理器上执行的软件应用中的每个输出端口的数据生成器简档，为应用的每个组件的每个输入端口接收数据订阅简档，在输出端口和输入端之间建立连接 基于每个数据生成器简档和每个数据订阅简档的比较来应用中的组件的端口，在一个或多个处理器上执行应用程序来处理数据流，接收新的数据生成器简档或新数据中的一个或两个 在执行应用期间的订阅简档，以及基于对包括新数据简档的所接收的数据简档进行修改的比较，在输出端口和输入端口之间建立至少一个新的连接。

    PROCESSING OF STREAMING DATA WITH A KEYED JOIN
    4.
    发明申请
    PROCESSING OF STREAMING DATA WITH A KEYED JOIN 审中-公开
    用密钥加密处理数据流

    公开(公告)号：US20110040887A1

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

    申请号：US12541465

    申请日：2009-08-14

    申请人： Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    发明人： Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    IPC分类号： G06F15/16

    CPC分类号： H04L65/4076 ,  H04L65/80

    摘要： A keyed join is used in the processing of streaming data to streamline processing to provide higher throughput and decreased use of resources. The most recent event for each unique replacement key value(s) is maintained substituting older events with the same key. An incoming event is joined with the data received from one or more other data sources, and the correlations are output.

    摘要翻译： 密钥加入用于处理流数据以简化处理，以提供更高的吞吐量和减少资源的使用。 维持每个唯一替换键值的最近事件替换具有相同键的旧事件。 传入事件与从一个或多个其他数据源接收的数据相结合，并输出相关性。

    Processing of streaming data with keyed aggregation
    6.
    发明授权
    Processing of streaming data with keyed aggregation 有权
    使用密钥聚合处理流数据

    公开(公告)号：US08868518B2

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

    申请号：US12541481

    申请日：2009-08-14

    申请人： Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    发明人： Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    IPC分类号： G06F17/30

    CPC分类号： G06F17/30516

    摘要： Keyed aggregation is used in the processing of streaming data to streamline processing to provide higher throughput and decreased use of resources. The most recent event for each unique replacement key value(s) is maintained. In response to an incoming event having a same key as a previous event, the effect on an aggregation of the previous event is removed. The aggregation is then updated with one or more values from the arriving event and the updated aggregation is output.

    摘要翻译： 密钥聚合用于处理流数据以简化处理，以提供更高的吞吐量和更少的资源使用。 维护每个唯一替换键值的最近事件。 响应于与先前事件具有相同键的传入事件，去除对先前事件的聚合的影响。 然后使用一个或多个值从到达事件更新聚合，并输出更新的聚合。

    PROCESSING OF STREAMING DATA WITH KEYED AGGREGATION
    7.
    发明申请
    PROCESSING OF STREAMING DATA WITH KEYED AGGREGATION 有权
    用键盘聚合处理数据流

    公开(公告)号：US20110040734A1

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

    申请号：US12541481

    申请日：2009-08-14

    申请人： Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    发明人： Henrique Andrade ,  Mitchell A. Cohen ,  Bugra Gedik

    IPC分类号： G06F17/30 ,  G06F15/16

    CPC分类号： G06F17/30516

    摘要： Keyed aggregation is used in the processing of streaming data to streamline processing to provide higher throughput and decreased use of resources. The most recent event for each unique replacement key value(s) is maintained. In response to an incoming event having a same key as a previous event, the effect on an aggregation of the previous event is removed. The aggregation is then updated with one or more values from the arriving event and the updated aggregation is output.

    摘要翻译： 密钥聚合用于处理流数据以简化处理，以提供更高的吞吐量和更少的资源使用。 维护每个唯一替换键值的最近事件。 响应于与先前事件具有相同键的传入事件，去除对先前事件的聚合的影响。 然后使用一个或多个值从到达事件更新聚合，并输出更新的聚合。

    Tracing Flow of Data in a Distributed Computing Application
    9.
    发明申请
    Tracing Flow of Data in a Distributed Computing Application 失效
    在分布式计算应用程序中跟踪数据流

    公开(公告)号：US20110289301A1

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

    申请号：US12785916

    申请日：2010-05-24

    申请人： Paul V. Allen ,  Henrique Andrade ,  Wim De Pauw ,  Bugra Gedik ,  Andy L. Frenkiel ,  Michael Donald Pfeifer

    发明人： Paul V. Allen ,  Henrique Andrade ,  Wim De Pauw ,  Bugra Gedik ,  Andy L. Frenkiel ,  Michael Donald Pfeifer

    IPC分类号： G06F9/30

    CPC分类号： G06F11/3636

    摘要： A method is provided for tracing dataflow in a distributed computing application. For example, the method includes incrementally advancing a dataflow in a dataflow path of one or more dataflow paths according to two or more directives encoded in two or more data messages. The method further includes performing the two or more directives. The dataflow path includes one or more operators including at least one merge operator operative to merge the two or more data messages and merge the two or more directives. One or more of the incrementally advancing of the dataflow and the performing of the two or more directives are implemented as instruction code performed on a processor device.

    摘要翻译： 提供了一种用于在分布式计算应用程序中跟踪数据流的方法。 例如，该方法包括根据在两个或多个数据消息中编码的两个或更多个指令，逐渐前进一个或多个数据流路径的数据流路径中的数据流。 该方法还包括执行两个或更多个指令。 数据流路径包括一个或多个运算符，包括至少一个合并运算符，用于合并两个或多个数据消息并合并两个或多个指令。 数据流的递增推进和两个或多个指令的执行中的一个或多个被实现为在处理器设备上执行的指令代码。

    METHOD OF SELECTING AN EXPRESSION EVALUATION TECHNIQUE FOR DOMAIN-SPECIFIC LANGUAGE COMPILATION
    10.
    发明申请
    METHOD OF SELECTING AN EXPRESSION EVALUATION TECHNIQUE FOR DOMAIN-SPECIFIC LANGUAGE COMPILATION 失效
    选择特定语言编译的表达评估技术的方法

    公开(公告)号：US20110246972A1

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

    申请号：US12749947

    申请日：2010-03-30

    申请人： Henrique Andrade ,  Bugra Gedik ,  Mark Mendell ,  Howard W. Nasgaard ,  Kun-Lung Wu

    发明人： Henrique Andrade ,  Bugra Gedik ,  Mark Mendell ,  Howard W. Nasgaard ,  Kun-Lung Wu

    IPC分类号： G06F9/45

    CPC分类号： G06F9/45516 ,  G06F8/51

    摘要： A method and computer program product for selecting an expression evaluation technique for domain-specific language (DSL) compilation. An application written in DSL for a programming task is provided, the application including a plurality of components configured by expressions. A technique that most quickly implements the programming task is selected from a plurality of techniques for evaluating the expressions. The DSL application is compiled in accordance with the selected expression evaluation technique to generate general-purpose programming language (GPL) code.

    摘要翻译： 一种用于选择域特定语言（DSL）编译的表达评估技术的方法和计算机程序产品。 提供了一种用DSL编写的用于编程任务的应用程序，该应用程序包括由表达式配置的多个组件。 从用于评估表达式的多种技术中选择最快速地实现编程任务的技术。 DSL应用程序根据所选择的表达式评估技术进行编译，以生成通用编程语言（GPL）代码。