filter + project is easier to understand for the system, as the number of output tuples is guaranteed to be <= the number of input tuples. With flatMap, the system cannot know an upper bound.

--sebastian

On 04.05.2015 14:43, Flavio Pompermaier wrote:
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

Reply via email to