Apache Beam：将PCollection展平到PCollection

Question

假设我们有一些嵌套列表：

["a", "b"]
["c", "d"]

我们可以像这样轻松地在Stream API中进行翻盖映射：

Stream
        .of(List.of("a", "b"), List.of("c", "d"))
        .flatMap(List::stream)
        .forEach(System.out::println);

但是用“FlatMapElements”做这件事，真是一团糟：

Pipeline pipeline = Pipeline.create();
pipeline.apply(Create.of(List.of(List.of("a", "b"), List.of("c", "d"))))
        .apply(FlatMapElements.into(TypeDescriptor.of(String.class)).via(list -> list))
        .apply(ParDo.of(new SomeOutputFunction()));

我们能用平面贴图功能做得更好吗<一个简单的平面图工作不应该那么复杂，所以我想我遗漏了一些东西
我甚至无法替换。via（列表-

Answer 1

请参阅《Apache Beam编程指南》https://beam.apache.org/documentation/programming-guide/#flatten:

PCollectionList<String> collections = PCollectionList.of(pc1).and(pc2).and(pc3);

PCollection<String> merged = collections.apply(Flatten.<String>pCollections());