Repository Index

A lightweight stream processing library for Go

• stream-processing
• pipeline
• etl
• kafka

Multi-core Window-Based Stream Processing Engine

• llvm
• incremental-computation
• aggregation
• stream-processing

Open-source streaming SQL engine written in Rust using Apache Arrow and DataFusion. Supports continuous queries, temporal stream joins, tumbling/session windows, and CDC/Kafka connectors. Lightweight, embeddable, and sub-microsecond latency

Window-Based Hybrid CPU/GPU Stream Processing Engine

• stream-processing
• hybrid
• multicore
• gpu

Sliding-window and regular top-K sketches, based on HeavyKeeper

• go
• golang
• heavy-hitters
• probabilistic-data-structures