in flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/table/JdbcDynamicTableSource.java [221:238]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (!(o instanceof JdbcDynamicTableSource)) {
return false;
}
JdbcDynamicTableSource that = (JdbcDynamicTableSource) o;
return Objects.equals(options, that.options)
&& Objects.equals(readOptions, that.readOptions)
&& Objects.equals(lookupMaxRetryTimes, that.lookupMaxRetryTimes)
&& Objects.equals(cache, that.cache)
&& Objects.equals(physicalRowDataType, that.physicalRowDataType)
&& Objects.equals(dialectName, that.dialectName)
&& Objects.equals(limit, that.limit)
&& Objects.equals(resolvedPredicates, that.resolvedPredicates)
&& Arrays.deepEquals(pushdownParams, that.pushdownParams);
}