in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardMetadata.java [141:160]
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());
}