摘要 |
Methods for processing multi-source data. It is determined whether any data exists at a position pointed by a first pointer corresponding to a first data source in a queue. If so, an overlapped portion of data read from the first data source and the data pointed by the first pointer in the queue is processed with the data in the queue, and stored to the queue from the position pointed by the first pointer. The first pointer re-points to a position subsequent to the processed data in the queue. A non-overlapped portion of the data read from the first data source and the data pointed by the first pointer in the queue is stored to the queue from the position pointed by the first pointer. If the data in the queue is processed with data from each of the data sources, the processed data is output to a data processing system for further processing.
|