回复： blink sql中如何清除state中的数据

[492341344 <ww...@qq.com>]

我觉得应该不行，原因有两点：1.淘汰时间设置多少不确定。2.会淘汰其他没有被delete的数据,但是这些数据很久没更新过。
------------------ 原始邮件 ------------------
发件人: "greemqqran"<gr...@163.com>;
发送时间: 2019年3月23日(星期六) 上午8:53
收件人: "492341344"<ww...@qq.com>;
抄送: "user-zh"<us...@flink.apache.org>; 
主题: 回复: blink sql中如何清除state中的数据



用时间淘汰可行不？



发自vivo智能手机
> 你好，实时数仓中A,B两个表join,如果A是一条带有delete操作的数据过来，与B表中的某条数据能join上， 
> 请问怎么把A表中state存的那条数据清除掉，不清除的话，如果B表中来一条数据就能跟A那条delete的数据 
> join上，我想要的是不能join上。

回复： blink sql中如何清除state中的数据

[492341344 <ww...@qq.com>]

感谢各位回复："B 可以带上一个 delete 的标记, join 之后用 where 过滤掉
" 可以解决我的问题。是不是table/sql api中，没提供像datastream这样精确控制state的接口了吗？




------------------ 原始邮件 ------------------
发件人: "Moxingxing Lei"<mo...@gmail.com>;
发送时间: 2019年3月25日(星期一) 上午9:35
收件人: "user-zh"<us...@flink.apache.org>;

主题: Re: blink sql中如何清除state中的数据



B 可以带上一个 delete 的标记, join 之后用 where 过滤掉

492341344 <ww...@qq.com> 于2019年3月25日周一 上午9:23写道：

> 我觉得应该不行，原因有两点：1.淘汰时间设置多少不确定。2.会淘汰其他没有被delete的数据,但是这些数据很久没更新过。
> ------------------ 原始邮件 ------------------
> 发件人: "greemqqran"<gr...@163.com>;
> 发送时间: 2019年3月23日(星期六) 上午8:53
> 收件人: "492341344"<ww...@qq.com>;
> 抄送: "user-zh"<us...@flink.apache.org>;
> 主题: 回复: blink sql中如何清除state中的数据
>
>
>
> 用时间淘汰可行不？
>
>
>
> 发自vivo智能手机
> > 你好，实时数仓中A,B两个表join,如果A是一条带有delete操作的数据过来，与B表中的某条数据能join上，
> > 请问怎么把A表中state存的那条数据清除掉，不清除的话，如果B表中来一条数据就能跟A那条delete的数据
> > join上，我想要的是不能join上。

Re: blink sql中如何清除state中的数据

[Moxingxing Lei <mo...@gmail.com>]

B 可以带上一个 delete 的标记, join 之后用 where 过滤掉

492341344 <ww...@qq.com> 于2019年3月25日周一 上午9:23写道：

> 我觉得应该不行，原因有两点：1.淘汰时间设置多少不确定。2.会淘汰其他没有被delete的数据,但是这些数据很久没更新过。
> ------------------ 原始邮件 ------------------
> 发件人: "greemqqran"<gr...@163.com>;
> 发送时间: 2019年3月23日(星期六) 上午8:53
> 收件人: "492341344"<ww...@qq.com>;
> 抄送: "user-zh"<us...@flink.apache.org>;
> 主题: 回复: blink sql中如何清除state中的数据
>
>
>
> 用时间淘汰可行不？
>
>
>
> 发自vivo智能手机
> > 你好，实时数仓中A,B两个表join,如果A是一条带有delete操作的数据过来，与B表中的某条数据能join上，
> > 请问怎么把A表中state存的那条数据清除掉，不清除的话，如果B表中来一条数据就能跟A那条delete的数据
> > join上，我想要的是不能join上。