flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: filter().project() vs flatMap()
Date Mon, 04 May 2015 12:49:08 GMT
It should not make a difference. I think its just personal taste.

If your filter condition is simple enough, I'd go with Flink's Table API
because it does not require to define a Filter or FlatMapFunction.

2015-05-04 14:43 GMT+02:00 Flavio Pompermaier <pompermaier@okkam.it>:

> Hi Flinkers,
> I'd like to know whether it's better to perform a filter.project or a
> flatMap to filter tuples and do some projection after the filter.
> Functionally they are equivalent but maybe I'm ignoring something..
> Thanks in advance,
> Flavio

View raw message