Integrated Application Server and Data Server Processes with Matching Data Formats

    公开(公告)号:US20200372042A1

    公开(公告)日:2020-11-26

    申请号:US16989447

    申请日:2020-08-10

    Applicant: SAP SE

    Abstract: In one embodiment, the present invention includes a computer-implemented method comprising storing data in an application using an application custom data type and application custom data structure. The data is stored in a database using the application custom data type and the application custom data structure. In one embodiment, a request is sent to access the data from the application to the database. The data is retrieved from the database in response to the request in the application custom data type and the application custom data structure. In one embodiment, the data is sent from the database to a shared memory in the application custom data type and the application custom data structure and the data is retrieved by the application from the shared memory in the application custom data type and the application custom data structure.

    Customizing operator nodes for graphical representations of data processing pipelines

    公开(公告)号:US10747506B2

    公开(公告)日:2020-08-18

    申请号:US16009987

    申请日:2018-06-15

    Applicant: SAP SE

    Abstract: A method may include receiving, from a client, a request to customize an operator node corresponding to a data processing operation. The request may include a first key. The operator node may be selected for inclusion in a graph representative of a data processing pipeline. The operator node may be associated with a first file that includes at least one configuration parameter associated with the operator node. The at least one configuration parameter may be associated with a second key. In response to the first key being determined to match the second key, the operator node may be customized by modifying the at least one configuration parameter. Furthermore, a second file associated with a customized operator node may be generated to store the customizations made to the operator node including the modification of the at least one configuration parameter. Related systems and articles of manufacture are also provided.

    Trace messaging for distributed execution of data processing pipelines

    公开(公告)号:US10733034B2

    公开(公告)日:2020-08-04

    申请号:US16010018

    申请日:2018-06-15

    Applicant: SAP SE

    Abstract: A method for routing trace messages during an execution of a data processing pipeline is provided. The method may include receiving, at a master node, a request from a client to receive trace messages output by a worker node executing at least a portion of the data processing pipeline. The master node and the worker node may be part of a distributed cluster of computing nodes. The trace messages may correspond to events occurring during the execution of at least the portion of the data processing pipeline. The master node may respond to the request by subscribing to a trace stream published by the worker node. The trace stream may include the trace messages output by the worker node. The master node may generate a user interface for displaying, at the client, the trace messages. Related systems and articles of manufacture, including computer program products, are also provided.

    Handling failovers at one or more nodes in a distributed database system

    公开(公告)号:US10719353B2

    公开(公告)日:2020-07-21

    申请号:US15274848

    申请日:2016-09-23

    Applicant: SAP SE

    Abstract: In one respect, there is provided a distributed database system that includes a first local scheduler node and a second local scheduler node. The first local scheduler node can be configured to coordinate a performance of a first task and a second task by a first worker node associated with the first local scheduler node. The second local scheduler node can be configured to respond to a defect at the first local scheduler node by at least: collecting, from the first worker node, a log indicating one or more tasks completed by the first worker node prior to the defect at the first local scheduler node; determining, based at least on the log, that the first worker node has completed the first task but not the second task; and coordinating a performance of the second task by the first worker node. Related methods and articles of manufacture are also provided.

    Mechanism for Constant-Space Indexing Optimized Data Block Merging

    公开(公告)号:US20180165315A1

    公开(公告)日:2018-06-14

    申请号:US15377375

    申请日:2016-12-13

    Applicant: SAP SE

    CPC classification number: G06F16/2282

    Abstract: In one aspect, a computer-implemented method includes calculating cardinality differences and combined sizes for one or more data block pairs in a relational database. The method also includes selecting a data block pair from the one or more data block pairs based on a calculated cardinality difference and a calculated combined size associated with the selected data block pair. The method further includes merging the selected data block pair to form a merged data block, and replacing the selected data block pair in the relational database by the merged data block.

    FAILOVER HANDLING IN A DISTRIBUTED DATABASE SYSTEM

    公开(公告)号:US20180088987A1

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

    申请号:US15274848

    申请日:2016-09-23

    Applicant: SAP SE

    Abstract: In one respect, there is provided a distributed database system that includes a first local scheduler node and a second local scheduler node. The first local scheduler node can be configured to coordinate a performance of a first task and a second task by a first worker node associated with the first local scheduler node. The second local scheduler node can be configured to respond to a defect at the first local scheduler node by at least: collecting, from the first worker node, a log indicating one or more tasks completed by the first worker node prior to the defect at the first local scheduler node; determining, based at least on the log, that the first worker node has completed the first task but not the second task; and coordinating a performance of the second task by the first worker node. Related methods and articles of manufacture are also provided.

    Containerized runtime environments

    公开(公告)号:US10949219B2

    公开(公告)日:2021-03-16

    申请号:US16010003

    申请日:2018-06-15

    Applicant: SAP SE

    Abstract: A method for executing a data processing pipeline may be provided. The method may include identifying a file providing a runtime environment required for executing a series of data processing operations comprising the data processing pipeline. The file may be identified based on one or more tags associated with the data processing pipeline. The one or more tags may specify at least one runtime requirement for the series of data processing operations. The file may be executed to generate an executable package that includes a plurality of components required for executing the series of data processing operations. The series of data processing operations included in the data processing pipeline may be executed by at least executing the executable package to provide the runtime environment required for executing the series of data processing operations. Related systems and articles of manufacture, including computer program products, are also provided.

    DATA PROCESSING PIPELINE ENGINE
    9.
    发明申请

    公开(公告)号:US20190384461A1

    公开(公告)日:2019-12-19

    申请号:US16010009

    申请日:2018-06-15

    Applicant: SAP SE

    Abstract: A method for generating a data processing pipeline is provided. The method may include generating a user interface for displaying, at a client, a first operator node and a second operator node. The first operator node and the second operator node may each correspond to a data processing operation. In response to one or more inputs received from the client via the user interface, the first operator node and/or the second operator node may be added to a graph displayed in the user interface. The graph may be representative of a data processing pipeline. The first operator node and the second operator node may further be interconnected with an directed edge. The data processing pipeline may be generated based on the graph. Related systems and articles of manufacture, including computer program products, are also provided.

    Dynamic hierarchy based message distribution

    公开(公告)号:US10305824B2

    公开(公告)日:2019-05-28

    申请号:US15211675

    申请日:2016-07-15

    Applicant: SAP SE

    Abstract: A distributed database system can include a plurality of nodes. In order to execute a query at the distributed database system, one or more of the plurality of nodes can perform operations included in an execution plan for the query. A first node of the plurality of nodes can group the plurality of nodes into at least a first cluster. The first node can further select a second node to act as a gateway node for the first cluster. The first node can determine that at least one recipient node of a message is included in the first cluster and route the message to the recipient node by at least sending the message to the second node. Related methods and articles of manufacture are also disclosed.

Patent Agency Ranking