Thanks, I'll check it out. On Mon, Nov 25, 2019 at 11:46 AM vino yang <yanghua1...@gmail.com> wrote:
> *This Message originated outside your organization.* > ------------------------------ > Hi Avi, > > The side output provides a superset of split's functionality. So anything > can be implemented via split also can be implemented via side output.[1] > > Best, > Vino > > [1]: > https://stackoverflow.com/questions/51440677/apache-flink-whats-the-difference-between-side-outputs-and-split-in-the-data > <https://stackoverflow.com/questions/51440677/apache-flink-whats-the-difference-between-side-outputs-and-split-in-the-data> > > Avi Levi <avi.l...@bluevoyant.com> 于2019年11月25日周一 下午5:32写道： > >> 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] >>>> >>>> >>>>
