You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@calcite.apache.org by "Wanglan (Lan)" <la...@huawei.com> on 2016/01/30 07:22:31 UTC

About Stream SQL

Hi to all,

I am from Huawei and am focusing on data stream processing.
Recently I noticed that both in Storm community and Flink community there are endeavors to user Calcite as SQL parser to enable Storm/Flink to support SQL. They both want to supplemented or clarify Streaming SQL of calcite, especially the definition of windows.
I am considering if both communities working on designing Stream SQL syntax separately, there would come out two different syntaxes which represent the same use case.
Therefore, I am wondering if it is possible to unify such work, i.e. design and compliment the calcite Streaming SQL to enrich window definition so that both storm and flink can reuse the calcite(Streaming SQL) as their SQL parser for streaming cases with little change.
What do you think about this idea?