in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java [163:186]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
DorisReadOptions that = (DorisReadOptions) o;
return useOldApi == that.useOldApi
&& Objects.equals(readFields, that.readFields)
&& Objects.equals(filterQuery, that.filterQuery)
&& Objects.equals(requestTabletSize, that.requestTabletSize)
&& Objects.equals(requestConnectTimeoutMs, that.requestConnectTimeoutMs)
&& Objects.equals(requestReadTimeoutMs, that.requestReadTimeoutMs)
&& Objects.equals(requestQueryTimeoutS, that.requestQueryTimeoutS)
&& Objects.equals(requestRetries, that.requestRetries)
&& Objects.equals(requestBatchSize, that.requestBatchSize)
&& Objects.equals(execMemLimit, that.execMemLimit)
&& Objects.equals(deserializeQueueSize, that.deserializeQueueSize)
&& Objects.equals(deserializeArrowAsync, that.deserializeArrowAsync)
&& Objects.equals(useFlightSql, that.useFlightSql)
&& Objects.equals(flightSqlPort, that.flightSqlPort)
&& Objects.equals(rowLimit, that.rowLimit);
}