in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShardState.java [80:94]
public boolean equals(Object obj) {
if (!(obj instanceof KinesisStreamShardState)) {
return false;
}
if (obj == this) {
return true;
}
KinesisStreamShardState other = (KinesisStreamShardState) obj;
return streamShardMetadata.equals(other.getStreamShardMetadata())
&& streamShardHandle.equals(other.getStreamShardHandle())
&& lastProcessedSequenceNum.equals(other.getLastProcessedSequenceNum());
}