任何人都可以使用 Java8 Lambdas 提供如何使用 Java8 Lambdas 处理无效输入的例子,我们可以在这篇优秀的博客文章_1438919中找到 . 或者我只是使用 ParDo 和 DoFn
Java8 Lambdas
ParDo
DoFn
PS我正在使用 beam 2.1.0
beam 2.1.0
干杯,
是的,你必须使用DoFn . 转换MapElements / FlatMapElements不支持侧输出 .
1 回答
是的,你必须使用DoFn . 转换MapElements / FlatMapElements不支持侧输出 .