in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java [218:244]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
DorisExecutionOptions that = (DorisExecutionOptions) o;
return checkInterval == that.checkInterval
&& maxRetries == that.maxRetries
&& bufferSize == that.bufferSize
&& bufferCount == that.bufferCount
&& useCache == that.useCache
&& force2PC == that.force2PC
&& flushQueueSize == that.flushQueueSize
&& bufferFlushMaxRows == that.bufferFlushMaxRows
&& bufferFlushMaxBytes == that.bufferFlushMaxBytes
&& bufferFlushIntervalMs == that.bufferFlushIntervalMs
&& enableBatchMode == that.enableBatchMode
&& ignoreUpdateBefore == that.ignoreUpdateBefore
&& ignoreCommitError == that.ignoreCommitError
&& Objects.equals(labelPrefix, that.labelPrefix)
&& Objects.equals(streamLoadProp, that.streamLoadProp)
&& Objects.equals(enableDelete, that.enableDelete)
&& Objects.equals(enable2PC, that.enable2PC)
&& writeMode == that.writeMode;
}