Streaming graph computations in a distributed processing system

    公开(公告)号:US09767217B1

    公开(公告)日:2017-09-19

    申请号:US14288456

    申请日:2014-05-28

    Applicant: Google Inc.

    CPC classification number: G06F17/30569 G06F9/5038 G06F17/30312 G06F17/30424

    Abstract: Methods, systems, and apparatus are described for performing streaming graph computations in a distributed processing system. In one aspect, a method includes receiving, during a first superstep, streaming graph input that comprises continuous input of first graph updates for updating the state of an existing graph, the existing graph comprising a plurality of vertices and edges, and each first graph update specifying a vertex and a message; scheduling, during the first superstep, the first graph updates for processing during a second superstep; providing, during the first superstep, the first graph updates as input to a graph computation for the existing graph; determining that the graph computation has completed processing for the first superstep, and in response: initiating the second superstep; and processing, during the second superstep, each first graph update; and providing, during the second superstep, graph output based at least in part on the first graph updates.

    Data Flow Windowing and Triggering
    8.
    发明申请
    Data Flow Windowing and Triggering 审中-公开
    数据流窗口和触发

    公开(公告)号:US20160285711A1

    公开(公告)日:2016-09-29

    申请号:US14931006

    申请日:2015-11-03

    Applicant: Google Inc.

    CPC classification number: G06F7/00 H04L47/00 H04L47/28

    Abstract: A method includes receiving data corresponding one of streaming data or batch data and a content of the received data for computation. The method also includes determining an event time of the data for slicing the data, determining a processing time to output results of the received data, and emitting at least a portion of the results of the received data based on the processing time and the event time.

    Abstract translation: 一种方法包括接收对应于流数据或批数据之一的数据以及用于计算的接收数据的内容。 该方法还包括确定所述数据的事件的时间切片中的数据,确定处理时间所接收到的数据的输出结果,并发射至少基于处理时间所接收到的数据的结果的一部分,并且所述事件的时间 。

Patent Agency Ranking