in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/enumerator/JdbcSourceEnumeratorState.java [70:84]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
JdbcSourceEnumeratorState that = (JdbcSourceEnumeratorState) o;
return Objects.equals(completedSplits, that.completedSplits)
&& Objects.equals(pendingSplits, that.pendingSplits)
&& Objects.equals(remainingSplits, that.remainingSplits)
&& Objects.equals(
optionalUserDefinedSplitEnumeratorState,
that.optionalUserDefinedSplitEnumeratorState);
}