Method and system for implementing hidden subscriptions in a distributed computation system
Embodiments of the invention relate to a method for managing subscriptions. The method includes monitoring a plurality of query requests executing on a plurality of query nodes, identifying, based on the monitoring, a query request of the plurality of query requests that satisfies a hidden subscription criterion, and generating a hidden subscription for the query request.
1. A method for managing subscriptions, comprising:
monitoring, by a database management system (DBMS), a plurality of query requests executing on a plurality of query nodes, wherein the plurality of query requests is for data stored on a persistent storage;
identifying, by the DBMS, based on the monitoring, a query request of the plurality of query requests that satisfies a hidden subscription criterion;
generating, by the DBMS, a hidden subscription for the query request, the hidden subscription is executed based on a hidden subscription trigger; and
in response to the hidden subscription trigger being activated by the query request:
determining, by the DBMS, that a query result associated with the query request is different than a latest query result of the query request, and
initiating, by the DMBS, execution of the hidden subscription on one of the plurality of query nodes to generate a query response comprising the query result,
wherein the query response is not provided to a client, and
wherein the hidden subscription maintains query results associated with the query request in at least one cache.
2. The method of claim 1 , wherein the hidden subscription trigger specifies an execution time.
3. The method of claim 1 , wherein the hidden subscription trigger specifies an execution day and time.
4. The method of claim 1 , wherein the hidden subscription trigger specifies an execution schedule.
5. The method of claim 1 , wherein the hidden subscription trigger specifies a modified user data sub-region.
6. The method of claim 1 , wherein the query request is identified using machine learning.
7. The method of claim 1 , wherein the hidden subscription criterion specifies a number of times the query request has been execution within a certain time period.
8. The method of claim 1 , wherein the hidden subscription criterion specifies an amount of computing resources on the plurality of query nodes that is required to execute the query request.
9. A non-transitory computer readable medium comprising computer readable program code, which when executed by a computer processor enables the computer processor to perform a method for managing subscriptions, the method comprising:
monitoring, by a database management system (DBMS), a plurality of query requests executing on a plurality of query nodes, wherein the plurality of query requests is for data stored on a persistent storage;
identifying, by the DBMS, based on the monitoring, a query request of the plurality of query requests that satisfies a hidden subscription criterion;
generating, by the DBMS, a hidden subscription for the query request, the hidden subscription is executed based on a hidden subscription trigger; and
in response to the hidden subscription trigger being activated by the query request:
determining, by the DBMS, that a query result associated with the query request is different than a latest query result of the query request, and
initiating, by the DMBS, execution of the hidden subscription on one of the plurality of query nodes to generate a query response comprising the query result,
wherein the query response is not provided to a client, and
wherein the hidden subscription maintains query results associated with the query request in at least one cache.
10. The non-transitory computer readable medium of claim 9 , wherein the hidden subscription trigger specifies an execution time.
11. The non-transitory computer readable medium of claim 9 , wherein the hidden subscription trigger specifies an execution day and time.
12. The non-transitory computer readable medium of claim 9 , wherein the hidden subscription trigger specifies an execution schedule.
13. The non-transitory computer readable medium of claim 9 , wherein the hidden subscription trigger specifies a modified user data sub-region.
14. The non-transitory computer readable medium of claim 9 , wherein the query request is identified using machine learning.
15. The non-transitory computer readable medium of claim 9 , wherein the hidden subscription criterion specifies a number of times the query request has been execution within a certain time period.
16. The non-transitory computer readable medium of claim 9 , wherein the hidden subscription criterion specifies an amount of computing resources on the plurality of query nodes that is required to execute the query request.