in amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/model/StreamShardMetadata.java [127:146]
public boolean equals(Object obj) {
if (!(obj instanceof StreamShardMetadata)) {
return false;
}
if (obj == this) {
return true;
}
StreamShardMetadata other = (StreamShardMetadata) obj;
return streamName.equals(other.getStreamName()) &&
shardId.equals(other.getShardId()) &&
Objects.equals(parentShardId, other.getParentShardId()) &&
Objects.equals(adjacentParentShardId, other.getAdjacentParentShardId()) &&
Objects.equals(startingHashKey, other.getStartingHashKey()) &&
Objects.equals(endingHashKey, other.getEndingHashKey()) &&
Objects.equals(startingSequenceNumber, other.getStartingSequenceNumber()) &&
Objects.equals(endingSequenceNumber, other.getEndingSequenceNumber());
}