Re: Som question about Flink stream sql

Posted by Fabian Hueske-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Som-question-about-Flink-stream-sql-tp10850p10858.html

Hi Yuhong,

as you noticed, FLIP-11 is about the window operations on the Table API and does not include SQL.

The reason is that the Table API is completely Flink domain, i.e., we can design and implement the API. For SQL we have a dependency on Calcite.

You are right, that Calcite's JIRA issue for group windows [1] seems to be stale. I don't have more information on that. You could ping there and ask what the status is.

Row windows are already supported by Calcite (SQL's OVER and WINDOW clauses), so these could be implemented for SQL as well.

Maybe it's even easier to start from the SQL side and add the Table API later to ensure a compatible compilation process.

Best, Fabian

2017-01-05 4:40 GMT+01:00 Hongyuhong <[hidden email]>:

Hi,

We are currently exploring on Flink streamsql ,

And I see the group-window has been implemented in Table API, and row-window is also planning in FLIP-11. It seems that row-window grammar is more similar to calcite over clause.

I’m curious about the detail plan and roadmap of stream sql, cause FLIP-11 just mentioned Table API.

And is that streamsql priority implement row-window? Or if group-window is considered, what is the status on calcite integration?

The issue on calcite jira was raised in August, what’s the status right now?

Thanks in advance!

 

Regards

Yuhong