flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From PedroMrChaves <pedro.mr.cha...@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 12:37:09 GMT
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