仅供内部使用;没有向后兼容性保证.
此外,DataflowRunner安装了一个ReshuffleOverrideFactory,我不清楚如何改变重组。
无论如何,JavaDoc并没有提到该使用什么。一般情况下,用户应该如何处理高扇和数据流的ParDo转换?
发布于 2020-03-16 12:12:43
您可以在GroupByKey和Combine操作中查看Combine选项。以下是Java https://beam.apache.org/releases/javadoc/2.0.0/org/apache/beam/sdk/transforms/Combine.Globally.html#withFanout-int-的链接
https://stackoverflow.com/questions/60702671
复制相似问题