RowDataUtils (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.iceberg.sink.utils.RowDataUtils

```
public class RowDataUtils
extends Object
```
Utils for convertion of RowData and DataChangeEvent.

Constructor Summary

Constructors
Constructor Description

RowDataUtils()

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method	Description
`static List<org.apache.flink.table.data.RowData>`	`convertDataChangeEventToRowData(DataChangeEvent dataChangeEvent, List<RecordData.FieldGetter> fieldGetters)`	Convert a `DataChangeEvent` to one or two `RowData`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - RowDataUtils
```
public RowDataUtils()
```
- Method Detail
  - convertDataChangeEventToRowData
```
public static List<org.apache.flink.table.data.RowData> convertDataChangeEventToRowData(DataChangeEvent dataChangeEvent,
                                                                                        List<RecordData.FieldGetter> fieldGetters)
```
    Convert a DataChangeEvent to one or two RowData.
    An UPDATE is split into a DELETE built from the before-image followed by an INSERT built from the after-image, rather than a single after-image row. Iceberg derives both the equality-delete key and the delete's target partition from the row passed to the writer; collapsing an UPDATE to just the after-image (as before) means a partition key change is never deleted from its old partition, leaving a stale duplicate behind.