赞
踩
在某些场景下,从一个原始文件中读取到的输入流,放在一起处理的话可能会带来操作上的不便,比如,电商网站中对一批用户行为日志进行分析时,需要根据不同的标签做过滤,如果转换成输入流之后统一处理的话,就不太好
flink中提供了split相关的API方便开发者对原始的流进行拆分,同时也提供了select流对多个不同渠道的流进行选择性处理
Split操作
顾名思义,split即为拆分,将一条流拆分成多条流,DataStream → SplitStream:根据某些特征把一个 DataStream 拆分成两个或者
赞
踩
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。