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