flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Welly Tambunan <if05...@gmail.com>
Subject Efficiency for Filter then Transform ( filter().map() vs flatMap() )
Date Thu, 03 Sep 2015 02:33:25 GMT
Hi All,

I would like to filter some item from the event stream. I think there are
two ways doing this.

Using the regular pipeline filter(...).map(...). We can also use flatMap
for doing both in the same operator.

Any performance improvement if we are using flatMap ? As that will be done
in one operator instance.


Welly Tambunan

http://www.triplelands.com <http://www.triplelands.com/blog/>

View raw message