in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java [96:109]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
MongoReadOptions that = (MongoReadOptions) o;
return noCursorTimeout == that.noCursorTimeout
&& partitionStrategy == that.partitionStrategy
&& samplesPerPartition == that.samplesPerPartition
&& Objects.equals(partitionSize, that.partitionSize)
&& Objects.equals(partitionRecordSize, that.partitionRecordSize);
}