in flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/datastream/source/split/CheckpointedOffset.java [55:65]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
CheckpointedOffset that = (CheckpointedOffset) o;
return offset == that.offset && recordsAfterOffset == that.recordsAfterOffset;
}