[improvement] adding runtime converter array

Open iundarigun opened this issue 7 months ago • 3 comments

Description

In the documentation doesn't mention a way to map between postgres type arrays and flink datatype.

Details

This PR add a way to process arrays. For primitive int and long is tranforming in a primitive array to create the GenericArrayData, and for String, the elements are being wrapped in StringData.

Jun 10 '25 13:06 iundarigun

Hi @Mrart, maybe you can help to review this.

Jun 16 '25 10:06 lvyanquan

Hi @Mrart, maybe you can help to review this.

I will review after https://github.com/apache/flink-cdc/pull/4086.

Aug 17 '25 14:08 Mrart

@iundarigun Can you update the code and add tests case for postgres pipeline to cover this？

Aug 20 '25 12:08 Mrart