flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Error with table sql query - No match found for function signature TUMBLE(<TIME>, <INTERVAL_DAY_TIME>)
Date Thu, 13 Oct 2016 13:08:25 GMT
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.chaves@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.
>

Mime
View raw message