in flink-connector-influxdb2/src/main/java/org/apache/flink/streaming/connectors/influxdb/common/DataPoint.java [135:154]
public boolean equals(final Object obj) {
// If the object is compared with itself then return true
if (obj == this) {
return true;
}
/* Check if o is an instance of Complex or not
"null instanceof [type]" also returns false */
if (!(obj instanceof DataPoint)) {
return false;
}
// typecast o to DataPoint so that we can compare data members
final DataPoint point = (DataPoint) obj;
return point.measurement.equals(this.measurement)
&& point.tags.equals(this.tags)
&& (point.timestamp.equals(this.timestamp));
}