At what point does it not make sense anymore to perform all steps of an operation on a single partition of data together?
Is there a point of diminishing returns?
I've seen some stream processing systems follow the partition data and apply all transformations at once (e.g. Kafka Streams) while others parallelize the transformations (e.g. Apache Storm IIRC).
Also isn't there a tradeoff that in a depth-first (for lack of better term) processing paradigm error-recovery becomes more costly?