Знать количество потоков, запущенных в прямом бегуне Apache Beam

Question

У меня есть программа Apache Beam в Java, работающая с прямым бегуном. Луч Apache использует потоки для достижения распределенной обработки.

1. Во время выполнения, как я могу узнать количество потоков, порожденных лучом apache?
2. Как я могу установить максимальное количество потоков для использования во время выполнения?

Answer 1

Эта ссылка ниже может быть полезной. В Java вы, похоже, не можете по состоянию на февраль 2021 года. В Python вы можете.

https://beam.apache.org/documentation/runners/direct/#parallel-execution

Answer 2

Вы можете использовать getTargetParallelismа также setTargetParallelismфункции для этого:

https://beam.apache.org/releases/javadoc/2.35.0/index.html?org/apache/beam/runners/direct/DirectOptions.html