chamikaramj commented on code in PR #38512:
URL: https://github.com/apache/beam/pull/38512#discussion_r3263407817
##########
sdks/python/apache_beam/yaml/yaml_io.py:
##########
@@ -723,3 +723,60 @@ def write_to_tfrecord(
num_shards=num_shards,
shard_name_template=shard_name_template,
compression_type=getattr(CompressionTypes, compression_type))
+
+
[email protected]_fn
Review Comment:
Will adding this as a source here allow us to make this under YAML
transforms in job builder ? I think job builder sources do not support input
PCollections (so has to be a Transform there).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
