Thanks Fabian,
I have seen Side Outputs and OutputTags but not fully understood the
mechanics yet. In my case, I don't need to keep bad records... And I think
I will end up with flatMap() after all, it just becomes a internal
documentation issue to provide relevant information...
Thanks for your
Hi Niclas,
I'd either add a Filter to directly discard bad records. That should make
the behavior explicit.
If you need to do complex transformations that you don't want to do twice,
the FlatMap approach would be the most efficient.
If you'd like to keep the bad records, you can implement a Proces
