Automated streaming data model generation

    公开(公告)号:US10346142B1

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

    申请号:US16217169

    申请日:2018-12-12

    Abstract: A computing device automatically generates an event stream processing (ESP) model to receive and process events. A mapping dataset is created from configuration and device information that includes a measurement processing description for a measurement and a measurement identifier that uniquely identifies a sensor and a device to which the sensor is associated and describe a computational process to be performed by an ESP window. An update macro is executed with an update template to create update code to parse the measurement identifier and a measurement value from the event block object. A transpose macro is executed with a transpose template to create transpose code to perform the described computational process. An ESP model is created that includes the created update code, a source window defined to execute the created update code, the created transpose code, and a transpose window defined to execute the created transpose code.

    Automated streaming data model generation with parallel processing capability

    公开(公告)号:US11550643B1

    公开(公告)日:2023-01-10

    申请号:US17879893

    申请日:2022-08-03

    Abstract: An event stream processing (ESP) model is read that describes computational processes. (A) An event block object is received. (B) A new measurement value, a timestamp value, and a sensor identifier are extracted. (C) An in-memory data store is updated with the new measurement value, the timestamp value, and the sensor identifier. (A) through (C) are repeated until an output update time is reached. When the output update time is reached, data stored in the in-memory data store is processed and updated using data enrichment windows to define enriched data values that are output. The data enrichment windows include a gate window before each window that uses values computed by more than one window. The gate window sends a trigger to a next window when each value of the more than one window has been computed. The enrichment windows are included in the ESP model.

    AUTOMATED STREAMING DATA MODEL GENERATION
    4.
    发明申请

    公开(公告)号:US20190196795A1

    公开(公告)日:2019-06-27

    申请号:US16217169

    申请日:2018-12-12

    CPC classification number: G06F8/35 G06F8/20

    Abstract: A computing device automatically generates an event stream processing (ESP) model to receive and process events. A mapping dataset is created from configuration and device information that includes a measurement processing description for a measurement and a measurement identifier that uniquely identifies a sensor and a device to which the sensor is associated and describe a computational process to be performed by an ESP window. An update macro is executed with an update template to create update code to parse the measurement identifier and a measurement value from the event block object. A transpose macro is executed with a transpose template to create transpose code to perform the described computational process. An ESP model is created that includes the created update code, a source window defined to execute the created update code, the created transpose code, and a transpose window defined to execute the created transpose code.

Patent Agency Ranking