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

[nickitat]

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