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

classic Classic list List threaded Threaded
5 messages Options
Reply | Threaded
Open this post in threaded view
|

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

casel.chen
flink sql中如何使用异步io关联维表?官网文档有介绍么?
Reply | Threaded
Open this post in threaded view
|

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

HunterXHunter
定义一个 sourcetable



--
Sent from: http://apache-flink.147419.n8.nabble.com/
Reply | Threaded
Open this post in threaded view
|

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

peibin wang
In reply to this post by casel.chen
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 <[hidden email]> 于2021年3月3日周三 下午10:54写道:

> flink sql中如何使用异步io关联维表?官网文档有介绍么?
Reply | Threaded
Open this post in threaded view
|

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

Leonard Xu
In reply to this post by HunterXHunter
目前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 <[hidden email]> 写道:
>
> 定义一个 sourcetable
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/

Reply | Threaded
Open this post in threaded view
|

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

黑色
In reply to this post by peibin wang
目前是同步来关联的




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2021年3月5日(星期五) 上午10:58
收件人:&nbsp;"user-zh"<[hidden email]&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 <[hidden email]&gt; 于2021年3月3日周三 下午10:54写道:

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