Data Streams
Showing 27 of 27 projects
A Java VM library for composing asynchronous and event-based programs using observable sequences.
A reactive programming library for JavaScript that enables composing asynchronous and event-based programs using observable sequences.
A tiny, fast reactive/iterable programming library implementing the callbag spec for unified stream processing.
A graphical toolkit for exploring, analyzing, and modifying real-time data streams through a visual interface.
A high-performance one-pass in-memory streaming analytics engine for temporal and streaming data.
A lightweight, spec-compliant implementation of Observables for JavaScript, enabling reactive programming with streams.
A Python machine learning package for incremental learning on streaming data with concept drift detection.
A Go implementation of the ReactiveX spec providing a declarative and composable API for handling asynchronous data streams.
An AutoML implementation and tutorial for automating machine learning pipelines on both static datasets and dynamic data streams, with a focus on IoT anomaly detection.
Reactive Extensions for Lua, providing Observables for handling events, data streams, and asynchronous operations.
A high-performance Go library for matching JSON events against multiple patterns with support for wildcards, regex, and complex queries.
A Spark Streaming library for mining big data streams with incremental learning algorithms.
An ultra-fast .NET library for complex event processing and time series manipulation, handling historical and real-time data streams.
A Go library providing monads, optional types, Rx-style observables, and functional programming utilities.
A lightweight stream processing engine designed specifically for IoT data processing and analytics.
A MapReduce-style framework for processing fast/streaming data, implementing the MapUpdate model.
Adds join operators to RxJava for combining multiple observable sequences based on pattern matching.
Provides mathematical operators and utilities for RxJava to enable reactive numeric computations.
A high-performance Delphi library for sequential data reading and writing using memory buffers, offering TStream-like interfaces with optimized speed.
A distributed platform for processing continuous unbounded streams of data with a clean API and fault tolerance.
A dynamic framework for processing high-volume data streams with subsecond pipeline instantiation and modification latency.
A fast Go implementation of HeavyKeeper-based top-K sketches, including sliding-window variants for real-time data streams.
A streams2 Readable stream generator for testing and converting lazy functions into streams.
Elixir implementation of the Space-Saving algorithm for estimating distinct element counts in data streams with bounded memory.
RxJS ReplaySubjects with additional features to simplify reactive programming patterns.
An educational resource explaining Reactive Programming concepts and the RxJs library with practical examples.
A Storm-based SQL query language for real-time data streams, simplifying complex stream processing with window-based in-memory computation.
Related Tags
Found a gem we're missing?
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.