flink dataset 分组后拼接分组后内容

[hery168]

col1 col2 pid 

1.0  2.0  1

2.0  2.0  1

1.0  2.0  1

3.0  2.0  1

1.0  2.0  1

1.0  2.0  2

1.0  2.0  2

1.0  2.0  2

1.0  2.0  2

1.0  2.0  2
各位大神，想问一下利用flink dataset 对pid 列进行分组，然后对分组后的col1列的内容进行拼接，如1.0#2.0#1.0#3.0....
请问大家这个该怎么实现？