in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSource.java [180:193]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
KinesisDynamicSource that = (KinesisDynamicSource) o;
return Objects.equals(producedDataType, that.producedDataType)
&& Objects.equals(requestedMetadataFields, that.requestedMetadataFields)
&& Objects.equals(streamArn, that.streamArn)
&& Objects.equals(sourceConfig, that.sourceConfig)
&& Objects.equals(decodingFormat, that.decodingFormat);
}