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 <pedro.mr.cha...@gmail.com>:

> 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.
>

Reply via email to