Есть ли способ установить число параллелизмов при выполнении преобразования parDo в Apache Beam с использованием библиотек python?
Код:
xmls = contracts | 'Get XML' >> beam.ParDo(get_xml())