And process the rows in a flatmap in parallel
# rx
a
And process the rows in a flatmap in parallel