Flink SplitStream的简单使用

Flink SplitStream的简单使用 在Flink DataStream api中有一个split()算子,它的功能是将一个Stream,经过split()设置多个标记,划分红多个流。再经过select()获取对应标记的流。web 像种算子,能够根据不一样的tag,进行不一样的逻辑处理,可谓是很是的方便。bootstrap 具体看代码:api public class SplitOpera
相关文章
相关标签/搜索