Использование Apache Beam
Считайте, что у меня есть соединение с базой данных. Данные в базе данных являются изменчивыми.
Теперь рассмотрим, что у меня есть поток (неограниченная коллекция), и для каждого события в потоке я хотел бы просмотреть базу данных.
Возможно ли это с PCollection (какой-то изменяемый флаг всегда перечитывается)?