context.output(channelOutputTag,String.valueOf(arrData(0)))
> context.output(eventOutputTag,arrData(1))
>
> }
> })
>
> val xStream = ouputStream.getSideOutput(xOutputTag)
> val xxStream = ouputStream.getSideOutput(xxOutputTag)
>
> Best,
> YunKillere
>
> _
日 19:26
收件人: user-zh@flink.apache.org
主题: 答复: flink疑问
使用 Split 算子把流根据特定条件拆分成两个或者更多，然后在用select算子从拆分流中选择对应的拆分流做处理即可。
可以看看文档上，有介绍用法
https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/
发件人: baiyg25...@hundsun.com
发送时间: 2019年3月26日 10:10
收件人: user-zh
主题: 回复: flink疑问
一个算子出来两个流好像不能吧。
要想实现你
split之后 做 select
> 在 2019年3月26日，上午10:09，baiyg25...@hundsun.com 写道：
>
> 一个算子出来两个流好像不能吧。
> 要想实现你说的，可以先基于A流过滤生成要进行B算子的流，基于A流过滤生成要进行C算子的流。
>
>
>
> baiyg25...@hundsun.com
>
> 发件人： IORI
> 发送时间： 2019-03-26 09:46
> 收件人： user-zh
> 主题： flink疑问
> 请问：数据流通过算子A时
使用 Split 算子把流根据特定条件拆分成两个或者更多，然后在用select算子从拆分流中选择对应的拆分流做处理即可。
可以看看文档上，有介绍用法
https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/operators/
发件人: baiyg25...@hundsun.com
发送时间: 2019年3月26日 10:10
收件人: user-zh
主题: 回复: flink疑问
一个算子出来两个流好像不能吧。
要想实现你说的，可以先基于A流过滤生成要进行B算子的流，基于A流过滤生成要进行C算子的流
split
吴志新高级Java开发
商业计算部http://pic.mmkj.site/360.jpg"; width="180"
height="25"> 中国 北京 朝阳区农展馆南路13号 瑞辰国际中心8层8F,
Ruichen Int'l Center, No. 13, Nongzhanguan South Rd, Chaoyang District,
Beijing, China M /手机 E / 邮箱 H /
网址13141163261wuzhi...@wecash.netwww.abakus.cn
