Function group_by_key

利用给定的PCollection，使用一个默认的key/value提取函数对输入的PCollection分组 ，返回一个表示分组的PTable Args: pcollection (PCollection): 输入PCollection **options: 可配置选项 Returns: PTable: 分组结果 >>> _p = _pipeline.parallelize([("A", 4), ("A", 3), ("B", 2), ("A", 1)]) >>> transforms.group

(pcollection, **options)