Учитывая следующие входные данные: (E1, E2), (E2, E3) и & (E3, E4). Можно ли вывести (E1, E2, E3, E4), используя платформу Apache Beam? Моя цель - вывести все подключенные компоненты по заданным парам элементов, которые совпадают (параллельно).
Одним простым способом было бы набрать (E1, E2) и (E3, E4) одним и тем же ключом, например, PCollection, затем использовать CoGroupByKey .