in flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/table/KinesisDynamicSink.java [166:183]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
KinesisDynamicSink that = (KinesisDynamicSink) o;
return super.equals(o)
&& Objects.equals(consumedDataType, that.consumedDataType)
&& Objects.equals(streamArn, that.streamArn)
&& Objects.equals(kinesisClientProperties, that.kinesisClientProperties)
&& Objects.equals(encodingFormat, that.encodingFormat)
&& Objects.equals(partitioner, that.partitioner)
&& Objects.equals(failOnError, that.failOnError);
}