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.