in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/AdbpgDynamicTableSink.java [94:123]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (!(o instanceof AdbpgDynamicTableSink)) {
return false;
}
AdbpgDynamicTableSink that = (AdbpgDynamicTableSink) o;
return Objects.equals(this.config.get(URL), that.config.get(URL))
&& Objects.equals(this.config.get(TABLE_NAME), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(USERNAME), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(PASSWORD), that.config.get(TABLE_NAME))
&& Objects.equals(fieldNum, that.fieldNum)
&& Arrays.equals(fieldNamesStr, that.fieldNamesStr)
&& Arrays.equals(keyFields, that.keyFields)
&& Arrays.equals(lts, that.lts)
&& Objects.equals(this.config.get(RETRY_WAIT_TIME), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(BATCH_SIZE), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(BATCH_WRITE_TIMEOUT_MS), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(MAX_RETRY_TIMES), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(CONNECTION_MAX_ACTIVE), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(CONFLICT_MODE), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(USE_COPY), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(TARGET_SCHEMA), that.config.get(TABLE_NAME))
&& Objects.equals(this.config.get(EXCEPTION_MODE), that.config.get(EXCEPTION_MODE))
&& Objects.equals(this.config.get(RESERVEMS), that.config.get(RESERVEMS))
&& Objects.equals(this.config.get(CASE_SENSITIVE), that.config.get(CASE_SENSITIVE))
&& Objects.equals(this.config.get(WRITE_MODE), that.config.get(WRITE_MODE))
&& Objects.equals(this.config.get(VERBOSE), that.config.get(VERBOSE));
}