fluss-lakehouse/fluss-lakehouse-paimon/src/main/java/com/alibaba/fluss/lakehouse/paimon/source/utils/FlussRowToFlinkRowConverter.java [57:65]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private RowData toFlinkRowData(InternalRow flussRow, RowKind rowKind) {
        GenericRowData genericRowData = new GenericRowData(toFlinkFieldConverters.length);
        genericRowData.setRowKind(rowKind);
        for (int i = 0; i < toFlinkFieldConverters.length; i++) {
            Object flussField = flussFieldGetters[i].getFieldOrNull(flussRow);
            genericRowData.setField(i, toFlinkFieldConverters[i].deserialize(flussField));
        }
        return genericRowData;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



fluss-flink/fluss-flink-common/src/main/java/com/alibaba/fluss/flink/utils/FlussRowToFlinkRowConverter.java [66:74]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private RowData toFlinkRowData(InternalRow flussRow, RowKind rowKind) {
        GenericRowData genericRowData = new GenericRowData(toFlinkFieldConverters.length);
        genericRowData.setRowKind(rowKind);
        for (int i = 0; i < toFlinkFieldConverters.length; i++) {
            Object flussField = flussFieldGetters[i].getFieldOrNull(flussRow);
            genericRowData.setField(i, toFlinkFieldConverters[i].deserialize(flussField));
        }
        return genericRowData;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -