由于 Hadoop 计数器大小有限制（我们不想只为一项工作增加它），我正在创建一个映射（Map），如果满足某些条件（与计数器相同），它将增加键。已经有一个 DoFn（返回自定义对象）正在处理数据，所以我有兴趣将地图传递到其中并根据键将其分组到外部。我认为 concurrenthashmap 可能有效，但无法实现。
由于 Hadoop 计数器大小有限制（我们不想只为一项工作增加它），我正在创建一个映射（Map），如果满足某些条件（与计数器相同），它将增加键。已经有一个 DoFn（返回自定义对象）正在处理数据，所以我有兴趣将地图传递到其中并根据键将其分组到外部。我认为 concurrenthashmap 可能有效，但无法实现。