flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcRowConverter.java [66:89]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        for (int i = 0; i < fieldLogicalTypes.length; i++) {
            toInternalConverters[i] = createNullableInternalConverter(fieldLogicalTypes[i]);
            toExternalConverters[i] = createNullableExternalConverter(fieldLogicalTypes[i]);
        }
    }

    public LogicalType[] getFieldLogicalTypes() {
        return fieldLogicalTypes;
    }

    public RowData toInternal(ResultSet resultSet, String em) throws SQLException {
        GenericRowData genericRowData = new GenericRowData(fieldLogicalTypes.length);

        for (int pos = 0; pos < fieldLogicalTypes.length; pos++) {
            try {
                Object field = resultSet.getObject(pos + 1);
                genericRowData.setField(pos, toInternalConverters[pos].deserialize(field));
            } catch (Exception e) {
                if ("strict".equalsIgnoreCase(em)) {
                    throw e;
                }
            }
        }
        return genericRowData;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/StreamingServerRowConverter.java [63:86]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        for (int i = 0; i < fieldLogicalTypes.length; i++) {
            toInternalConverters[i] = createNullableInternalConverter(fieldLogicalTypes[i]);
            toExternalConverters[i] = createNullableExternalConverter(fieldLogicalTypes[i]);
        }
    }

    public LogicalType[] getFieldLogicalTypes() {
        return fieldLogicalTypes;
    }

    public RowData toInternal(ResultSet resultSet, String em) throws SQLException {
        GenericRowData genericRowData = new GenericRowData(fieldLogicalTypes.length);

        for (int pos = 0; pos < fieldLogicalTypes.length; pos++) {
            try {
                Object field = resultSet.getObject(pos + 1);
                genericRowData.setField(pos, toInternalConverters[pos].deserialize(field));
            } catch (Exception e) {
                if ("strict".equalsIgnoreCase(em)) {
                    throw e;
                }
            }
        }
        return genericRowData;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -