flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/utils/JdbcRowConverter.java [76:90]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    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 [73:87]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    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;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -