flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cai yi <cy.2...@gmail.com>
Subject Re: Split a stream into any number of streams
Date Tue, 17 Sep 2019 05:33:16 GMT
可以使用Side Output, 将输入流根据不同需求发送到自定义的不同的OutputTag中,最后可以使用DataStream.getSideOutput(outputTag)取出你需要的流进行处理!

在 2019/9/17 上午10:05,“Wesley Peng”<wesley@thepeng.eu> 写入:

    on 2019/9/17 9:55, 王佩 wrote:
    > I want to split a stream into any number of streams according to a field,
    > and then process the split stream one by one.
    I think that should be easy done. refer to:
View raw message