使用Apache Beam（并行）查找组件？

Question

给出以下输入：（E1，E2），（E2，E3）和（E3，E4）。是否可以使用Apache Beam框架输出（E1，E2，E3，E4）？我的目标是在给定的元素对（并行）的情况下输出所有连接的组件。

Answer 1

一种简单的方法是使用相同的密钥（E1，E2）和（E3，E4），例如PCollection，然后使用CoGroupByKey。