connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata/FieldsMetadata.java [45:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public FieldsMetadata(
            Set<String> keyFieldNames,
            Set<String> nonKeyFieldNames,
            Map<String, SinkRecordField> allFields
    ) {
        boolean fieldCountsMatch = (keyFieldNames.size() + nonKeyFieldNames.size()) == allFields.size();
        boolean allFieldsContained = allFields.keySet().containsAll(keyFieldNames)
                && allFields.keySet().containsAll(nonKeyFieldNames);
        if (!fieldCountsMatch || !allFieldsContained) {
            throw new IllegalArgumentException(String.format(
                    "Validation fail -- keyFieldNames:%s nonKeyFieldNames:%s allFields:%s",
                    keyFieldNames, nonKeyFieldNames, allFields
            ));
        }
        this.keyFieldNames = keyFieldNames;
        this.nonKeyFieldNames = nonKeyFieldNames;
        this.allFields = allFields;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java [45:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public FieldsMetadata(
            Set<String> keyFieldNames,
            Set<String> nonKeyFieldNames,
            Map<String, SinkRecordField> allFields
    ) {
        boolean fieldCountsMatch = (keyFieldNames.size() + nonKeyFieldNames.size()) == allFields.size();
        boolean allFieldsContained = allFields.keySet().containsAll(keyFieldNames)
                && allFields.keySet().containsAll(nonKeyFieldNames);
        if (!fieldCountsMatch || !allFieldsContained) {
            throw new IllegalArgumentException(String.format(
                    "Validation fail -- keyFieldNames:%s nonKeyFieldNames:%s allFields:%s",
                    keyFieldNames, nonKeyFieldNames, allFields
            ));
        }
        this.keyFieldNames = keyFieldNames;
        this.nonKeyFieldNames = nonKeyFieldNames;
        this.allFields = allFields;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -