Efficiency for Filter then Transform ( filter().map() vs flatMap() )
Posted by
tambunanw on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Efficiency-for-Filter-then-Transform-filter-map-vs-flatMap-tp2644.html
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.