This repo contains reference implementations of sliding window aggregation algorithms.

An open source, cloud-native analytics product optimized to create real-time, actionable insights for agile digital businesses

Pachyderm lets you deploy and manage multi-stage, language-agnostic data pipelines while maintaining complete reproducibility and provenance

Kasper is a lightweight library for processing Kafka topics

Fast, efficient, and scalable distributed map/reduce system, DAG execution, in memory or on disk, written in pure Go, runs standalone or distributedly

a curated list of awesome streaming frameworks, applications, etc