MUTABLE CHRONOLOGIES FOR ACCOMMODATION OF RANDOMLY OCCURRING EVENT DELAYS
    71.
    发明申请
    MUTABLE CHRONOLOGIES FOR ACCOMMODATION OF RANDOMLY OCCURRING EVENT DELAYS 审中-公开
    可追溯性的随机事件延迟事件

    公开(公告)号:US20160026502A1

    公开(公告)日:2016-01-28

    申请号:US14808243

    申请日:2015-07-24

    CPC classification number: G06F9/5038 G06F9/542 G06F2209/546

    Abstract: Causing a computing system to process events from a sequence of events that defines a correct order for said events independent from an order in which those events are received includes: defining a first variable, defining, for the first variable, a chronology of operations on the first variable associated with received events, receiving a first event that pertains to the first variable, executing a first operation on said first variable that results in a first update of the chronology, receiving a delayed event that pertains to the first variable, executing a second operation on said first variable that results in a second update of the chronology, and determining whether the first update is valid or invalid, wherein the delayed event precedes the first event in the sequence, the first update is based on the first event, and the second update is based on the delayed event.

    Abstract translation: 使计算系统处理事件序列中的事件,该事件序列定义了与所接收事件无关的顺序的正确顺序,包括:定义第一个变量,为第一个变量定义一个操作的时间顺序 与所接收的事件相关联的第一变量,接收与所述第一变量相关的第一事件,对所述第一变量执行导致所述年表的第一更新的第一操作,接收与所述第一变量相关的延迟事件,执行第二变量 对所述第一变量进行操作,其导致所述年表的第二更新,以及确定所述第一更新是有效还是无效,其中所述延迟事件在所述序列中的所述第一事件之前,所述第一更新基于所述第一事件, 第二次更新是基于延迟事件。

    MAPPING ATTRIBUTES OF KEYED ENTITIES
    72.
    发明申请
    MAPPING ATTRIBUTES OF KEYED ENTITIES 审中-公开
    关键实体的映射属性

    公开(公告)号:US20150261882A1

    公开(公告)日:2015-09-17

    申请号:US14658357

    申请日:2015-03-16

    Abstract: One or more mappings each define a correspondence between one or more input attributes of an input entity and one or more output attributes of an output entity, where the input entity includes one or more key attributes identified as part of a unique key, and the output entity includes one or more key attributes identified as part of a unique key. Generating instances of the output entity includes: determining one or more mapped input attributes of the input entity that correspond to each of the key attributes of the output entity, based on the mappings; and comparing the mapped input attributes with the key attributes of the input entity to determine whether the mapped input attributes include: (1) all of the key attributes of the input entity, or (2) fewer than all of the key attributes of the input entity.

    Abstract translation: 一个或多个映射各自定义输入实体的一个或多个输入属性与输出实体的一个或多个输出属性之间的对应关系,其中输入实体包括被识别为唯一密钥的一部分的一个或多个密钥属性,并且输出 实体包括被识别为唯一密钥的一部分的一个或多个关键属性。 生成输出实体的实例包括:基于映射确定与输出实体的每个关键属性对应的输入实体的一个或多个映射输入属性; 并将映射的输入属性与输入实体的关键属性进行比较,以确定映射的输入属性是否包括:(1)输入实体的所有关键属性,或者(2)少于输入的所有关键属性 实体。

    DYNAMICALLY LOADING GRAPH-BASED COMPUTATIONS
    73.
    发明申请
    DYNAMICALLY LOADING GRAPH-BASED COMPUTATIONS 有权
    动态加载图形计算

    公开(公告)号:US20150106818A1

    公开(公告)日:2015-04-16

    申请号:US14520588

    申请日:2014-10-22

    CPC classification number: G06F9/44521 G06F9/44536 G06F9/4494

    Abstract: Processing data includes: receiving units of work that each include one or more work elements, and processing a first unit of work using a first compiled dataflow graph (160) loaded into a data processing system (100) in response to receiving the first unit of work. The processing includes: analysis to determine a characteristic of the first unit of work; identifying one or more compiled dataflow graphs from graphs stored in a data storage system (107) that include at least some that were compiled for processing a unit of work having the determined characteristic; loading one of the identified compiled dataflow graphs into the data processing system (100) as the first compiled dataflow graph (160); and generating one or more output work elements from at least one work element in the first unit of work.

    Abstract translation: 处理数据包括:接收每个工作单元包括一个或多个工作单元,以及响应于接收到第一单元的第一单元来处理加载到数据处理系统(100)中的第一编译数据流图(160)来处理第一工作单元 工作。 处理包括:分析确定第一工作单元的特征; 从存储在数据存储系统(107)中的图形中识别一个或多个编译数据流图,所述图形包括至少一些被编译用于处理具有所确定的特征的工作单元的编译数据流图; 将所识别的编译数据流图中的一个加载到数据处理系统(100)中作为第一编译数据流图(160); 以及从所述第一工作单元中的至少一个工作元件生成一个或多个输出工作元件。

    Managing buffer conditions through sorting
    74.
    发明授权
    Managing buffer conditions through sorting 有权
    通过排序管理缓冲区条件

    公开(公告)号:US08762604B2

    公开(公告)日:2014-06-24

    申请号:US13799249

    申请日:2013-03-13

    CPC classification number: G06F12/02 G06F9/544

    Abstract: Systems and techniques include, in some implementations, a computer implemented method storing a portion of data elements present in a first buffer in a second buffer in response to detecting an overflow condition of the first buffer, wherein the data elements in the first buffer are sorted according to a predetermined order, and inserting a proxy data element in the first buffer to represent the portion of data elements stored to the second buffer.

    Abstract translation: 在一些实施方式中,系统和技术包括响应于检测到第一缓冲器的溢出状况而存储存在于第二缓冲器中的第一缓冲器中的数据元素的一部分的计算机实现的方法,其中第一缓冲器中的数据元素被排序 并且将代理数据元素插入到第一缓冲器中以表示存储到第二缓冲器的数据元素的部分。

    Executable logic for processing keyed data in networks

    公开(公告)号:US11295049B2

    公开(公告)日:2022-04-05

    申请号:US16780657

    申请日:2020-02-03

    Abstract: A method implemented by a data processing system for processing data items of a stream of data items, including: accessing a specification that represents the executable logic, wherein a state of the specification for a particular value of the key specifies one or more portions of the executable logic that are executable in that state; receiving, over an input device or port, data items of a stream of data; for a first one of the data items of the stream, identifying a first state of the specification for a value of the key associated with that first one of the data items; processing, by the data processing system, the first one of the data items according to one or more portions of executable logic that are represented in the specification as being associated with the first state.

    Optimizing Communication in Distributed Computing Network

    公开(公告)号:US20210367861A1

    公开(公告)日:2021-11-25

    申请号:US17323389

    申请日:2021-05-18

    Abstract: A computing system includes a distributed computing cluster including a plurality of computing nodes interconnected by an interconnect network over which the computing nodes of the plurality of computing nodes communicate with each other by passing messages. The computing nodes are configured with a first parameter governing transmissions of messages by the computing nodes over the interconnect network. The computing nodes are configured to accumulate messages for transmission as a group of messages according to the first parameter, and the computing system is configured to limit injections of computing requests into the distributed computing cluster according to a second parameter. A controller is configured to receive at least one predetermined service level requirement and to control a value of the second parameter and a value of the first parameter to control a computational throughput of the distributed computing cluster while complying with the at least one service level requirement.

    Controlling data processing tasks
    77.
    发明授权

    公开(公告)号:US10599475B2

    公开(公告)日:2020-03-24

    申请号:US16117486

    申请日:2018-08-30

    Abstract: Information representative of a graph-based program specification has a plurality of components, each of which corresponds to a task, and directed links between ports of said components. A program corresponding to said graph-based program specification is executed. A first component includes a first data port, a first control port, and a second control port. Said first data port is configured to receive data to be processed by a first task corresponding to said first component, or configured to provide data that was processed by said first task corresponding to said first component. Executing a program corresponding to said graph-based program specification includes: receiving said first control information at said first control port, in response to receiving said first control information, determining whether or not to invoke said first task, and after receiving said first control information, providing said second control information from said second control port.

    MAPPING ATTRIBUTES OF KEYED ENTITIES
    78.
    发明申请

    公开(公告)号:US20190391934A1

    公开(公告)日:2019-12-26

    申请号:US16258749

    申请日:2019-01-28

    Abstract: One or more mappings each define a correspondence between one or more input attributes of an input entity and one or more output attributes of an output entity, where the input entity includes one or more key attributes identified as part of a unique key, and the output entity includes one or more key attributes identified as part of a unique key. Generating instances of the output entity includes: determining one or more mapped input attributes of the input entity that correspond to each of the key attributes of the output entity, based on the mappings; and comparing the mapped input attributes with the key attributes of the input entity to determine whether the mapped input attributes include: (1) all of the key attributes of the input entity, or (2) fewer than all of the key attributes of the input entity.

    Managing computations for hierarchical entities

    公开(公告)号:US10360186B2

    公开(公告)日:2019-07-23

    申请号:US14844131

    申请日:2015-09-03

    Abstract: Entity data represent entities related according to a hierarchy, with at least one root entity at a highest level and one or more entities at one or more levels below the highest level. One or more entities each have multiple instances, and at least one attribute having respective elements for each of the instances. Input data includes expressions that express functions of arguments, with one or more of the arguments referencing an attribute of an entity represented in the entity data. Processing expressions includes: (a) analyzing an expression to determine, for each of one or more attributes, at least one of: (1) a position in the hierarchy of an entity of the attribute, or (2) a number of elements of a result of a function applied to an argument that references the attribute, and (b) evaluating the expression, or indicating an error based on a result of analyzing the expression.

    Specifying control and data connections in graph-based programs

    公开(公告)号:US10338782B2

    公开(公告)日:2019-07-02

    申请号:US15942757

    申请日:2018-04-02

    Abstract: A first component of a graph-based program specification includes an output control port. A second component includes an input control port and an input data port. A third component includes an output data port. The output control port is connected to the input control port, and the output data port is connected to the input data port. The first component includes control code that when executed causes the output control port to provide, to the input control port, at least one of suppression information or invocation information. The second component includes control code that when executed causes a computing system configured by the graph-based program specification to begin processing data received at the input data port in response to the invocation information if no suppression information is received at the input control port before the invocation information is received at the input control port.

Patent Agency Ranking