当前位置:   article > 正文

flink中split与select操作_flink split select

flink split select

前言

在某些场景下,从一个原始文件中读取到的输入流,放在一起处理的话可能会带来操作上的不便,比如,电商网站中对一批用户行为日志进行分析时,需要根据不同的标签做过滤,如果转换成输入流之后统一处理的话,就不太好

flink中提供了split相关的API方便开发者对原始的流进行拆分,同时也提供了select流对多个不同渠道的流进行选择性处理

Split操作

顾名思义,split即为拆分,将一条流拆分成多条流,DataStream SplitStream:根据某些特征把一个 DataStream 拆分成两个或者

多个 DataStream

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/Cpp五条/article/detail/639072
推荐阅读
相关标签
  

闽ICP备14008679号