🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.

Stream Processing and Complex Event Processing Engine

Python Streaming DataFrames for Kafka

A framework for Big Data Optimization with multi-objective metaheuristics

Streaming API for pandas applied to big datasets

[IEEE TKDE 2023] A list of up-to-date papers on streaming tensor decomposition, tensor tracking, dynamic tensor analysis

Demonstration of streaming applications using Spring Cloud Data Flow with microservices written in Spring Cloud Stream.

[IEEE ICASSP 2021] "A fast randomized adaptive CP decomposition for streaming tensors". In 46th IEEE International Conference on Acoustics, Speech, & Signal Processing, 2021.

A project for the module (Advanced) Distributed Systems Prototyping at the Technical University of Berlin.

🔥👨‍💻 Build Big data pipelines with Apache Beam in any language and run it via Spark, Flink, GCP (Google Cloud Dataflow).

Real-time crypto trading data pipeline using Apache Spark, Kafka, and Airflow. Containerized microservices architecture for streaming analytics.

Stream processing of AIS data with Flink

Tool for efficient loading and processing of streaming data from Kafka to Elasticsearch

e2e machine learning pipeline using a config based approach for classification problems. Supports grouping and grading classifiers in addition to online learning algorithms

This repository contains a collection of Java demos presented in technical events and on the french YouTube channel 'Les Mains Dans Le Code'.

a complete streaming data pipeline that ingests simulated IoT sensor data, processes it and displays in real time through a simple website

Apache Beam stream data analytics template featuring Google PubSub and Google BigQuery

Spark Streaming using Flume (pushed based Approach)

This repository contains a collection of NodeJS/Typescript demos presented in technical events and on the french YouTube channel 'Les Mains Dans Le Code'.