Re: Split a stream into any number of streams

Mon, 16 Sep 2019 22:33:59 -0700 

可以使用Side Output, 
将输入流根据不同需求发送到自定义的不同的OutputTag中,最后可以使用DataStream.getSideOutput(outputTag)取出你需要的流进行处理!

在 2019/9/17 上午10:05，“Wesley Peng”<[email protected]> 写入:

    
    
    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:
    
https://stackoverflow.com/questions/53588554/apache-flink-using-filter-or-split-to-split-a-stream
    
    regards.

回复