in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/Elasticsearch7DynamicSink.java [317:329]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
Elasticsearch7DynamicSink that = (Elasticsearch7DynamicSink) o;
return Objects.equals(format, that.format)
&& Objects.equals(schema, that.schema)
&& Objects.equals(config, that.config)
&& Objects.equals(builderProvider, that.builderProvider);
}