Real-Time Innovations

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.

Condition-based maintenance (CBM) of naval assets is preferred over scheduled maintenance because CBM provides a window into the future of each asset’s performance, and recommends/schedules service only when needed. In practice, the asset’s condition indicators must be reduced, transmitted (off-ship), and mined using shore-based predictive analytics. Real-Time Innovations (RTI), Inc.

The Internet of Things (IoT) paradigm has given rise to a new class of applications wherein complex data analytics must be performed in real-time on large volumes of fast-moving, heterogeneous sensor-generated data. Such data streams are often unbounded and must be processed in a distributed and parallel manner to ensure timely processing and delivery to interested subscribers.