英文:
Missing options in DirectOptions class
问题
docs中提到了以下选项：
direct_num_workers 和 direct_running_mode，以及设置 streaming 选项。
所有这些选项在 DirectOptions 类 中都缺失。
此外，当尝试从 args 中设置这些选项时，会抛出以下异常：
java.lang.IllegalArgumentException: 类接口 org.apache.beam.runners.direct.DirectOptions 缺少名为 '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)
是否有人成功使用过这些选项？如何使用？
英文:
The docs mention the following options:
direct_num_workers and direct_running_mode as well as setting the streaming option.
All of these are missing from the DirectOptions class
Also when trying to set those from args the following exception is thrown:
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)
Has someone managed to use these? How?
答案1
得分: 1
这些选项仅适用于Python SDK，实际上并不清楚，因为这些选项在两个SDK的注意事项部分都有记录，当记录Java SDK时应将其隐藏，欢迎报告文档问题。
这些选项是Python的FnApiRunner的一部分。
英文:
These options are relevant for the Python SDK only, it’s actually not clear as these options are documented in the caveats section for both sdks, it should be hidden when documenting the Java SDK, feel free to report the documentation issue.
These options are part of the Python FnApiRunner.
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论