公开(公告)号：US10657127B2

公开(公告)日：2020-05-19

申请号：US15362586

申请日：2016-11-28

Applicant: SAP SE

Inventor： Kornel Skalkowski ,  Youssef Hatem ,  Stephan Kessler ,  Christian Mathis

IPC: G06F16/2453 ,  G06F16/22 ,  G06F16/2455

Abstract: In one respect, there is provided a distributed database system that includes hosts configured to store and/or manage data, a first query processing engine comprising a master node and an executor node, and a second query processing engine. The master node can be implemented on programmable processors and configured to perform operations. The operations can include: offloading, to the second query processing engine, a creation of a first and a second table such that the first and the second table are partitioned by the second query processing engine; generating an execution plan for a query on data in the distributed database system, the execution plan including a distributed join operation that combines data from the first and second table; determining to push down, to the second query processing engine, the distributed join operation; and dispatching, to the executor node, a portion of the execution plan including the distributed join operation.

公开(公告)号：US20180089267A1

公开(公告)日：2018-03-29

申请号：US15275040

申请日：2016-09-23

Applicant: SAP SE

Inventor： Youssef Hatem ,  Stephan Kessler ,  Axel Christ ,  Christian Mathis

IPC: G06F17/30

CPC classification number: G06F16/24542 ,  G06F16/2455 ,  G06F16/2471 ,  G06F16/9535

Abstract: In one respect, there is provided a distributed database system. The distributed database system can include a plurality of hosts configured to store and/or manage data, a first query processing engine comprising a master node and an executor node, and a second query processing engine. The master node can be implemented on one or more programmable processors and configured to perform operations. The operations can include: generating an execution plan for a query on data that is stored at and/or managed by one or more of the plurality of hosts; determining to push down, to the second query processing engine, at least one data processing operations in the execution plan; and dispatching, to the executor node, at least a portion of the execution plan, the portion of the execution plan including the at least one data processing operation that is pushed down to the second query processing engine.

公开(公告)号：US20160292246A1

公开(公告)日：2016-10-06

申请号：US15185182

申请日：2016-06-17

Applicant: SAP SE

Inventor： Christian Mathis ,  Daniel Ritter

IPC: G06F17/30

CPC classification number: G06F17/30569 ,  G06F17/30345 ,  G06F17/30474 ,  G06F17/3056 ,  G06F17/30595

Abstract: The present disclosure describes methods, systems, and computer program products for providing application integration functionality directly on a relational database according to an implementation. One computer-implemented method includes inserting relational data into a start table of a database, detecting a change in the start table, retrieving the inserted relational data from the start table, processing, using a computer, the relational data using a database integration flow runtime into result data, inserting the result data into an end table of the database, detecting a change in the end table, and retrieving the result data from the end table.

Abstract translation: 本公开描述了用于根据实现直接在关系数据库上提供应用集成功能的方法，系统和计算机程序产品。 一种计算机实现的方法包括将关系数据插入到数据库的起始表中，检测起始表的变化，从起始表检索插入的关系数据，使用计算机处理使用数据库集成流运行时的关系数据 将结果数据插入到数据库的结束表中，检测结束表中的变化，并从结束表中检索结果数据。

公开(公告)号：US09177025B2

公开(公告)日：2015-11-03

申请号：US13742034

申请日：2013-01-15

Applicant: SAP SE

Inventor： Christian Bensberg ,  Christian Mathis ,  Frederik Transier ,  Nico Bohnsack ,  Kai Stammerjohann

IPC: G06F7/00 ,  G06F17/30

CPC classification number: G06F17/30466 ,  G06F17/3033 ,  G06F17/30445

Abstract: According to some embodiments, a system and method for a parallel join of relational data tables may be provided by calculating, by a plurality of concurrently executing execution threads, hash values for join columns of a first input table and a second input table; storing the calculated hash values in a set of disjoint thread-local hash maps for each of the first input table and the second input table; merging the set of thread-local hash maps of the first input table, by a second plurality of execution threads operating concurrently, to produce a set of merged hash maps; comparing each entry of the merged hash maps to each entry of the set of thread-local hash maps for the second input table to determine whether there is a match, according to a join type; and generating an output table including matches as determined by the comparing.

Abstract translation: 根据一些实施例，可以通过由多个并发执行执行线程计算第一输入表和第二输入表的连接列的散列值来提供用于关系数据表的并行连接的系统和方法; 将所计算的散列值存储在所述第一输入表和所述第二输入表中的每一个的一组不相交的线程局部散列图中; 通过并行操作的第二多个执行线程来合并第一输入表的一组线程局部散列图，以产生一组合并的散列图; 将合并的散列映射的每个条目与第二输入表的线程局部散列映射集合的每个条目进行比较，以根据连接类型确定是否存在匹配; 以及生成包括通过比较确定的匹配的输出表。

公开(公告)号：US20180150521A1

公开(公告)日：2018-05-31

申请号：US15362586

申请日：2016-11-28

Applicant: SAP SE

Inventor： Kornel Skalkowski ,  Youssef Hatem ,  Stephan Kessler ,  Christian Mathis

IPC: G06F17/30

CPC classification number: G06F16/24544 ,  G06F16/2282 ,  G06F16/2455

Abstract: In one respect, there is provided a distributed database system that includes hosts configured to store and/or manage data, a first query processing engine comprising a master node and an executor node, and a second query processing engine. The master node can be implemented on programmable processors and configured to perform operations. The operations can include: offloading, to the second query processing engine, a creation of a first and a second table such that the first and the second table are partitioned by the second query processing engine; generating an execution plan for a query on data in the distributed database system, the execution plan including a distributed join operation that combines data from the first and second table; determining to push down, to the second query processing engine, the distributed join operation; and dispatching, to the executor node, a portion of the execution plan including the distributed join operation.

公开(公告)号：US09740758B2

公开(公告)日：2017-08-22

申请号：US15185182

申请日：2016-06-17

Applicant: SAP SE

Inventor： Christian Mathis ,  Daniel Ritter

IPC: G06F17/30

CPC classification number: G06F17/30569 ,  G06F17/30345 ,  G06F17/30474 ,  G06F17/3056 ,  G06F17/30595

Abstract: The present disclosure describes methods, systems, and computer program products for providing application integration functionality directly on a relational database according to an implementation. One computer-implemented method includes inserting relational data into a start table of a database, detecting a change in the start table, retrieving the inserted relational data from the start table, processing, using a computer, the relational data using a database integration flow runtime into result data, inserting the result data into an end table of the database, detecting a change in the end table, and retrieving the result data from the end table.