Hi all,

I just wonder can Beam allow to set parallelism for each operator
(PTransform) separately? Flink provides such feature.

The usecase I have is the source is kafka topics, which has less
partitions, while we have heavy PTransform and would like to scale it with
more parallelism.

Thanks a lot!
Eleanore

Reply via email to