I ended up implementing it: https://github.com/apache/beam/pull/6463/commits/334b1050d110a8f2635767976888d16b3eeee467
[ Full content available at: https://github.com/apache/beam/pull/6463 ] This message was relayed via gitbox.apache.org for [email protected]
