how to split a column value into multiple rows in flink sql?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

how to split a column value into multiple rows in flink sql?

1095193290@qq.com
Hi
  For example , a table like this:
   A     B      C
  ------------------
   a1   b1    c1,c2,c3
  -------------------
  how to split c1,c2,c3 into multiple rows like this in flink sql function:
A  B   C
--------
a1  b1  c1
a1  b1  c2
a1  b1  c3 
Thank you


Reply | Threaded
Open this post in threaded view
|

Re: how to split a column value into multiple rows in flink sql?

Yik San Chan
Hi,

Maybe try row-based flatMap operation in table api. It is available on flink
1.13.x

https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/tableapi/#flatmap

Best,
Yik San



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/