Systems and methods for facilitating atomic delivery of bundled data sets to applications within distributed systems

A system comprising:

• a receiving module, stored in memory, that receives, at a queue of an application running within a distributed system, a data set from at least one other application running within the distributed system;
• a determination module, stored in memory, that determines that the data set received from the other application is incorporated in a bundle whose contents have yet to completely arrive at the queue of the application;
• a gating module that gates, due at least in part to the data set being incorporated in the bundle, the data set at the queue of the application at least until the bundle's contents have completely arrived at the queue of the application;
• wherein:
• the receiving module further receives, at the queue of the application, another data set incorporated in the bundle from the other application running within the distributed system;
• the determination module further determines that the bundle's contents have completely arrived at the queue of the application based at least in part on receiving the other data set incorporated in the bundle;
• a delivery module, stored in memory, that notifies, in response to the determination that the bundle's contents have completely arrived at the queue of the application, notifies the application that the bundle is ready for atomic delivery to the application such that the application is able to consume the bundle's contents on an as-needed basis;
• wherein the bundle comprises:
• a root node that includes metadata that identifies the bundle's contents;
• and
• a plurality of bundles that each include a bundle root that connects one or more content nodes to the root node, wherein:
• at least one of the content nodes represents the data set received from the other application;
• at least one of the content nodes represents the other data set received from the other application;
• and
• each bundle root represents a beginning of a bundle within the plurality of bundles;
• wherein the receiving module further receives, at the queue of the application, an updated version of the other data set from the other application running within the distributed system;
• and
• a bundle module, stored in memory, that modifies the bundle's contents to incorporate the updated version of the other data set without re-transferring any redundant versions of the bundle's contents from the other application to the queue of the application by:
• modifying, within the bundle, each bundle root along a path that leads from the root node to the content node representing the other data set to account for the updated version of the other data set without modifying any bundle roots that do not lead from the root node to the content node representing the other data set;
• and
• replacing the other data set with the updated version of the other data set to account for the updated version of the other data set without modifying any content nodes that do not represent the other data set;
• and
• at least one physical processor that executes the receiving module, the determination module, the gating module, and the delivery module.

A non-transitory computer-readable medium comprising one or more computer-executable instructions that, when executed by at least one processor of a computing device, cause the computing device to:

• receive, at a queue of an application running within a distributed system, a data set from at least one other application running within the distributed system;
• determine that the data set received from the other application is incorporated in a bundle whose contents have yet to completely arrive at the queue of the application;
• gate, due at least in part to the data set being incorporated in the bundle, the data set at the queue of the application at least until the bundle's contents have completely arrived at the queue of the application;
• receive, at the queue of the application, another data set incorporated in the bundle from the other application running within the distributed system;
• determine that the bundle's contents have completely arrived at the queue of the application based at least in part on receiving the other data set incorporated in the bundle;
• and
• in response to determining that the bundle's contents have completely arrived at the queue of the application, notify the application that the bundle is ready for atomic delivery to the application such that the application is able to consume the bundle's contents on an as-needed basis;
• wherein the bundle comprises:
• a root node that includes metadata that identifies the bundle's contents;
• a plurality of bundles that each include a bundle root that connects one or more content nodes to the root node, wherein:
• at least one of the content nodes represents the data set received from the other application;
• at least one of the content nodes represents the other data set received from the other application;
• and
• each bundle root represents a beginning of a bundle within the plurality of bundles;
• and
• modify the bundle's contents to incorporate an updated version of the other data set without re-transferring any redundant versions of the bundle's contents from the other application to the queue of the application by:
• receiving, at the queue of the application, the updated version of the other data set from the other application running within the distributed system;
• modifying, within the bundle, each bundle root along a path that leads from the root node to the content node representing the other data set to account for the updated version of the other data set without modifying any bundle roots that do not lead from the root node to the content node representing the other data set;
• and
• replacing the other data set with the updated version of the other data set to account for the updated version of the other data set without modifying any content nodes that do not represent the other data set.