GCP 数据流：打印 PCollection 数据

Question

我是 GCP Dataflow 的新手，只是想了解是否有任何方法可以打印 PCollection 的所有值。

Pipeline p = Pipeline.create(options);
PCollection<String> lines = p.apply("ReadLines", TextIO.read().from(options.getInputFile()));

在这里，我想打印并检查行中所有可用的值（PCollection）

同样的，想要在下面的操作之后访问所有单词中的值

PCollection<String> words = lines.apply(
            FlatMapElements.into(TypeDescriptors.strings())
                    .via((String line) -> Arrays.asList(line.split(" "))));

Answer 1

您需要在 ParDo 中处理 PCollection。 See docs here。在 ParDo 中，您可以检查每个元素。