在Python中设置单个操作的并行度

Question

我使用 dop > 1 执行程序，但我不需要多个输出文件。在 Java 中myDataSet.writeAsText(outputFilePath, WriteMode.OVERWRITE).setParallelism(1);正在按预期工作。

但当我在 Python 中尝试同样的方法时，它不起作用。这是我的代码： myDataSet.write_text(output_file, write_mode=WriteMode.OVERWRITE).set_degree_of_parallelism(1)

有可能在Python中实现这种行为吗？

Answer 1

这不是错误，而是不受支持的功能。目前无法为单个操作员设置并行度，而只能为整个作业设置并行度。