Flink SQL Stream Parser based on calcite

Posted by PedroMrChaves on Oct 17, 2016; 2:43pm
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-SQL-Stream-Parser-based-on-calcite-tp9592.html

Hello,

I am pretty new to Apache Flink.

I am trying to figure out how does Flink parses an Apache Calcite sql query to its own Streaming API in order to maybe extend it, because, as far as I know, many operations are still being developed and not currently supported (like TUMBLE windows). I need to be able to load rules from a file , like so:

tableEnv.sql([File])..

in order to do that I need a fully functional Streaming SQL parser.

I am currently analyzing the StreamTableEnvironment class from github [1] in order to understand the method sql but I can't figure out where does the parsing happens.

Can someone point me in the right direction?


[1] https://github.com/apache/flink/blob/d7b59d761601baba6765bb4fc407bcd9fd6a9387/flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/StreamTableEnvironment.scala

Best Regards,
Pedro Chaves