flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Benchao Li <libenc...@gmail.com>
Subject Re: Re: 可撤回流是否可以进行双流 Join?
Date Sat, 09 May 2020 06:22:46 GMT
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

刘大龙 <ldliu@zju.edu.cn> 于2020年5月9日周六 下午2:13写道:

> Hi,Benchao,
>
> 我看TimeBoundedStreamJoin这个类里面并没有限制消息的类型,理论上应该是可以的吧?
>
> > -----原始邮件-----
> > 发件人: "Benchao Li" <libenchao@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 <shenleifighting@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: libenchao@gmail.com; libenchao@pku.edu.cn
>
>
> ------------------------------
> 刘大龙
>
> 浙江大学 控制系 智能系统与控制研究所 工控新楼217
> 地址:浙江省杭州市浙大路38号浙江大学玉泉校区
> Tel:18867547281
>


-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message