Vertex-proximity query processing
    81.
    发明授权
    Vertex-proximity query processing 有权
    顶点邻近查询处理

    公开(公告)号:US08903824B2

    公开(公告)日:2014-12-02

    申请号:US13315415

    申请日:2011-12-09

    IPC分类号: G06F17/30

    CPC分类号: G06F17/30327

    摘要: A method, an apparatus and an article of manufacture for processing a random-walk based vertex-proximity query on a graph. The method includes computing at least one vertex cluster and corresponding meta-information from a graph, dynamically updating the clustering and corresponding meta-information upon modification of the graph, and identifying a vertex cluster relevant to at least one query vertex and aggregating corresponding meta-information of the cluster to process the query.

    摘要翻译: 一种用于在图上处理随机走路的顶点 - 邻近度查询的方法,装置和制品。 该方法包括:从图中计算至少一个顶点簇和对应的元信息,在修改图形时动态地更新聚类和对应的元信息,以及识别与至少一个查询顶点相关的顶点簇, 集群的信息来处理查询。

    STREAM PROCESSING WITH RUNTIME ADAPTATION
    82.
    发明申请
    STREAM PROCESSING WITH RUNTIME ADAPTATION 审中-公开
    具有运行适应性的流程处理

    公开(公告)号:US20140059212A1

    公开(公告)日:2014-02-27

    申请号:US13600294

    申请日:2012-08-31

    IPC分类号: G06F15/173

    摘要: Embodiments of the disclosure include a method for providing stream processing with runtime adaptation includes registering one or more events, wherein each of the events is associated with a stream processing application. The method also includes monitoring, by a processor, for an occurrence of the one or more events associated with the stream processing application, wherein each of the one or more events is associated with one or more runtime metrics. The method further includes receiving an event notification, wherein the event notification includes event identification and an event context and executing an adaptation of the stream processing application.

    摘要翻译: 本公开的实施例包括用于提供具有运行时适应的流处理的方法,包括登记一个或多个事件,其中每个事件与流处理应用相关联。 该方法还包括由处理器监视与流处理应用相关联的一个或多个事件的发生,其中所述一个或多个事件中的每一个与一个或多个运行时度量相关联。 该方法还包括接收事件通知,其中事件通知包括事件识别和事件上下文以及执行流处理应用的适应。

    Data sharing in a stream processing system
    85.
    发明授权
    Data sharing in a stream processing system 有权
    流处理系统中的数据共享

    公开(公告)号:US08560602B2

    公开(公告)日:2013-10-15

    申请号:US13608371

    申请日:2012-09-10

    IPC分类号: G06F15/16

    CPC分类号: G06F9/548 G06F8/35

    摘要: Data sharing is facilitated in stream processing environments, including distributed stream processing environments. A processor of the stream processing environment obtains at least one of usage information for shared data of the stream processing environment, one or more pre-declared characteristics of the shared data, or performance information relating to the stream processing environment. Based on at least one of the usage information, the one or more pre-declared characteristics or the performance information, code is generated for managing the shared data.

    摘要翻译: 在流处理环境中,包括分布式流处理环境,数据共享便利。 流处理环境的处理器获得用于流处理环境的共享数据的使用信息,共享数据的一个或多个预先声明的特性或与流处理环境相关的性能信息中的至少一个。 基于使用信息中的至少一个,生成用于管理共享数据的一个或多个预先声明的特征或性能信息的代码。

    Generating a distributed stream processing application
    86.
    发明授权
    Generating a distributed stream processing application 有权
    生成分布式流处理应用程序

    公开(公告)号:US08407360B2

    公开(公告)日:2013-03-26

    申请号:US13495534

    申请日:2012-06-13

    IPC分类号: G06F15/16

    摘要: Techniques for generating a distributed stream processing application are provided. The techniques include obtaining a declarative description of one or more data stream processing tasks from a graph of operators, wherein the declarative description expresses at least one stream processing task, generating one or more containers that encompass a combination of one or more stream processing operators, and generating one or more execution units from the declarative description of one or more data stream processing tasks, wherein the one or more execution units are deployable across one or more distributed computing nodes, and comprise a distributed data stream processing application binary.

    摘要翻译: 提供了用于生成分布式流处理应用的技术。 这些技术包括从运算符的图形获得一个或多个数据流处理任务的声明性描述,其中所述声明性描述表达至少一个流处理任务,生成包含一个或多个流处理算子的组合的一个或多个容器, 以及从一个或多个数据流处理任务的声明性描述生成一个或多个执行单元,其中所述一个或多个执行单元可跨越一个或多个分布式计算节点部署,并且包括分布式数据流处理应用程序二进制。

    Generating a Distributed Stream Processing Application
    88.
    发明申请
    Generating a Distributed Stream Processing Application 有权
    生成分布式流处理应用程序

    公开(公告)号:US20120259910A1

    公开(公告)日:2012-10-11

    申请号:US13495534

    申请日:2012-06-13

    IPC分类号: G06F15/16 G06F9/45

    摘要: Techniques for generating a distributed stream processing application are provided. The techniques include obtaining a declarative description of one or more data stream processing tasks from a graph of operators, wherein the declarative description expresses at least one stream processing task, generating one or more containers that encompass a combination of one or more stream processing operators, and generating one or more execution units from the declarative description of one or more data stream processing tasks, wherein the one or more execution units are deployable across one or more distributed computing nodes, and comprise a distributed data stream processing application binary.

    摘要翻译: 提供了用于生成分布式流处理应用的技术。 这些技术包括从运算符的图形获得一个或多个数据流处理任务的声明性描述,其中所述声明性描述表达至少一个流处理任务,生成包含一个或多个流处理算子的组合的一个或多个容器, 以及从一个或多个数据流处理任务的声明性描述生成一个或多个执行单元,其中所述一个或多个执行单元可跨越一个或多个分布式计算节点部署,并且包括分布式数据流处理应用程序二进制。

    AMORTIZING COSTS OF SHARED SCANS
    90.
    发明申请
    AMORTIZING COSTS OF SHARED SCANS 失效
    共享扫描成本

    公开(公告)号:US20120174110A1

    公开(公告)日:2012-07-05

    申请号:US12984909

    申请日:2011-01-05

    IPC分类号: G06F9/46

    CPC分类号: G06F9/4843

    摘要: Techniques for scheduling a plurality of jobs sharing input are provided. The techniques include partitioning one or more input datasets into multiple subcomponents, analyzing a plurality of jobs to determine which of the plurality of jobs require scanning of one or more common subcomponents of the one or more input datasets, and scheduling a plurality of jobs that require scanning of one or more common subcomponents of the one or more input datasets, facilitating a single scanning of the one or more common subcomponents to be used as input by each of the plurality of jobs.

    摘要翻译: 提供了用于调度多个作业共享输入的技术。 这些技术包括将一个或多个输入数据集划分成多个子组件,分析多个作业以确定多个作业中的哪个作业需要扫描一个或多个输入数据集的一个或多个公共子组件,以及调度需要 扫描所述一个或多个输入数据集中的一个或多个通用子部件,便于对所述一个或多个公共子部件进行单次扫描以用作多个作业中的每个作业的输入。