flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Xingcan <xingc...@gmail.com>
Subject Re: How to Join a dimension table in flink sql
Date Mon, 15 Jan 2018 13:04:03 GMT
Hi XiangWei,

Unfortunately, it's not possible for the Flink SQL API to join a stream 
with a common dataset now. As a workaround, if the table is just a tiny 
one, you can achieve a inner/left outer join with the user defined table 
functions 
<https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/table/sql.html#joins>.

Note that due to some reasons, the UDTF left outer join cannot support 
arbitrary conditions now.

Hope that helps.

Best,

Xingcan

On 15/01/2018 6:11 PM, XiangWei Huang wrote:
> Hi all,
> Is it possible to  join records read from a kafka stream with one(or 
> more) dimension tableswhich are saved as mysql table using flink 
> streaming sql.


Mime
View raw message