in flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/table/RowElasticsearchSinkFunction.java [117:131]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
RowElasticsearchSinkFunction that = (RowElasticsearchSinkFunction) o;
return Objects.equals(indexGenerator, that.indexGenerator)
&& Objects.equals(docType, that.docType)
&& Objects.equals(serializationSchema, that.serializationSchema)
&& contentType == that.contentType
&& Objects.equals(requestFactory, that.requestFactory)
&& Objects.equals(createKey, that.createKey);
}