Re: Flink SQL Stream Parser based on calcite

Posted by PedroMrChaves on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-SQL-Stream-Parser-based-on-calcite-tp9592p9596.html

Thank you for the response.

I'm not understanding where does something like this,

SELECT * WHERE action='denied'

gets translated to something similar in the Flink Stream API,

filter.(new FilterFunction<Event>() {
                        public boolean filter(Event event) {
                                return event.action.equals("denied");
                        }
                });

or if that happens at all. My idea was to extend the library to support other unsupported
calls like (TUMBLE -> timeWindow) but it's probably more complex than what I'm thinking.

Regards.