Re: Joining streamed data to reference data

2018-07-20 Thread Dawid Wysakowicz
Hi James, 1) Unfortunately, Flink does not support DataSet with DataStream joins as of now. If the "batch" table is small enough you might try the solution suggested by Vino to load it in the UDTF. You can also try implementing the Stream version of this table yourself. You can use the org.apache.

Re: Joining streamed data to reference data

2018-07-20 Thread vino yang
Hi Porritt, Flink does not support streaming and batch join, currently, streaming and batch job are both independent. I guess your use case is streaming and dimension table join? Unfortunately, it's not possible for the Flink SQL API to join a stream with a common dataset now. 1) As a workaround