
Applications that generate continuous data have proliferated in recent years, and thus the challenge of processing those data streams has emerged. This requires Data Stream Processing frameworks with monitoring capabilities able to detect and react to any nondesired situation. Many streaming use cases deal with distributed sources of data which, for privacy and communication saving purposes, need to be tackled in a distributed manner. Based on the mentioned challenges, this paper presents STREAMER 3.0, an improvement on the former data stream framework with two new modules: (i) a monitoring manager with detection algorithms, alert raising and automatic model updater; and (ii) a distributed learning module relying on federated learning. We showcase these new functionalities with an example of remaining useful life estimation of turbofan engines using an LSTM.
[INFO.INFO-AI] Computer Science [cs]/Artificial Intelligence [cs.AI], Distributed Machine Learning, [INFO.INFO-LG] Computer Science [cs]/Machine Learning [cs.LG], Data Stream Processing, artificial intelligence, anomaly detection, monitoring, Data Stream, machine learning, RUL Estimation, Streaming Framework, distributed learning, LSTM, signal processing, Federated Learning
[INFO.INFO-AI] Computer Science [cs]/Artificial Intelligence [cs.AI], Distributed Machine Learning, [INFO.INFO-LG] Computer Science [cs]/Machine Learning [cs.LG], Data Stream Processing, artificial intelligence, anomaly detection, monitoring, Data Stream, machine learning, RUL Estimation, Streaming Framework, distributed learning, LSTM, signal processing, Federated Learning
| selected citations These citations are derived from selected sources. This is an alternative to the "Influence" indicator, which also reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically). | 1 | |
| popularity This indicator reflects the "current" impact/attention (the "hype") of an article in the research community at large, based on the underlying citation network. | Average | |
| influence This indicator reflects the overall/total impact of an article in the research community at large, based on the underlying citation network (diachronically). | Average | |
| impulse This indicator reflects the initial momentum of an article directly after its publication, based on the underlying citation network. | Average |
