in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java [182:194]
public boolean equals(Object o) {
if (!(o instanceof MongoDynamicTableSource)) {
return false;
}
MongoDynamicTableSource that = (MongoDynamicTableSource) o;
return Objects.equals(connectionOptions, that.connectionOptions)
&& Objects.equals(readOptions, that.readOptions)
&& Objects.equals(producedDataType, that.producedDataType)
&& Objects.equals(limit, that.limit)
&& Objects.equals(lookupCache, that.lookupCache)
&& Objects.equals(lookupMaxRetries, that.lookupMaxRetries)
&& Objects.equals(lookupRetryIntervalMs, that.lookupRetryIntervalMs);
}