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.