Re: How to Join a dimension table in flink sql

2018-01-15 Thread Xingcan
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

Re: How to Join a dimension table in flink sql

2018-01-15 Thread Lin Li
Hi XiangWei, Currently one could implement a udtf to achieve that. (see https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/table/udfs. html#table-functions) BTW, this udtf should carefully dealing with the connections to database server(s), and enable caching if possible can reduce se