Distributed Stream and Batch Processing

Modern, open-source event-processing

Golang based Rules for Real-time Contextual Decisions

:game_die: Casino Roulette :slot_machine: Analyzer and Predictor :coin:

Event Based Applications [DEPRECATED]

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

Radio is a DuckDB extension by Query.Farm that brings real-time event streams into your SQL workflows. It enables DuckDB to receive and send events over systems like WebSocket and Redis Pub/Sub.

Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.

A light-weight package for in-app micro batch processing

Apache Flink CEP: Automatic pattern generation and processing

RoadSafety BC DataHub API. A series of Python components for handling and processing digital forms.

Coyote Data Exchange Toolkit - Mediate or Integrate Anything

Front-end framework for processing user interface events in TypeScript + undo/redo algorithms

A Generic Benchmarking Platform for Big Data Architectures

Open-the-chests is a training environment for event-patterns recognition.

Front-end framework for processing user interface events in JavaFX

Unified sync/async stream processing with category-based filtering. Single API for IEnumerable/IAsyncEnumerable with Cases/SelectCase/ForEachCase pattern. Eliminates Rx complexity, enables elegant pipeline composition for real-time data processing.

Курс по алгоритмам от Яндекса

An application-agnostic, open-source tool designed to build incremental indices from continuously streaming event data.

An automated tracker system for the Chronos framework

Garbage-free (green) toolset to implement a Thread Actor with asynchronous API

This package provides visualizations for data aggregators from the Keystone library.

Front-end framework for processing user interface events in Angular

Keystone is an event processing library for Swift apps that handles event submission, persistence, as well as data aggregation and analysis.

Light-weight event-processing based on the idea of meshed cells with different pluggable behaviors

An event driven backend that generates and publishes smartwatch health metrics (heart rate, temperature, SpO₂) to AWS IoT Core. Useful for testing IoT pipelines, analytics, and real-time data processing

Spring Boot backend system for ingesting machine events with deduplication, concurrent-safe updates, and statistical analytics over time windows.

🕰️ Measure clock skew in real-time to identify devices with Chronos-Track's advanced fingerprinting engine, ensuring accurate device recognition and security.

🗺️ A Rust library for modeling, indexing, and analyzing spatial narratives — events anchored in space and time. Supports GeoJSON, CSV, R-tree indexes, and graph analysis.

A Wishbone output module to write data to the Elasticsearch document store