发明授权
- 专利标题: Channel-based runtime engine for stream processing
- 专利标题(中): 基于通道的运行时引擎,用于流处理
-
申请号: US12485592申请日: 2009-06-16
-
公开(公告)号: US08380965B2公开(公告)日: 2013-02-19
- 发明人: Eric Bouillet , Hanhua Feng , Zhen Liu , Anton V. Riabov
- 申请人: Eric Bouillet , Hanhua Feng , Zhen Liu , Anton V. Riabov
- 申请人地址: US NY Armonk
- 专利权人: International Business Machines Corporation
- 当前专利权人: International Business Machines Corporation
- 当前专利权人地址: US NY Armonk
- 代理机构: F. Chau & Associates, LLC
- 代理商 William J. Stock
- 主分类号: G06F9/00
- IPC分类号: G06F9/00
摘要:
An apparatus to facilitate design of a stream processing flow that satisfies an objective, wherein the flow includes at least three processing groups, wherein a first processing group includes a data source and an operator, a second processing group includes a data source and an operator and a third processing group includes a join operator at its input and another operator, wherein data inside each group is organized by channels and each channel is a sequence of data, wherein an operator producing a data channel does not generate new data for the channel until old data of the channel is received by all other operators in the same group, and wherein data that flows from the first and second groups to the third group is done asynchronously and is stored in a queue if not ready for processing by an operator of the third group.
公开/授权文献
- US20100318768A1 CHANNEL-BASED RUNTIME ENGINE FOR STREAM PROCESSING 公开/授权日:2010-12-16