Отсутствующие параметры в классе DirectOptions

Question

В документах упоминаются следующие параметры: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)

Кому-нибудь удалось это использовать? Как?

Answer 1

Эти параметры актуальны только для Python SDK, на самом деле это неясно, поскольку эти параметры задокументированы в разделе предупреждений для обоих SDK, они должны быть скрыты при документировании Java SDK, не стесняйтесь сообщать о проблеме с документацией.

Эти параметры являются частью Python FnApiRunner.