edge intelligence

StreamCoCo: A DSL for Processing Data-Centric Streams for Industrial IoT Edge Applications

We report our experience of developing and using a simple yet an effective flow-based programming language and its distributed execution engine for detecting behavioral anomalies in physical assets in industrial IoT systems. Our stream processing systems is built using the Reactive Extensions (Rx) library for composing asynchronous data streams and the OMG Data Distribution Service (DDS) for publish-subscribe communication over the network.

Publication Year: 
Subscribe to RSS - edge intelligence