flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jark Wu" <wuchong...@alibaba-inc.com>
Subject Re: applying where after group by in dataset
Date Thu, 18 Aug 2016 02:10:58 GMT
Hi,

You can only apply aggregate after groupBy. But you can apply filter before groupBy.

So you can do like this:  

distancePoints.filter(filterFunction).groupBy(1)


- Jark Wu 

> 在 2016年8月17日,下午5:29,subash basnet <yasubash@gmail.com> 写道:
> 
> here


Mime
View raw message