I think you basically need something like this:
DataStream input = ...
DataStream withErrors = input.filter(new MyErrorFilter());
DataStream withoutErrors = input.filter(new MyWithoutErrorFilter());
withErrors.addSink(...)
withoutErrors.addSink(...)
Does that help?
On Mon, 20 Feb 2017 at 13:44
A while back on the mailing list, there was a discussion on validating a stream, and splitting the stream into two sinks, depending on how the validation went:(operator generating errors) --> (filter) --> stream without errors --> sink --> (filter) --> error stream --> sink Is there an exam
