I think it is `pre_finalize_coll` in `iobase.py`. That's a flat map which indeed does not output any data. It would be nice to be able to distinguish "not ready" from "no output". I suppose if the key exists in the state backend, we can assume that (which is in lines with this PR).
[ Full content available at: https://github.com/apache/beam/pull/6325 ] This message was relayed via gitbox.apache.org for [email protected]
