Hi Pedro,
the DataStream program would like this:
val eventData: DataStream[?] = ???
val result = eventData
.filter("action = denied")
.keyBy("user", "ip")
.timeWindow(Time.hours(1))
.apply("window.end, user, ip, count(*)")
.filter("count > 5")
.map("windowEnd, user, ip")
Note, this is just the overall structure. You need to implement a couple of
user functions (basically all operators require a function).
Cheers, Fabian
2016-10-13 12:45 GMT+02:00 PedroMrChaves <[email protected]>:
> Hi,
>
> Thanks for the response.
> What would be the easiest way to do this query using the DataStream API?
>
> Thank you.
>
>
>
>
>
> --
> 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-tp9497p9523.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
