RE: Implementing Multiple sink

2024-06-03 Thread Colletta, Edward via user
Yes. But the filter us usually a very light weight operation. From: Mingliang Liu Sent: Monday, June 3, 2024 7:16 PM To: Colletta, Edward Cc: mejri houssem ; user@flink.apache.org Subject: Re: Implementing Multiple sink NOTICE: This email is from an external sender - do not click on links or

RE: Implementing Multiple sink

2024-06-03 Thread Colletta, Edward via user
I usually just reuse the stream, sending it to through different filters and adding different sinks to the filtered streams. Something like streamWithMultipleConditions.filter(FilterForCondition1) .addSink(SinkforCondtiton1);