Besides the global parallelism of beam job, is there any way to set parallelism for individual operators like group by and join? I understand the parallelism setting depends on the underlying execution engine, but it is very common to set parallelism like group by and join in both spark & flink.
-- Best Regards Jeff Zhang
