in flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/internal/options/JdbcReadOptions.java [88:101]
public boolean equals(Object o) {
if (o instanceof JdbcReadOptions) {
JdbcReadOptions options = (JdbcReadOptions) o;
return Objects.equals(query, options.query)
&& Objects.equals(partitionColumnName, options.partitionColumnName)
&& Objects.equals(partitionLowerBound, options.partitionLowerBound)
&& Objects.equals(partitionUpperBound, options.partitionUpperBound)
&& Objects.equals(numPartitions, options.numPartitions)
&& Objects.equals(fetchSize, options.fetchSize)
&& Objects.equals(autoCommit, options.autoCommit);
} else {
return false;
}
}