Hi Dongwon,
There was a previous thread regarding this[1], unfortunately this is not
supported yet.
However there are some latest development proposal[2,3] to enhance the
TableAPI which might be able to support your use case.
--
Rong
[1]
http://apache-flink-user-mailing-list-archive.2336050.n4.
Hi all,
I’m looking into Table API for my new project.
It looks like a sweet spot between DataStream API/SQL.
However, it doesn’t seem like the expressivity of Table API equals to that of
DataStream API.
My previous Flink projects were building simple pipelines using DataStream API
with custom