How to Join a dimension table in flink sql

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

How to Join a dimension table in flink sql

XiangWei Huang
Hi all,
   Is it possible to  join records read from a kafka stream with one(or more) dimension tables which are saved as mysql table using flink streaming sql.
Reply | Threaded
Open this post in threaded view
|

Re: How to Join a dimension table in flink sql

Xingcan Cui

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. 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 tables which are saved as mysql table using flink streaming sql.