Hello I have a question. If I have a transform for each input it will emit 1 or many output (same collection) I can do it with ParDo + DoFun while in processElement method for each input, call context.output multiply times vs doing it with FlatMapElements, is there any difference? Does the dataflow fuse the downstream transform automatically? Eventually I want more downstream transform workers cause it needs to handle more data, How do I supposed to do that?
Regards, Siyuan
