Hi +1 for vino's answer. Also, this kind of join will be supported in FLINK-9712 <https://issues.apache.org/jira/browse/FLINK-9712>. You can check more details in the jira.
Best, Hequn On Fri, Sep 21, 2018 at 4:51 PM vino yang <yanghua1...@gmail.com> wrote: > Hi Henry, > > There are three ways I can think of: > > 1) use DataStream API, implement a flatmap UDF to access dimension table; > 2) use table/sql API, implement a UDTF to access dimension table; > 3) customize the table/sql join API/statement's implementation (and change > the physical plan) > > Thanks, vino. > > 徐涛 <happydexu...@gmail.com> 于2018年9月21日周五 下午4:43写道： > >> Hi All, >> Sometimes some “dimension table” need to be joined from the "fact >> table", if data are not joined before sent to Kafka. >> So if the data are joined in Flink, does the “dimension table” >> have to be import as a stream, or there are some other ways can achieve it? >> Thanks a lot! >> >> Best >> Henry > >
