in flink-connector-pulsar/src/main/java/org/apache/flink/connector/pulsar/source/split/PulsarPartitionSplit.java [102:111]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
PulsarPartitionSplit that = (PulsarPartitionSplit) o;
return partition.equals(that.partition);
}