A Computing Model for Real-Time Stream Processing

For two main problems of the existing stream processing model: lack of support for iterative computing and tight coupling, the paper proposes a real-time stream processing model based on directed graph with sources and sinks, which supports both general DAG computing by means of directed circle detection and iteration protection as well as iterative feedback stream computing of directed circles, tow-way arcs and ring arcs. On this basis, the paper has implemented a set of flexible and loosely-coupled interfaces, which supports functional programming and runs executable program directly to achieve language independence without performance loss. This computing model is applicable to a wider range with more flexible interfaces and provides an effective approach to complicated stream computing.