Hello,

We have an application that uses a custom ResultExtractor to process
ResultSet. By the contract of ResultSet, the cursor points before the first
row. A typical ResultSetExtractor iterates through a loop starting for
moving the cursor first.

However,
https://github.com/apache/flink-connector-jdbc/blob/main/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/reader/extractor/ResultExtractor.java
 expects the cursor to the current row and only process one row.

This breaks the contract of ResultSet. Can we change the design that the
iteration happens in the ResultExtractor or call it a RowMapper and takes a
row instead of ResultSet? Are there existing custom ResultExtractors that
will be broken by this change?

Thanks,

Clara Xiong

Reply via email to