@robertwb thanks for the ping. I did not pay attention to `fn_api_runner` so far - this gives a good idea for the wiring work we need to do for user state and timers in the Flink runner. Just curious, why do we have a direct runner and an fn_api_runner for Python, why not just have the latter? Or perhaps that is the (undocumented) goal?
[ Full content available at: https://github.com/apache/beam/pull/6433 ] This message was relayed via gitbox.apache.org for [email protected]
