apply() accepts a WindowFunction which is essentially the same as a GroupReduceFunction, i.e., you have an iterator over all events in the window. If you only want to count, you should have a look at incremental window aggregation with a ReduceFunction or FoldFunction [1].
Best, Fabian [1] https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/windows.html#windowfunction-with-incremental-aggregation 2016-10-13 14:37 GMT+02:00 PedroMrChaves <pedro.mr.cha...@gmail.com>: > 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. >
