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. 


View this message in context:
Sent from the Apache Flink User Mailing List archive. mailing list archive at

Reply via email to