如何为数据流指定工作者数量?

Ale*_*vey 10 google-cloud-dataflow apache-beam

我有一个大约90GB的大型导入文件,由我用Java编写的数据流处理.使用PipelineOptionsFactory的默认设置,我的工作需要很长时间才能完成.如何增加工人数量以提高绩效?

谢谢