Lineage Information For Streaming Event Data And Event Lineage Graph Structures For Visualization
First Claim
1. A computer-implemented method for providing transparency in streaming event data, the method comprising:
- receiving, at one or more computing devices, a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity;
processing, using the one or more computing devices, the plurality of events using one or more complex event processing (CEP) rules to generate a complex event;
in response to generating the complex event, generating at least one lineage event that comprises lineage information, the lineage information comprising information corresponding to one or more source events, each of the one or more source events contributing to the complex event; and
storing the lineage event and the one or more source events in an event archive provided as a computer-readable storage medium.
2 Assignments
0 Petitions
Accused Products
Abstract
Implementations of the present disclosure include methods for providing transparency in streaming event data. In some implementations, methods include receiving a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity, processing the plurality of events using one or more complex event processing (CEP) rules to generate a complex event, in response to generating the complex event, generating at least one lineage event that comprises lineage information, the lineage information comprising information corresponding to one or more source events, each of the one or more source events contributing to the complex event, and storing the lineage event and the one or more source events in an event archive provided as a computer-readable storage medium.
-
Citations
20 Claims
-
1. A computer-implemented method for providing transparency in streaming event data, the method comprising:
-
receiving, at one or more computing devices, a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity; processing, using the one or more computing devices, the plurality of events using one or more complex event processing (CEP) rules to generate a complex event; in response to generating the complex event, generating at least one lineage event that comprises lineage information, the lineage information comprising information corresponding to one or more source events, each of the one or more source events contributing to the complex event; and storing the lineage event and the one or more source events in an event archive provided as a computer-readable storage medium. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18)
-
-
19. A computer-readable storage medium coupled to one or more processors and having instructions stored thereon which, when executed by the one or more processors, cause the one or more processors to perform operations for providing transparency in streaming event data, the operations comprising:
-
receiving, at one or more computing devices, a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity; processing, using the one or more computing devices, the plurality of events using one or more complex event processing (CEP) rules to generate a complex event; in response to generating the complex event, generating at least one lineage event that comprises lineage information, the lineage information comprising information corresponding to one or more source events, each of the one or more source events contributing to the complex event; and storing the lineage event and the one or more source events in an event archive provided as a computer-readable storage medium.
-
-
20. A system, comprising:
-
a computing device; and a computer-readable storage device coupled to the computing device and having instructions stored thereon which, when executed by the computing device, cause the computing device to perform operations for providing transparency in streaming event data, the operations comprising; receiving a plurality of events, each event comprising event data and being generated by an event source in response to a real-world activity; processing the plurality of events using one or more complex event processing (CEP) rules to generate a complex event; in response to generating the complex event, generating at least one lineage event that comprises lineage information, the lineage information comprising information corresponding to one or more source events, each of the one or more source events contributing to the complex event; and storing the lineage event and the one or more source events in an event archive provided as a computer-readable storage medium.
-
Specification