Beam 中的 groupbykey 功能

Does groupbykey functionality in Beam

我们需要使用 groupbykey 来实现功能

KV < ID , <对象列表> > 喜欢

KV <1, < obj1,obj2 >>

请问 groupbykey 在 Spark runner 中是否有效。根据能力矩阵不支持,但根据以下 link 支持。

https://issues.apache.org/jira/browse/BEAM-799

谢谢

如果您在功能矩阵上按 "expand details",您可以看到 Spark 运行程序支持 GroupByKey,并附注:

Partially: fully supported in batch mode

Using Spark's groupByKey. GroupByKey with multiple trigger firings in streaming mode is a work in progress.