Distributed, type-safe, incremental stream processing framework in OCaml. 250ns stabilization, 2M+ events/sec, heap-based dirty propagation, idempotent delta algebra.
distributed-systems real-time kafka ocaml stream-processing type-safe incremental-computation jane-street self-adjusting-computation bin-prot
-
Updated
Mar 25, 2026 - OCaml