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
in order to do that I need a fully functional Streaming SQL parser.
I am currently analyzing the StreamTableEnvironment class from github  in
order to understand the method sql but I can't figure out where does the
Can someone point me in the right direction?
View this message in context:
Sent from the Apache Flink User Mailing List archive. mailing list archive at