java - 如何转换 PCollectionjava 内存集合中只有一个元素？

Question

所以我想要做的是我将Count转换的输出存储在一个PCollection<Long>现在只有一个元素的地方。如果有任何方法可以将其转换为 Java 内存中的集合，那将非常方便。基本上我正在寻找的是对Create.of()变换的否定。任何想法？

标签： javagoogle-cloud-dataflowapache-beam

Answer 1

看看Scio中的 materialize 。