flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: filter().project() vs flatMap()
Date Mon, 04 May 2015 12:53:30 GMT
Thanks Sebastian and Fabian for the feedback, just one last question:
what does change from the system point of view to know that the  output
tuples is <= the number of input tuples?
Is there any optimization that Flink can apply to the pipeline?

On Mon, May 4, 2015 at 2:49 PM, Fabian Hueske <fhueske@gmail.com> wrote:

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

Mime
View raw message