首页 文章

Apache beam,使用java 8 lambdas处理错误/侧输出

提问于
浏览
0

任何人都可以使用 Java8 Lambdas 提供如何使用 Java8 Lambdas 处理无效输入的例子,我们可以在这篇优秀的博客文章_1438919中找到 . 或者我只是使用 ParDoDoFn

PS我正在使用 beam 2.1.0

干杯,

1 回答

  • 1

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

相关问题