可撤回流是否可以进行双流 Join？

[LakeShen]

Hi 各位，

最近有业务需求，需要用到双流 Join (Interval Join)，如果两个流中，其中一个流式可撤回流（Retract），或者两个流都是
Retract 流，那么他们还能进行双流 Join 吗？

目前我知道如果两个流是 Append 流的话，肯定可以双流 Join，但是其中一个流式 Retract 流，就不知道还能不能 Join 了。

期望你的回复。

Best,
LakeShen

[Benchao Li]

你指的是time interval join，还是普通的双流join？

time interval join应该是不能的。一般的双流join应该是可以的。

LakeShen <[hidden email]> 于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:[phone]
Email: [hidden email]; [hidden email]

[刘大龙]

Hi,Benchao,
 
我看TimeBoundedStreamJoin这个类里面并没有限制消息的类型，理论上应该是可以的吧？

> -----原始邮件-----
> 发件人: "Benchao Li" <[hidden email]>
> 发送时间: 2020-05-09 11:35:27 (星期六)
> 收件人: user-zh <[hidden email]>
> 抄送:
> 主题: Re: 可撤回流是否可以进行双流 Join？
>
> 你指的是time interval join，还是普通的双流join？
>
> time interval join应该是不能的。一般的双流join应该是可以的。
>
> LakeShen <[hidden email]> 于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:[phone]
> Email: [hidden email]; [hidden email]

------------------------------
刘大龙

浙江大学 控制系 智能系统与控制研究所 工控新楼217
地址：浙江省杭州市浙大路38号浙江大学玉泉校区
Tel：[phone]

[Benchao Li]

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

刘大龙 <[hidden email]> 于2020年5月9日周六 下午2:13写道：

> Hi,Benchao,
>
> 我看TimeBoundedStreamJoin这个类里面并没有限制消息的类型，理论上应该是可以的吧？
>
> > -----原始邮件-----
> > 发件人: "Benchao Li" <[hidden email]>
> > 发送时间: 2020-05-09 11:35:27 (星期六)
> > 收件人: user-zh <[hidden email]>
> > 抄送:
> > 主题: Re: 可撤回流是否可以进行双流 Join？
> >
> > 你指的是time interval join，还是普通的双流join？
> >
> > time interval join应该是不能的。一般的双流join应该是可以的。
> >
> > LakeShen <[hidden email]> 于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:[phone]
> > Email: [hidden email]; [hidden email]
>
>
> ------------------------------
> 刘大龙
>
> 浙江大学 控制系 智能系统与控制研究所 工控新楼217
> 地址：浙江省杭州市浙大路38号浙江大学玉泉校区
> Tel：[phone]
>

--

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:[phone]
Email: [hidden email]; [hidden email]