Apacheビーム、java 8ラムダでエラー/サイド出力を処理する

Question

Java8 Lambdasを使用して、Apacheのビームで無効な入力を処理する方法について、誰でもこの優秀なブログ投稿https://cloud.google.com/blog/big-data/2016/01/handling-invalid-inputs-in-dataflowで見つけることができる例はありますか？それとも私がbeam 2.1.0

乾杯、

Answer 1

はい、あなたはDoFnを使用する必要がありますを使用していParDoとDoFn

PSを使用することを単に持っています。変換MapElements/FlatMapElementsはサイド出力をサポートしていません。