公开(公告)号：US20090070355A1

公开(公告)日：2009-03-12

申请号：US11853690

申请日：2007-09-11

申请人： Paul Michael CADARETTE ,  Lawrence E. KIRK ,  Robert Daniel LOVE ,  Gregg Andrew UPTON ,  Anil Venkatesh VARKHEDI ,  Charles Joseph WEIGEL, III

发明人： Paul Michael CADARETTE ,  Lawrence E. KIRK ,  Robert Daniel LOVE ,  Gregg Andrew UPTON ,  Anil Venkatesh VARKHEDI ,  Charles Joseph WEIGEL, III

IPC分类号： G06F17/00

CPC分类号： G06F17/30516

摘要： 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.

摘要翻译： 提供了用于数据流切换的技术。 在从历史数据流接受数据改变消息的同时，响应于确定历史数据流的结束正在接近，恢复来自实时数据流的消耗。 在从历史数据流和实时数据流之一接收数据改变消息时，获得用于数据改变消息的数据改变消息标识符（DCMID）。 然后，确定数据改变消息是否来自实时数据流。 响应于确定数据改变消息来自实时数据流，针对历史数据结构处理DCMID以确定在历史数据流中是否已经看到相关数据改变消息。 响应于确定数据改变消息来自历史数据流，针对实时数据结构处理DCMID以确定在实时数据流中是否已经看到相关数据改变消息。 确定是否已经满足在实时数据流和历史数据流中彼此对应的多个DCMID的阈值。 响应于确定已经满足阈值，存在从历史数据流中捕获数据改变消息到捕获实时数据流中的数据改变消息的切换。