flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chet Masterson <chet.master...@yandex.com>
Subject Splitting a stream based on validation
Date Mon, 20 Feb 2017 12:44:47 GMT
<div><div> </div><div>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:</div><div><br />(operator generating errors)</div><div>   
--&gt; (filter) --&gt; stream without errors --&gt; sink<br />    --&gt;
(filter) --&gt; error stream  --&gt; sink</div><div> </div><div>Is
there an example of this implemented in (scala) code anywhere? I'm not sure how to code this
up. Do I embed the error sink in the filter? The compiler hated everything I tried.</div></div>

View raw message