in flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/table/KinesisDynamicSource.java [224:238]
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(physicalDataType, that.physicalDataType)
&& Objects.equals(stream, that.stream)
&& Objects.equals(consumerProperties, that.consumerProperties)
&& Objects.equals(decodingFormat, that.decodingFormat);
}