in flink-connector-aws/flink-connector-sqs/src/main/java/org/apache/flink/connector/sqs/table/SqsDynamicSink.java [127:141]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
SqsDynamicSink that = (SqsDynamicSink) o;
return super.equals(o)
&& failOnError == that.failOnError
&& Objects.equals(consumedDataType, that.consumedDataType)
&& Objects.equals(sqsUrl, that.sqsUrl)
&& Objects.equals(sqsClientProps, that.sqsClientProps)
&& Objects.equals(encodingFormat, that.encodingFormat);
}