apache-beam - FlinkRunner 上 Apache Beam GroupByKey.create() 的可迭代输出类型
问题描述
Apache-Beam GroupByKey.create() 转换的输出是 PCollection< KV< K,Iterable< V>>>。
当我使用 FlinkRunner (batch mode)运行代码时，我看到 Iterable< V> 是一个 ArrayList。
这是否意味着每个键的分组元素必须适合内存？
解决方案
推荐阅读
- javascript - TypeError: Attempting to change enumerable attribute of unconfigurable property (Vue.js SPA)(Webpack 4)(iPhone 6S)(iOS Safari)
- spring-boot - RabbitMQ 的延迟功能不起作用
- c# - 对对象副本所做的更改反映在原始对象中
- python - Python：使用正向前瞻删除标点符号之间的空格
- java - 当editText在另一个onclick内时，如何在editText字段上使用getText（）？
- c# - 从插入的多个设备中检索使用过的条形码阅读器
- macros - 如何匹配宏中的特征边界？
- javascript - 折叠后隐藏按钮使用 Javascript 切换
- vba - 节标题 Range.Text 返回空字符串而不是实际文本
- php - imgur 通过 api 删除图像