Dynamic adaptations for network delays during complex event processing
First Claim
1. A system including instructions recorded on a computer-readable medium and executable by at least one processor, the system comprising:
- a message handler configured to cause the at least one processor to receive a plurality of messages associated with a plurality of events, the events having a temporal relationship to one another, the events including a first event and a second event, wherein the first event and the second event are associated with a time window to process the first event and the second event such that the first and second events are not processed when at least one of the first and second events are considered to have occurred outside the time window;
a header inspector configured to cause the at least one processor to extract latency information from the plurality of messages, the latency information characterizing a transmission duration experienced by each message in traveling from one or more source nodes through a network of nodes;
a window manager configured to cause the at least one processor to correct a disruption in the temporal relationship between the first event and the second event based on the extracted latency information for a first message corresponding to the first event and a second message corresponding to the second event, the disruption including relative differences in the transmission duration experienced by the first event and the second event, wherein disruption in the temporal relationship is corrected by extending the time window such that the first event and the second event fall within the time window; and
an event processor configured to cause the at least one processor to process the first and second events relative to the time window.
2 Assignments
0 Petitions
Accused Products
Abstract
A message handler may receive a plurality of messages associated with a plurality of events, the events having a temporal relationship to one another. A header inspector may extract latency information from the plurality of messages, the latency information characterizing a transmission duration experienced by each message in traveling from the one or more source nodes through the network. A window manager may correct a disruption in the temporal relationship between at least two events of the plurality of events, the disruption including relative differences in the transmission duration experienced by the at least two events, including relating the at least two events to a time window for processing the at least two events. An event processor may process the at least two events relative to the time window.
-
Citations
18 Claims
-
1. A system including instructions recorded on a computer-readable medium and executable by at least one processor, the system comprising:
-
a message handler configured to cause the at least one processor to receive a plurality of messages associated with a plurality of events, the events having a temporal relationship to one another, the events including a first event and a second event, wherein the first event and the second event are associated with a time window to process the first event and the second event such that the first and second events are not processed when at least one of the first and second events are considered to have occurred outside the time window; a header inspector configured to cause the at least one processor to extract latency information from the plurality of messages, the latency information characterizing a transmission duration experienced by each message in traveling from one or more source nodes through a network of nodes; a window manager configured to cause the at least one processor to correct a disruption in the temporal relationship between the first event and the second event based on the extracted latency information for a first message corresponding to the first event and a second message corresponding to the second event, the disruption including relative differences in the transmission duration experienced by the first event and the second event, wherein disruption in the temporal relationship is corrected by extending the time window such that the first event and the second event fall within the time window; and an event processor configured to cause the at least one processor to process the first and second events relative to the time window. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A computer-implemented method for executing instructions stored on a computer readable storage medium, the method comprising:
-
receiving a plurality of messages associated with a plurality of events, the events having a temporal relationship to one another, the events including a first event and a second event, wherein the first event and the second event are associated with a time window to process the first event and the second event such that the first and second events are not processed when at least one of the first and second events are considered to have occurred outside the time window; extracting latency information from the plurality of messages, the latency information characterizing a transmission duration experienced by each message in traveling from one or more source nodes through a network of nodes; correcting a disruption in the temporal relationship between the first event and the second event based on the extracted latency information for a first message corresponding to the first event and a second message corresponding to the second event, the disruption including relative differences in the transmission duration experienced by the first event and the second event, wherein disruption in the temporal relationship is corrected by extending the time window such that the first event and the second event fall within the time window; and processing the first and second events relative to the time window. - View Dependent Claims (13)
-
-
14. A computer program product, the computer program product being tangibly embodied on a non-transitory computer-readable storage medium and comprising instructions that, when executed, are configured to:
-
receive a plurality of messages associated with a plurality of events, the events having a temporal relationship to one another, the events including a first event and a second event, wherein the first event and the second event are associated with a time window to process the first event and the second event such that the first and second events are not processed when at least one of the first and second events are considered to have occurred outside the time window; extract latency information from the plurality of messages, the latency information characterizing a transmission duration experienced by each message in traveling from the one or more source nodes through a network of nodes; correct a disruption in the temporal relationship between the first event and the second event based on the extracted latency information for a first message corresponding to the first event and a second message corresponding to the second event, the disruption including relative differences in the transmission duration experienced by the first event and the second event, wherein disruption in the temporal relationship is corrected by extending the time window such that the first event and the second event fall within the time window; and process the first and second events relative to the time window. - View Dependent Claims (15, 16, 17, 18)
-
Specification