Thank you, for your quick reply. I appreciate that. but this it not exactly "side output" per se. it is simple splitting. IIUC The side output is more for splitting the records buy something the differentiate them (latnes , value etc' ) . I thought there is more idiomatic but if this is it, than I will go with that.
On Mon, Nov 25, 2019 at 10:42 AM vino yang <yanghua1...@gmail.com> wrote: > *This Message originated outside your organization.* > ------------------------------ > Hi Avi, > > As the doc of DataStream#split said, you can use the "side output" feature > to replace it.[1] > > [1]: > https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/side_output.html > <https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/side_output.html> > > Best, > Vino > > Avi Levi <avi.l...@bluevoyant.com> 于2019年11月25日周一 下午4:12写道： > >> Hi, >> I want to split the output of one of the operators to two pipelines. >> Since the *split* method is deprecated, what is the idiomatic way to do >> that without duplicating the operator ? >> >> [image: Screen Shot 2019-11-25 at 10.05.38.png] >> >> >>
