发明名称 |
System and method for analyzing streams and counting stream items on multi-core processors |
摘要 |
Systems and methods for parallel stream item counting are disclosed. A data stream is partitioned into portions and the portions are assigned to a plurality of processing cores. A sequential kernel is executed at each processing core to compute a local count for items in an assigned portion of the data stream for that processing core. The counts are aggregated for all the processing cores to determine a final count for the items in the data stream. A frequency-aware counting method (FCM) for data streams includes dynamically capturing relative frequency phases of items from a data stream and placing the items in a sketch structure using a plurality of hash functions where a number of hash functions is based on the frequency phase of the item. A zero-frequency table is provided to reduce errors due to absent items. |
申请公布号 |
US8321579(B2) |
申请公布日期 |
2012.11.27 |
申请号 |
US20070828732 |
申请日期 |
2007.07.26 |
申请人 |
AGGARWAL CHARU CHANDRA;BORDAWEKAR RAJESH;THOMAS DINA;YU PHILIP SHILUNG;INTERNATIONAL BUSINESS MACHINES CORPORATION |
发明人 |
AGGARWAL CHARU CHANDRA;BORDAWEKAR RAJESH;THOMAS DINA;YU PHILIP SHILUNG |
分类号 |
G06F15/16 |
主分类号 |
G06F15/16 |
代理机构 |
|
代理人 |
|
主权项 |
|
地址 |
|