in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java [144:158]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
MongoDynamicTableSink that = (MongoDynamicTableSink) o;
return Objects.equals(connectionOptions, that.connectionOptions)
&& Objects.equals(writeOptions, that.writeOptions)
&& Objects.equals(parallelism, that.parallelism)
&& Objects.equals(supportUpsert, that.supportUpsert)
&& Objects.equals(resolvedSchema, that.resolvedSchema)
&& Arrays.equals(partitionKeys, that.partitionKeys);
}