如何解决DirectOptions类中缺少选项
docs提到以下选项:
direct_num_workers
和direct_running_mode
,以及设置streaming
选项。
此外,当尝试从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)
有人设法使用了这些吗?怎么样?
解决方法
这些选项仅与Python SDK相关,实际上并不清楚,因为这些选项已在两个SDK的注意事项部分中进行了记录,在记录Java SDK时应将其隐藏,请随时报告文档问题。
这些选项是Python FnApiRunner的一部分。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。