Apache Beam，使用 java 8 个 lambda 表达式处理 errors/side 输出

Question

任何人都可以提供一个示例，说明如何使用 Java8 Lambdas 以我们可以在这个出色的博客 post https://cloud.google.com/blog/big-data/2016/01/handling-invalid-inputs-in-dataflow 中找到的相同逻辑来处理 apache beam 中的无效输入。或者我只需要使用 ParDo 和 DoFn

PS 我正在使用 beam 2.1.0

干杯，

Answer 1

是的，你必须使用 DoFn。转换 MapElements/FlatMapElements 不支持侧输出。