in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/connector/elasticsearch/table/ElasticsearchDynamicSink.java [199:215]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
ElasticsearchDynamicSink that = (ElasticsearchDynamicSink) o;
return Objects.equals(format, that.format)
&& Objects.equals(physicalRowDataType, that.physicalRowDataType)
&& Objects.equals(
primaryKeyLogicalTypesWithIndex, that.primaryKeyLogicalTypesWithIndex)
&& Objects.equals(config, that.config)
&& Objects.equals(summaryString, that.summaryString)
&& Objects.equals(builderSupplier, that.builderSupplier)
&& Objects.equals(documentType, that.documentType);
}