Leases in a heterogenous data environment

摘要

A computer implemented method, system and product comprising establishing a lease contract for an analytic subscription, defining an analytic subscription as an evaluation that is passed to a provider that provides a Boolean evaluation model and a potential true/false event expression, receiving, via the bus, events from the systems of records until the expiration of the lease; and rejecting during a specified period of time events received from the systems of record after the expiration of the lease period.

主权项

1. A computer implemented method for controlling information flow between systems of record connected to a bus comprising:
establishing a lease contract for an analytic subscription; defining an analytic subscription as an evaluation that is passed to a provider that provides a Boolean evaluation model and a potential true/false event expression; receiving, via the bus, events from adaptors communicatively coupled between the systems of record and the bus until the expiration of the lease, wherein each of the systems of record is enabled to have a different data model, and wherein the adaptors are enabled to transform specific events of each of the different data models from each of the systems of record into an event, wherein the bus is enabled to mitigate a change storm, wherein the change storm includes multiple conflicting events received by the bus from the systems of record; wherein the change storm further includes events from different systems of record; wherein during the change storm at least two of the different systems of record have one or more rules that conflict with the other different system of record for the events included in the change storm; wherein applying the one or more rules that conflict during the change storm would not mitigate the change storm; wherein mitigating the change storm includes the bus invoking stewardship by invoking mastering services communicatively coupled to the bus; wherein the mastering services overrides the conflicting rules to mitigate the change storm; and rejecting during a specified period of time events received from the systems of record after the expiration of the lease period, wherein the specified period of time is equivalent to an amount of time to accumulate sufficient events for a particular analysis calculation, wherein the particular analysis calculation is based on the events received during the lease period, and wherein a policy is invoked to deal with a loss of access to resources.