You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 邓成刚【qq】 <bn...@qq.com> on 2019/03/26 02:26:11 UTC

回复: 回复: flink疑问

DataStream ds = ....


DataStream ds1 = 直接拿ds 做 B操作                生成的新流，SINK或其它的，你想干什么都可以，

DataStream ds2 = 直接拿ds 做 C操作                生成的新流，SINK或其它的，你想干什么都可以，


在DS1，DS2里，DS是同一个流。。。就像SQL中的表一样，它们是一样的东东，其实就是复用，你可以试试。。。


邓成刚【qq】
 
发件人： baiyg25281@hundsun.com
发送时间： 2019-03-26 10:09
收件人： user-zh
主题： 回复: flink疑问
一个算子出来两个流好像不能吧。
要想实现你说的，可以先基于A流过滤生成要进行B算子的流，基于A流过滤生成要进行C算子的流。
 
 
 
baiyg25281@hundsun.com
发件人： IORI
发送时间： 2019-03-26 09:46
收件人： user-zh
主题： flink疑问
请问：数据流通过算子A时，我想分裂成两个数据流，一个数据流进行算子B操作然后sink,另外一个数据流需要先进行算子C操作，再reduce然后sink，请问这种情况应该如何处理？一个operator中能出来两个不同的数据流吗？