The lookup fashion Temporal Join[1] should be a solution for your case and
there is an ITCase as an example[2]
[1]
https://github.com/apache/flink/blob/master/flink-table/flink-table-common/src/main/java/org/apache/flink/table/sources/LookupableTableSource.java
[2]
You can try to use UDTF
-- Original --
From: srikanth flink
Hi there,
I'm working with streaming in FlinkSQL. I've two tables created one with
dynamic stream and the other a periodic updates.
I would like to keep the periodic table a static(but updates with new data
every day or so by flushing the old), So at any point of time the static
table should
