calco

Contract-based approach to specify distributed dataflows.

Java (and Kotlin) API implementation here.
Python API implementation: https://github.com/flame-stream/palco
Haskell prototype: https://github.com/flame-stream/halco