I have this so far:

result = eventData
                                .filter(new FilterFunction<Event>(){
                                        public boolean filter(Event event){
                                                return 
event.action.equals("denied");
                                        }
                                })
                                .keyBy(0)
                                .timeWindow(Time.seconds(10))
                                .apply("???")
                                .filter(new FilterFunction<Integer>(){
                                        public boolean filter(Integer count){
                                                return count.intValue() > 5
                                        }
                                });

I don't know what can I put in the apply function in order to the count of
pairs (user,ip ) whose action="denied.

Regards.



--
View this message in context: 
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Error-with-table-sql-query-No-match-found-for-function-signature-TUMBLE-TIME-INTERVAL-DAY-TIME-tp9497p9526.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at 
Nabble.com.

Reply via email to