Database calculation engine with dynamic top operator

A system comprising:

• at least one programmable processor;
• and
• a non-transitory machine-readable medium storing instructions that, when executed by the at least one programmable processor, cause the at least one programmable processor to perform operations comprising:
• receiving, by a database server from an application server, a query associated with a reusable calculation scenario defining a data flow model that includes one or more calculation nodes, each one or more calculation nodes corresponding to an operation being performed on one or more database tables stored at a database, the one or more calculation nodes including one or more nodes specifying a window function operation, the window function operation including one or more first attributes and one or more second attributes, wherein a portion of the calculation scenario not forming part of the received query being removed during instantiation of the calculation scenario;
• executing, by a calculation engine, the calculation scenario, the executing including, using at least one of the first and second attributes, performing the window function operation on the one or more database tables stored at the database, at least one first calculation node in the one or more calculation nodes is executed by the calculation engine, and at least one second calculation node in the one or more calculation nodes is transformed into a set of logical database execution plans having a combination of a plurality of calculation nodes and corresponding operations, wherein each of the first and second attributes being associated with a corresponding rule configured to be triggered upon attributes exceeding a corresponding predetermined threshold, at least one rule being generated based on a determination of at least one of an estimated and an actual amount of memory consumed by a dataset associated with at least one of the first and second attributes;
• and
• generating, based on the executing of the calculation scenario, a result data set and providing, by the database server to the application server, the result data set.

A computer program product comprising a non-transitory machine-readable medium storing instructions that, when executed by at least one programmable processor, cause the at least one programmable processor to perform operations comprising:

• receiving, by a database server from an application server, a query associated with a reusable calculation scenario defining a data flow model that includes one or more calculation nodes, each one or more calculation nodes corresponding to an operation being performed on one or more database tables stored at a database, the one or more calculation nodes including one or more nodes specifying a window function operation, the window function operation including one or more first attributes and one or more second attributes, wherein a portion of the calculation scenario not forming part of the received query being removed during instantiation of the calculation scenario;
• executing, by a calculation engine, the calculation scenario, the executing including, using at least one of the first and second attributes, performing the window function operation on the one or more database tables stored at the database, at least one first calculation node in the one or more calculation nodes is executed by the calculation engine, and at least one second calculation node in the one or more calculation nodes is transformed into a set of logical database execution plans having a combination of a plurality of calculation nodes and corresponding operations, wherein each of the first and second attributes being associated with a corresponding rule configured to be triggered upon attributes exceeding a corresponding predetermined threshold, at least one rule being generated based on a determination of at least one of an estimated and an actual amount of memory consumed by a dataset associated with at least one of the first and second attributes;
• and
• generating, based on the executing of the calculation scenario, a result data set and providing, by the database server to the application server, the result data set.