У меня проблемы с пониманием того, как Cloud Dataflow знает, когда выполнять код конвейера синхронно или асинхронно.
Например, в разработанном мною конвейере я читаю файл, содержащий список идентификаторов, и создаю из него sideInput.Этот sideinput используется преобразованием ParDo с другим набором PCollection, созданным путем чтения другого файла.
В этом смысле для потока данных сначала необходимо полностью создать sideInput перед выполнением преобразования ParDo.
Как узнать, когда конвейер работает в «синхронном или асинхронном режиме»?Есть ли у меня контроль над этим?