Re: 流与流 left join

2021-06-14 文章 刘建刚 
https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/dev/table/sql/queries/joins/#interval-joins

chenchencc <1353637...@qq.com> 于2021年6月15日周二 上午9:46写道：

> 你好，谢谢哈，想问下有相关的资料或者案例能发下吗？
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-06-14 文章 chenchencc 
你好，想问下有什么案例或者资料吗



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-06-14 文章 chenchencc 
你好，谢谢哈，想问下有相关的资料或者案例能发下吗？



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-05-31 文章 LakeShen 
Hi，或许 Flink SQL  interval join 能够满足你的需求。

Best，
LakeShen.

Shuo Cheng  于2021年5月31日周一 下午12:10写道：

> state ttl 只能是全局算子维度, table.exec.state.ttl
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

Re: 流与流 left join

2021-05-30 文章 Shuo Cheng 
state ttl 只能是全局算子维度, table.exec.state.ttl



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-05-28 文章 chenchencc 
恩恩，单表table 有什么方式能设置ttl吗？



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-05-28 文章 chenchencc 
恩恩，是可以的
，但是有些缺点
1.B表本身是维表属性，inter join B表如果有重复数据，会造成数据冗余
2.inter join 会有大量多余state数据



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-05-27 文章 Shuo Cheng 
我理解双流 Join 就能满足需求吧, 缺点是数据全量放 state，只能靠 state ttl 来清理数据

On 5/27/21, chenchencc <1353637...@qq.com> wrote:
> 想问下cep sql批处理能使用吗？想流批一体的。
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

Re: 流与流 left join

2021-05-27 文章 chenchencc 
想问下cep sql批处理能使用吗？想流批一体的。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-05-27 文章 chenchencc 
好的，谢谢。
想问下如果使用普通sql有啥其他方式吗。如果定义版本维度表可以吗



--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-05-27 文章 JasonLee 
Hi
可以看下 interval join 是否能满足你的需求



-
Best Wishes
JasonLee
--
Sent from: http://apache-flink.147419.n8.nabble.com/

Re: 流与流 left join

2021-05-27 文章 jinghuiwang 
sql可以定义cep，捕获匹配流和超时流

发自我的iPhone

> 在 2021年5月27日，下午7:40，流弊 <1353637...@qq.com> 写道：
> 
> 我们现在场景有两个流join，A流left joinB流，A流比B流晚到，而且最晚比B流晚到3小时，用flink sql有啥方法实现吗？

流与流 left join

2021-05-27 文章 流弊 
我们现在场景有两个流join，A流left joinB流，A流比B流晚到，而且最晚比B流晚到3小时，用flink sql有啥方法实现吗？