Hi Haohui,
sorry for the delayed reply.
Defining joins and windowing on streams with SQL is certainly on the road
map of Flink.
However, the challenge here is not so much in mapping RelNodes to Flink's
DataStream operators.
It is rather to have the right SQL syntax and semantics to define common
Hi Fabian,
Thanks for the reply. The design document is quite interesting down the
road.
For our business needs we are interested in adding supports like windowing
and joins in the streaming SQL part. The question is that how does it fit
in the long-term road map? I quickly skimmed through the co
Hi Haohui,
the Flink community started about a year ago to port its Table API on top
of Apache Calcite and finalized the integration in June.
Now, Calcite is the central component of Flink's relational APIs. Flink
features SQL and the Table API, a language-integrated query (LINQ) API.
Both APIs ar
Hi,
We are currently exploring on building a streaming SQL solution on top of
Flink. We think that Flink is a good fit for the problem.
I'm curious about what is the status on the Flink-Calcite integration right
now? Is it being actively developed and on the road map?
We are also very open to co
