Hi 大龙, 你可以看下这里: https://github.com/apache/flink/blob/master/flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/optimize/program/FlinkChangelogModeInferenceProgram.scala#L213
刘大龙 <ld...@zju.edu.cn> 于2020年5月9日周六 下午2:13写道: > Hi,Benchao, > > 我看TimeBoundedStreamJoin这个类里面并没有限制消息的类型,理论上应该是可以的吧? > > > -----原始邮件----- > > 发件人: "Benchao Li" <libenc...@gmail.com> > > 发送时间: 2020-05-09 11:35:27 (星期六) > > 收件人: user-zh <user-zh@flink.apache.org> > > 抄送: > > 主题: Re: 可撤回流是否可以进行双流 Join? > > > > 你指的是time interval join,还是普通的双流join? > > > > time interval join应该是不能的。一般的双流join应该是可以的。 > > > > LakeShen <shenleifight...@gmail.com> 于2020年5月9日周六 上午11:28写道: > > > > > Hi 各位, > > > > > > 最近有业务需求,需要用到双流 Join (Interval Join),如果两个流中,其中一个流式可撤回流(Retract),或者两个流都是 > > > Retract 流,那么他们还能进行双流 Join 吗? > > > > > > 目前我知道如果两个流是 Append 流的话,肯定可以双流 Join,但是其中一个流式 Retract 流,就不知道还能不能 Join 了。 > > > > > > 期望你的回复。 > > > > > > Best, > > > LakeShen > > > > > > > > > -- > > > > Benchao Li > > School of Electronics Engineering and Computer Science, Peking University > > Tel:+86-15650713730 > > Email: libenc...@gmail.com; libenc...@pku.edu.cn > > > ------------------------------ > 刘大龙 > > 浙江大学 控制系 智能系统与控制研究所 工控新楼217 > 地址:浙江省杭州市浙大路38号浙江大学玉泉校区 > Tel:18867547281 > -- Benchao Li School of Electronics Engineering and Computer Science, Peking University Tel:+86-15650713730 Email: libenc...@gmail.com; libenc...@pku.edu.cn