Sap Se

Sap Ag

Christian Mathis

Christian Bensberg

Daniel Ritter

Frederik Transier

Kai Stammerjohann

Xiaohui Xue

Peter Sanders

Nico Bohnsack

Stephan Kessler

Youssef Hatem

Axel Christ

Jens Boening

Karsten Schmidt

Kornel Skalkowski

Ingo Müller

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.

Distributed joins in a distributed database system

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.

Integration of query processing engines in a distributed database system

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.

Integration flow database runtime

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.

Hash-join in parallel computation environments

A system and method for generating a database management system (DBMS) internal program language function from a foreign program language function. The method includes loading the foreign function into a DBMS server, an internal program module unit, examining the foreign function to determine whether the foreign function is annotated for translation, if annotated determining if the foreign function is translated into an internal program language function and executing the internal program language function, else compiling the foreign function into an internal function. If the foreign function is not annotated for translation, executing the foreign program language function. The DBMS system includes a parsing unit, a type inference unit, a normalizer unit, a serializer unit, and a deployer unit. A computer readable medium is also disclosed.

System and method for translating business application functions into DBMS internal programming language procedures

Growing community of inventors

Wachenheim, Germany

Christian Mathis