TRANSITIONING BETWEEN HISTORICAL AND REAL TIME DATA STREAMS IN THE PROCESSING OF DATA CHANGE MESSAGES
First Claim
1. A computer-implemented method, comprising:
- while accepting data change messages from one of a historical data stream and a real time data stream,obtaining a data change message identifier (DCMID) for a data change message;
determining whether the data change message is from the real time data stream;
in response to determining that the data change message is from the real time data stream, processing the DCMID against a historical data structure to determine whether the related data change message has been seen in the historical data stream;
in response to determining that the data change message is from the historical data stream, processing the DCMID against a real time data structure to determine whether the related data change message has been seen in the real time data stream;
determining whether a threshold for a number of DCMIDs that correspond to each other in the real time data stream and the historical data stream has been met; and
in response to determining that the threshold has been met, switching from capturing data change messages in the historical data stream to capturing data change messages in the real time data stream.
1 Assignment
0 Petitions
Accused Products
Abstract
Provided are techniques for data stream switching. While accepting data change messages from a historical data stream, in response to determining that the end of the historical data stream is approaching, consumption from a real time data stream is resumed. In accepting data change messages from one of a historical data stream and a real time data stream, a data change message identifier (DCMID) for a data change message is obtained. Then, it is determined whether the data change message is from the real time data stream. In response to determining that the data change message is from the real time data stream, the DCMID is processed against a historical data structure to determine whether the related data change message has been seen in the historical data stream. In response to determining that the data change message is from the historical data stream, the DCMID is processed against a real time data structure to determine whether the related data change message has been seen in the real time data stream. It is determined whether a threshold for a number of DCMIDs that correspond to each other in the real time data stream and the historical data stream has been met. In response to determining that the threshold has been met, there is a switch from capturing data change messages in the historical data stream to capturing data change messages in the real time data stream.
-
Citations
21 Claims
-
1. A computer-implemented method, comprising:
while accepting data change messages from one of a historical data stream and a real time data stream, obtaining a data change message identifier (DCMID) for a data change message; determining whether the data change message is from the real time data stream; in response to determining that the data change message is from the real time data stream, processing the DCMID against a historical data structure to determine whether the related data change message has been seen in the historical data stream; in response to determining that the data change message is from the historical data stream, processing the DCMID against a real time data structure to determine whether the related data change message has been seen in the real time data stream; determining whether a threshold for a number of DCMIDs that correspond to each other in the real time data stream and the historical data stream has been met; and in response to determining that the threshold has been met, switching from capturing data change messages in the historical data stream to capturing data change messages in the real time data stream. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
8. A computer program product comprising a computer useable medium including a computer readable program, wherein the computer readable program when executed on a computer causes the computer to:
while accepting data change messages from one of a historical data stream and a real time data stream, obtain a data change message identifier (DCMID) for a data change message; determine whether the data change message is from a real time data stream; in response to determining that the data change message is from the real time data stream, process the DCMID against a historical data structure to determine whether the related data change message has been seen in the historical data stream; in response to determining that the data change message is from the historical data stream, process the DCMID against a real time data structure to determine whether the related data change message has been seen in the real time data stream; determine whether a threshold for a number of DCMIDs that correspond to each other in the real time data stream and the historical data stream has been met; and in response to determining that the threshold has been met, switch from capturing data change messages in the historical data stream to capturing data change messages in the real time data stream. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
15. A system, comprising:
-
logic capable of performing operations, the operations comprising; while accepting data change messages from one of a historical data stream and a real time data stream, obtaining a data change message identifier (DCMID) for a data change message; determining whether the data change message is from a real time data stream; in response to determining that the data change message is from the real time data stream, processing the DCMID against a historical data structure to determine whether the related data change message has been seen in the historical data stream; in response to determining that the data change message is from the historical data stream, processing the DCMID against a real time data structure to determine whether the related data change message has been seen in the real time data stream; determining whether a threshold for a number of DCMIDs that correspond to each other in the real time data stream and the historical data stream has been met; and in response to determining that the threshold has been met, switching from capturing data change messages in the historical data stream to capturing data change messages in the real time data stream. - View Dependent Claims (16, 17, 18, 19, 20, 21)
-
Specification