Enforce higher pipeline parallelism of later plan steps when the number of reading streams is low

Noticeable when there are not so many rows with heavy aggregate function states. Because we create as many AggregatingTransforms as there are input reading streams we deteriorate performance (more granular parallelisation would be in fact useful since processing of each row is computationally nontrivial).