У меня есть сценарий использования, для которого я оцениваю, идеально ли подходит google-cloud-dataflow для нашего дизайна кода.У нас есть требование параллельной обработки обработки торговых событий для отчетности перед регулирующими органами.Тем не менее, нам нужно обработать выплаты по одной и той же сделке в последовательности, чтобы поддерживать порядок по тем же сделкам.
Как я прочитал в google-cloud-dataflow, все события из PCollection обрабатываются независимо и параллельно на основеприменяются PTransforms.
Если каждая моя сделка является событием в созданной PCollection, могу ли я обрабатывать сделки с одинаковым идентификатором в последовательности, а остальные параллельно.
Я читаю о обработке с отслеживанием состоянияс Apache Beam, в котором мы можем иметь функции ParDo с сохранением состояния, однако поддерживается ли это с помощью google-cloud-dataflow?