Hi, Not sure if there is a "developer" documentation for the protocol. I am cc'ing Igal and Gordon who know better than I if there is one.
To give you some hints though. If I am correct the Python API is implemented as a so called remote functions [1][2], which communicate with Flink via HTTP/gRPC. Besides the bundled Python API you can also use a Rust SDK[3] implemented by my colleague Aljoscha as a reference. BTW, it would be really cool to see an SDK written in Haskell ;) Best, Dawid [1] https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.1/concepts/distributed_architecture.html#remote-functions [2] https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.1/sdk/modules.html#remote-module [3] https://github.com/aljoscha/statefun-rust On 12/09/2020 07:26, Timothy Bess wrote: > The flink stateful function Python API looks cool, but is there a > documented spec for how it communicates with Flink? I'd like to > implement an SDK in Haskell if I can.
signature.asc
Description: OpenPGP digital signature
