in flink-kubernetes-operator/src/main/java/org/apache/flink/runtime/rest/messages/job/metrics/IOMetricsInfo.java [155:174]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
IOMetricsInfo that = (IOMetricsInfo) o;
return bytesRead == that.bytesRead
&& bytesReadComplete == that.bytesReadComplete
&& bytesWritten == that.bytesWritten
&& bytesWrittenComplete == that.bytesWrittenComplete
&& recordsRead == that.recordsRead
&& recordsReadComplete == that.recordsReadComplete
&& recordsWritten == that.recordsWritten
&& recordsWrittenComplete == that.recordsWrittenComplete
&& accumulatedBackpressured == that.accumulatedBackpressured
&& accumulatedBusy == that.accumulatedBusy
&& accumulatedIdle == that.accumulatedIdle;
}