Quality-driven processing of out-of-order data streams

    公开(公告)号:US10311061B2

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

    申请号:US14935009

    申请日:2015-11-06

    Applicant: SAP SE

    Abstract: The present disclosure involves systems, software, and computer implemented methods for providing quality-driven processing of out-of-order data streams based on a configurable quality metric. In one example, the method includes identifying a configurable quality metric defined by a user or application for executing continuous queries over a sliding window, the metric specifying a user requirement for the quality of the continuous query result. A quality threshold metric is calculated based on the configurable quality metric, the configurable quality metric associated with a size of an adaptation buffer for incoming tuples of the query. In response to receiving a signal indicating a new query result, a sliding window prior to a current time is identified. A runtime quality metric associated with the incoming tuples for the sliding window is measured, and the adaptation buffer is modified based on a difference between the quality threshold metric and the measured runtime quality metric.

    QUALITY-DRIVEN PROCESSING OF OUT-OF-ORDER DATA STREAMS

    公开(公告)号:US20170132285A1

    公开(公告)日:2017-05-11

    申请号:US14935009

    申请日:2015-11-06

    Applicant: SAP SE

    CPC classification number: G06F17/30516

    Abstract: The present disclosure involves systems, software, and computer implemented methods for providing quality-driven processing of out-of-order data streams based on a configurable quality metric. In one example, the method includes identifying a configurable quality metric defined by a user or application for executing continuous queries over a sliding window, the metric specifying a user requirement for the quality of the continuous query result. A quality threshold metric is calculated based on the configurable quality metric, the configurable quality metric associated with a size of an adaptation buffer for incoming tuples of the query. In response to receiving a signal indicating a new query result, a sliding window prior to a current time is identified. A runtime quality metric associated with the incoming tuples for the sliding window is measured, and the adaptation buffer is modified based on a difference between the quality threshold metric and the measured runtime quality metric.

    Optimization of continuous queries in hybrid database and stream processing systems

    公开(公告)号:US10216793B2

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

    申请号:US14931005

    申请日:2015-11-03

    Applicant: SAP SE

    Abstract: The present disclosure involves systems, software, and computer implemented methods for optimizing continuous queries for hybrid execution over a stream processing engine and an in-memory database. In one example, a method may include identifying a continuous query executed at a stream processing engine, the continuous query including a plurality of operators. An optimal plan for execution of the identified continuous query at the stream processing engine is determined. For each of the plurality of operators in the determined optimal plan, an optimized placement decision for executing a particular operator in the stream processing engine or at a database system is determined. An optimized continuous query is generated from the identified continuous query based on the determined optimal placement decisions for each of the plurality of operators in the determined optimal plan. The optimized continuous query is then executed at the stream processing engine and the database system.

    OPTIMIZATION OF CONTINUOUS QUERIES IN HYBRID DATABASE AND STREAM PROCESSING SYSTEMS

    公开(公告)号:US20170124151A1

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

    申请号:US14931005

    申请日:2015-11-03

    Applicant: SAP SE

    CPC classification number: G06F17/30463 G06F17/30516

    Abstract: The present disclosure involves systems, software, and computer implemented methods for optimizing continuous queries for hybrid execution over a stream processing engine and an in-memory database. In one example, a method may include identifying a continuous query executed at a stream processing engine, the continuous query including a plurality of operators. An optimal plan for execution of the identified continuous query at the stream processing engine is determined. For each of the plurality of operators in the determined optimal plan, an optimized placement decision for executing a particular operator in the stream processing engine or at a database system is determined. An optimized continuous query is generated from the identified continuous query based on the determined optimal placement decisions for each of the plurality of operators in the determined optimal plan. The optimized continuous query is then executed at the stream processing engine and the database system.

Patent Agency Ranking