0

文档提到了以下选项： 以及direct_num_workers设置direct_running_mode选项streaming。

DirectOptions 类中缺少所有这些

此外，当尝试从args以下异常中设置它们时：

java.lang.IllegalArgumentException: Class interface org.apache.beam.runners.direct.DirectOptions missing a property named 'direct_running_mode'.
        at org.apache.beam.sdk.options.PipelineOptionsFactory.parseObjects(PipelineOptionsFactory.java:1613)
        at org.apache.beam.sdk.options.PipelineOptionsFactory.access$400(PipelineOptionsFactory.java:117)
        at org.apache.beam.sdk.options.PipelineOptionsFactory$Builder.as(PipelineOptionsFactory.java:300)

有人设法使用这些吗？如何？

4

1 回答 1

1

这些选项仅与 Python SDK 相关，实际上并不清楚，因为这些选项都记录在两个 sdks 的警告部分中，在记录 Java SDK 时应该隐藏它，请随时报告文档问题。

这些选项是 Python FnApiRunner的一部分。

于 2020-10-04T18:10:29.113 回答