Stream Processing
Showing 20 of 200 projects
Apply SQL queries and spatial filters to GeoJSON data in memory, with support for streams and Esri format conversion.
An end-to-end data management system for IoT, optimizing stream processing across cloud, edge, and sensor deployments.
F# library for serializing events in event-sourcing systems with version-tolerant converters for System.Text.Json and Newtonsoft.Json.
A comprehensive Ada utility library providing logging, serialization, encoding, stream composition, and concurrency tools for building robust applications.
A high-performance C++ JSON library with a binary wire protocol, optimized for network efficiency and zero-copy parsing.
A TypeScript/JavaScript library providing Python-inspired iteration utilities for working with iterables, streams, and pipes.
A fast Node.js stream splitter for binary data that splits on newlines or custom delimiters without converting to strings.
A Node.js Transform stream that processes data chunks concurrently with configurable max concurrency.
A multi-core stream processing engine for high-throughput window aggregation with optional exactly-once fault tolerance.
OCaml bindings for Apache Kafka, enabling Kafka client functionality in OCaml applications.
Go implementation of Count-Min-Log sketch for improved approximate counting of low-frequency events.
A thin wrapper around through2 that provides an Array.prototype.map-like API for transforming Node.js streams.
A runtime supervisor for deploying and running data processing programs called Sequences on Linux servers, Docker, and Kubernetes clusters.
A multi-threaded Python example demonstrating how to produce and consume records from Amazon Kinesis streams.
A fluent builder for lazy streams and generators in Groovy, enabling functional-style data processing.
A utilities library for Reactive Streams in the JDK, providing familiar operators like map and filter for java.util.concurrent.Flow.
A .NET interface to the Amazon Kinesis Client Library MultiLangDaemon for building distributed streaming data applications.
A Node.js library that pipes queued streams sequentially to preserve content order.
A Go package providing a simplistic implementation of pipelines using goroutines for concurrent data processing.
A simple, Kafka-inspired stream processing library for Scala with exactly-once semantics and strong ordering guarantees.
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.