发明名称 |
System and methodology for parallel stream processing |
摘要 |
A system and methodology for parallel processing of continuous data streams. In one embodiment, a system for parallel processing of data streams comprises: a converter receiving input streams of data in a plurality of formats and transforming the streams into a standardized data stream format comprising rows and columns in which values in a given column are of a homogeneous type; a storage system that continuously maintains a finite interval of each stream subject to specified space limits for the stream; an interface enabling a user to construct parallel stream programs for processing streams in the standardized data stream format, wherein a parallel stream program comprises a linear sequence of program building blocks for performing operations on a data stream; and a runtime computing system running multiple parallel stream programs continuously on the streams as they flow through the storage system.
|
申请公布号 |
US8069190(B2) |
申请公布日期 |
2011.11.29 |
申请号 |
US20080343215 |
申请日期 |
2008.12.23 |
申请人 |
MCCOLL WILLIAM FINLAY;SUIJLEN WIJNAND JOHANNES;CLOUDSCALE, INC. |
发明人 |
MCCOLL WILLIAM FINLAY;SUIJLEN WIJNAND JOHANNES |
分类号 |
G06F7/00;G06F17/20;G06F17/30 |
主分类号 |
G06F7/00 |
代理机构 |
|
代理人 |
|
主权项 |
|
地址 |
|