in flink-connector-elasticsearch7/src/main/java/org/apache/flink/streaming/connectors/elasticsearch7/ElasticsearchSink.java [244:257]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
Builder<?> builder = (Builder<?>) o;
return Objects.equals(httpHosts, builder.httpHosts)
&& Objects.equals(elasticsearchSinkFunction, builder.elasticsearchSinkFunction)
&& Objects.equals(bulkRequestsConfig, builder.bulkRequestsConfig)
&& Objects.equals(failureHandler, builder.failureHandler)
&& Objects.equals(restClientFactory, builder.restClientFactory);
}