flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hery168 <hery...@163.com>
Subject flink dataset 分组后拼接分组后内容
Date Tue, 28 Apr 2020 09:24:10 GMT
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....
请问大家这个该怎么实现?
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message