Notification framework for document store

1. A computing system comprising:

a storage configured to store instructions; and

a processor configured to execute the instructions stored in the storage, wherein when executed, the instructions cause the processor to:

receive, via an event manager within a main memory of a database, a message published by a database partition that is located internally within the main memory, the message including information about a database event in which the database accesses a collection of data stored in the main memory of the database;

determine a publication type of the message from among a plurality of publication types based on attributes included in the message, the publication type corresponding to the database event of the message;

identify, via the event manager within the main memory, respective aggregation preferences of first and second database processes that are running internally within the main memory of the database and that have subscribed with the event manager for the identified publication type; and

transfer message information from the event manager to the first database process in real time based on the aggregation preferences of the first database process, aggregate the message with other published messages over a period of time until a size threshold is reached and, after the size threshold is reached, transfer aggregated message information from the event manager to the second database process based on the aggregation preferences of the second database process.

2. The computing system of claim 1 , wherein the publication type comprises one or more of a loading or unloading of data from the database, a data access operation on the database, and a scan of the database.

3. The computing system of claim 1 , wherein the database event comprises at least one of transferring data of the collection of data from disk to the main memory including the collection of data and transferring data of the collection of data from the main memory to the disk.

4. The computing system of claim 1 , wherein the processor is configured to push the information about the database event from the event manager to the first database process running internally within the main memory of the database.

5. The computing system of claim 1 , wherein the processor is configured to pull the aggregated message information from the event manager to the second database process running internally within the main memory of the database.

6. The computing system of claim 1 , wherein the first and second database processes comprise two of a garbage collector, a checkpoint process, and a query optimizer, which have subscribed to the identified publication type of the message.

7. The computing system of claim 1 , wherein the processor is configured to transfer the information about the database event to the first database process via a push request and transfer the aggregated message information to the second database process via a pull request.

8. The computing system of claim 1 , wherein the publication type comprises loading data to the database partition that published the message, and the processor is configured to identify the first and second database processes based on a mapping of the first and second database processes to the loading of data.

9. A method comprising:

receiving, via an event manager within a main memory of a database, a message published by a database partition that is located internally within the main memory, the message including information about a database event in which the database accesses a collection of data stored in the main memory of the database;

determining a publication type of the message from among a plurality of publication types based on attributes included in the message, the publication type corresponding to the database event of the message;

identifying, via the event manager within the main memory, respective aggregation preferences of first and second database processes that are running internally within the main memory of the database and that have subscribed with the event manager for the identified publication type; and

transferring message information from the event manager to the first database process in real time based on the aggregation preferences of the first database process, aggregate the message with other published messages over a period of time until a size threshold is reached and, after the size threshold is reached, transfer aggregated message information from the event manager to the second database process based on the aggregation preferences of the second database process.

10. The method of claim 9 , wherein the publication type comprises one or more of a loading or unloading of data from the database, a data access operation on the database, and a scan of the database.

11. The method of claim 9 , wherein the database event comprises at least one of transferring data of the collection of data from disk to the main memory including the collection of data and transferring data of the collection of data from the main memory to the disk.

12. The method of claim 9 , wherein the transferring comprises pushing the information about the database event from an event manager to the first database process running internally within the main memory of the database.

13. The method of claim 9 , wherein the transferring comprises pulling the aggregated message information from an event manager to the second database process running internally within the main memory of the database.

14. The method of claim 9 , wherein the first and second database processes comprise two of a garbage collector, a checkpoint process, and a query optimizer, which have subscribed to the identified publication type of the message.

15. The method of claim 9 , wherein the transferring comprises transferring the information about the database event to the first database process via a push request and transferring the aggregated message information to the second database process via a pull request.

16. A non-transitory computer-readable storage medium storing program instructions that when executed cause a processor to perform a method comprising:

receiving, via an event manager within a main memory of a database, a message published by a database partition that is located internally within the main memory, the message including information about a database event in which the database access a collection of data stored in the main memory of the database;

determining a publication type of the message from among a plurality of publication types based on attributes included in the message, the publication type corresponding to the database event of the message;

identifying, via the event manager within the main memory, respective aggregation preferences of first and second database processes that are running internally within the main memory of the database and that have subscribed with the event manager for the identified publication type; and

transferring message information from the event manager to the first database process in real time based on the aggregation preferences of the first database process, aggregate the message with other published messages over a period of time until a size threshold is reached and, after the size threshold is reached, transfer aggregated message information from the event manager to the second database process based on the aggregation preferences of the second database process.

17. The non-transitory computer readable medium of claim 16 , wherein the publication type comprises one or more of a loading or unloading of data from the database, a data access operation on the database, and a scan of the database.

18. The non-transitory computer readable medium of claim 16 , wherein the database event comprises at least one of transferring data of the collection of data from disk to the main memory including the collection of data and transferring data of the collection of data from the main memory to the disk.