apachebeam管道I/O有两个读取文本文件的函数:beam.io.ReadFromText()
和beam.io.ReadAllFromText()
。但是,我无法理解它们之间的区别以及在哪里使用哪一种。你知道吗
这两个函数都有参数min_bundle_size
根据文件:https://beam.apache.org/releases/pydoc/2.9.0/apache_beam.io.textio.html
min_bundle_size
– Minimum size of bundles that should be generated when splitting this source into bundles.
我可以知道它的功能以及。你知道吗
目前没有回答
相关问题 更多 >
编程相关推荐