Apache Kafka® running on Kubernetes

Implementation/Tutorial of using Automated Machine Learning (AutoML) methods for static/batch and online/continual learning

Online anomaly detection for data streams/ Real-time anomaly detection for time series data.

A lightweight, memory-efficient library for working with generator functions in TypeScript.

Rust based DuckDB Server with 1st class Postgres interface for BI Tools like Power BI and Tableau. Streaming interfaces like Web, Kafka, and FlightSQL/RPC.

The stream-learn is an open-source Python library for difficult data stream analysis.

BBoxDB is a scalable, highly available, and distributed data store for multi-dimensional big data. The software supports operations like multi-dimensional range queries and spatial joins. In addition, data streams are supported.

This repository includes code for the AutoML-based IDS and adversarial attack defense case studies presented in the paper "Enabling AutoML for Zero-Touch Network Security: Use-Case Driven Analysis" published in IEEE Transactions on Network and Service Management.

DataDog data streams library for Elixir

AutoML framework for implementing automated machine learning on data streams

Python framework for generating streams of labeled data.

Python implementation of adwin algorithm

Telestion is a ground station software developed by the TelestionTeam for WüSpace projects.

FedStream: Prototype-Based Federated Learning on Distributed Concept-drifting Data Streams

A React group chat demo powered by PubNub and reusable chat components.

Semi-supervised Federated Learning on Evolving Data Streams

Repository for the StreamingRandomPatches algorithm implemented in MOA 2019.04

Simulations, Paper Submission Drafts and Patent Applications for Research on Hierarchical Modulations

Stream Autoencoder Windowing (SAW) - Change Detection Framework for high dimensional data streams

Queue-Based Resampling (QBR, ICANN 2018)

Implementation of "Fast clustering-based anonymization approaches with time constraints for data streams".

Adaptive REBAlancing (AREBA, IEEE TNNLS 2021)

Easy to integrate and powerful Oracle on top of Chainlink Data Streams and Chainlink Data Feeds

The implementation of Synthetic Minority Oversampling based on stream Clustering (SMOClust)

Application allowing to view data streams and Alternative Data Streams (ADS) of files on NTFS systems without the need of Powershell or any other (technical) tool.

This code refers to all experiments in our paper "Autonomous Deep Learning: Continual Learning Approach for Dynamic Environments"

On metaattribute ability in implicit concept identification

Parallel Count Sketch implementations (Sequential, MPI, Hybrid MPI+OpenMP) for high-performance frequency estimation in massive data streams. Benchmarked on the UniTN HPC cluster with strong & weak scaling analyses up to 64 processes.

Learning High-Dimensional Evolving Data Streams With Limited Labels

Как организовать обмен данными через сервис Yandex Data Streams (YDS) в Yandex Cloud.