公开(公告)号：US10311061B2

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

申请号：US14935009

申请日：2015-11-06

Applicant: SAP SE

Inventor： Yuanzhen Ji ,  Zbigniew Jerzak ,  Anisoara Nica ,  Gregor Hackenbroich

IPC: G06F17/30 ,  G06F7/00 ,  G06F16/2455

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.

公开(公告)号：US20170132285A1

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

申请号：US14935009

申请日：2015-11-06

Applicant: SAP SE

Inventor： Yuanzhen Ji ,  Zbigniew Jerzak ,  Anisoara Nica ,  Gregor Hackenbroich

IPC: G06F17/30

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.

公开(公告)号：US10216793B2

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

申请号：US14931005

申请日：2015-11-03

Applicant: SAP SE

Inventor： Yuanzhen Ji ,  Zbigniew Jerzak ,  Anisoara Nica ,  Gregor Hackenbroich

IPC: G06F17/30

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.

公开(公告)号：US20170124151A1

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

申请号：US14931005

申请日：2015-11-03

Applicant: SAP SE

Inventor： Yuanzhen Ji ,  Zbigniew Jerzak ,  Anisoara Nica ,  Gregor Hackenbroich

IPC: G06F17/30

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.