Apache beam，使用java处理错误/端口输出8 lambdas

Question

任何人都可以提供一个例子，说明如何使用Java8 Lambdas来处理无效输入，这与我们可以在此优秀博客文章https://cloud.google.com/blog/big-data/2016/01/handling-invalid-inputs-in-dataflow中找到的逻辑相同。还是我只是用我用beam 2.1.0

干杯ParDo和DoFn

PS，

Answer 1

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