У меня есть требование, чтобы иметь возможность проследить происхождение до отдельного файла...
Я пытаюсь создать ParDo с сохранением состояния в Apache Beam, который хранит данные о значениях и...
У меня есть потоковый конвейер в Apache Beam 2.5, который подписывается на подписку PubSub,...
Я разрабатываю задание GCP Cloud Dataflow, в котором используется брокер Kafka и реестр схем.Наш...
У меня есть применение, при котором мне приходится периодически (еженедельно) получать список всех...