Stream Processing
Showing 36 of 200 projects
Merge multiple Node.js streams into one interleaved stream for parallel processing in gulp and other stream-based workflows.
A Python toolkit for text-focused data science on medium-sized datasets, bridging memory and cluster-scale processing.
A .NET standard for asynchronous stream processing with non-blocking backpressure, enabling interoperability between reactive libraries.
A collection of reusable Delphi units providing Win32 wrappers, thread-safe structures, file utilities, and VCL enhancements.
A distributed video processing platform built on Apache Storm with OpenCV integration for large-scale computer vision pipelines.
A type-safe functional Stream processing library for Go, inspired by the Java Streams API.
A sample application demonstrating real-time data processing and visualization using Amazon Kinesis, DynamoDB, and a web server.
A blazingly fast, highly scalable graph-based stream processing framework for latency-critical applications like electronic trading and real-time AI.
A Go library for building data processing workflows and pipelines with functional operations, cycles, and fan-out capabilities.
A visual development platform for building, deploying, and managing streaming analytics applications with multiple engine bindings.
A Gulp plugin that executes shell commands on files in your pipeline.
A PHP library providing Python-inspired iteration tools for efficient data processing with loops and streams.
A Gulp plugin that remembers and recalls files passed through it, enabling incremental builds with full file sets.
A Ruby interface for the Amazon Kinesis Client Library, enabling developers to build robust streaming data applications.
A functional programming library for Go that introduces streams, collectors, and functional paradigms to improve code readability and reduce bugs.
Reactive programming library for F# Elmish and Fable applications using Async Observables.
A high-level Node.js module for creating readable streams with proper backpressure handling and a familiar API.
A Swift framework for launching shell tasks with ReactiveSwift-based stream processing.
A Go library for writing Storm spouts and bolts that communicate with Storm shells via the multilang protocol.
A MapReduce-style framework for processing fast/streaming data, implementing the MapUpdate model.
A CLI tool for extracting patterns from streaming unstructured log messages using the Drain parser algorithm.
A parser for the Test Anything Protocol (TAP) that converts TAP output into structured JavaScript objects.
A Java implementation of composable algorithmic transformations called transducers, independent from input/output sources.
A synchronous transform stream for Node.js with 10x performance over standard Transform streams.
A Storm spout that fetches data records from Amazon Kinesis and emits them as tuples for real-time stream processing.
A Java adapter that enables Amazon Kinesis Client Library (KCL) to consume and process data from DynamoDB Streams.
A Logstash input plugin that reads data from DynamoDB tables via table scans and DynamoDB Streams for near real-time data processing.
A Node.js library for parsing and creating Web ARChive (WARC) files with support for Chrome, Puppeteer, and Electron.
A parallelized stream implementation for Elixir that maintains order while processing with a worker pool.
Adds join operators to RxJava for combining multiple observable sequences based on pattern matching.
An experimental integration of Apache Samza and Luwak for scalable real-time document matching against large query sets.
A command-line tool that humanizes JSON streams by extracting and formatting specific fields for easier reading.
A distributed stream processing system written in Haskell that guarantees exactly-once semantics.
A probabilistic data structure service and storage for efficient frequency, cardinality, and membership queries on large datasets.
A Go library implementing IO, Stream, and Fiber monads with generics, inspired by cats-effect and fs2.
A reactive Kafka client for Vert.x that provides asynchronous consumer and producer APIs with stream support.
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.