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有啥方法实现吗?