FILTER PROCESSING APPARATUS, DATA STORAGE DEVICE, FILTER PROCESSING METHOD, AND FILTER PROCESSING PROGRAM

摘要

PROBLEM TO BE SOLVED: To prevent overall throughput of a stream data management system from deteriorating even if the amount of data input as information sources remarkably changes. SOLUTION: A filter processing means 10 creates a source list 142a based on queue load information indicating the queue load of each data storage means 20, the source list 142a indicating the data storage means 20 that serves as a data source for the filter processing means 10. The filter processing means 10 acquires data from the data storage means 20 according to the source list 142a. If the overall throughput of each filter processing means 10 is greater than the overall load of each data storage means 10, sleep time is set for the source list 142a to reduce the failures when the filter processing means 10 acquires data from the data storage means 20, so as to prevent the throughput of the data storage means 20 from deteriorating. COPYRIGHT: (C)2009,JPO&INPIT