No, I don't think we need to do this on Beam side - I believe it should a responsibility of OutputFormat implementation since it very depends on type of sink in the end.
[ Full content available at: https://github.com/apache/beam/pull/6306 ] This message was relayed via gitbox.apache.org for [email protected]
