You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by "casel.chen" <ca...@126.com> on 2021/03/03 14:54:29 UTC

flink sql中如何使用异步io关联维表？

flink sql中如何使用异步io关联维表？官网文档有介绍么？

Re:Re: flink sql中如何使用异步io关联维表？

Posted by Michael Ran <gr...@163.com>.
Hello，咨询一下，目前connector-hbase 的异步join，是能保证顺序的吗？
在 2021-03-05 11:10:41，"Leonard Xu" <xb...@gmail.com> 写道：
>目前Flink SQL 中的connector都没实现异步io关联维表，接口是上已经支持了的，如果是自己实现可以参考[1]
>另外，HBase connector 社区有人正在支持异步io关联维表，预计1.13可以使用[2]
>
>祝好
>
>[1]https://github.com/apache/flink/blob/73cdd3d0d9f6a807b3e47c09eef7983c9aa180c7/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesRuntimeFunctions.java#L618
>[2] https://github.com/apache/flink/pull/14684#pullrequestreview-604148209 <https://github.com/apache/flink/pull/14684#pullrequestreview-604148209>
>
>
>
>> 在 2021年3月4日，14:22，HunterXHunter <13...@qq.com> 写道：
>> 
>> 定义一个 sourcetable
>> 
>> 
>> 
>> --
>> Sent from: http://apache-flink.147419.n8.nabble.com/
>

Re: flink sql中如何使用异步io关联维表？

Posted by Leonard Xu <xb...@gmail.com>.
目前Flink SQL 中的connector都没实现异步io关联维表，接口是上已经支持了的，如果是自己实现可以参考[1]
另外，HBase connector 社区有人正在支持异步io关联维表，预计1.13可以使用[2]

祝好

[1]https://github.com/apache/flink/blob/73cdd3d0d9f6a807b3e47c09eef7983c9aa180c7/flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/factories/TestValuesRuntimeFunctions.java#L618
[2] https://github.com/apache/flink/pull/14684#pullrequestreview-604148209 <https://github.com/apache/flink/pull/14684#pullrequestreview-604148209>



> 在 2021年3月4日，14:22，HunterXHunter <13...@qq.com> 写道：
> 
> 定义一个 sourcetable
> 
> 
> 
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

Re: flink sql中如何使用异步io关联维表？

Posted by HunterXHunter <13...@qq.com>.
定义一个 sourcetable



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

回复： flink sql中如何使用异步io关联维表？

Posted by 黑色 <xi...@qq.com>.
目前是同步来关联的




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <wangpeibin713@gmail.com&gt;;
发送时间:&nbsp;2021年3月5日(星期五) 上午10:58
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Re: flink sql中如何使用异步io关联维表？



https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/streaming/legacy.html#temporal-table-function-join
flink sql的 temporal-table join 应该都是通过异步io来关联维表的

casel.chen <casel_chan@126.com&gt; 于2021年3月3日周三 下午10:54写道：

&gt; flink sql中如何使用异步io关联维表？官网文档有介绍么？

Re: flink sql中如何使用异步io关联维表？

Posted by peibin wang <wa...@gmail.com>.
https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/streaming/legacy.html#temporal-table-function-join
flink sql的 temporal-table join 应该都是通过异步io来关联维表的

casel.chen <ca...@126.com> 于2021年3月3日周三 下午10:54写道：

> flink sql中如何使用异步io关联维表？官网文档有介绍么？