Hi Pedro, The sql() method calls the Calcite parser in line 129.
Best, Fabian 2016-10-17 16:43 GMT+02:00 PedroMrChaves <pedro.mr.cha...@gmail.com>: > 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/d7b59d761601baba6765bb4fc407bc > d9fd6a9387/flink-libraries/flink-table/src/main/scala/ > org/apache/flink/api/table/StreamTableEnvironment.scala > <https://github.com/apache/flink/blob/d7b59d761601baba6765bb4fc407bc > d9fd6a9387/flink-libraries/flink-table/src/main/scala/ > org/apache/flink/api/table/StreamTableEnvironment.scala> > > Best Regards, > Pedro Chaves > > > > > > -- > View this message in context: http://apache-flink-user- > mailing-list-archive.2336050.n4.nabble.com/Flink-SQL- > Stream-Parser-based-on-calcite-tp9592.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
