Hey guys, I have a question, does withkeys transformation enforce a reshuffle?
My pipeline basically look like this PubsubLiteIO -> ParDo(..) -> ParDo() -> BigqueryIO.write() The problem is PubsubLiteIO -> ParDo(..) -> ParDo() always fused together. But The ParDo is expensive and I want dataflow to have more workers to work on that, what's the best way to do that? Regards,