public void addAlias()

in timebase-kafka-connector/src/main/java/deltix/kafka/connect/FieldMap.java [28:44]


    public void addAlias(String srcField, String destField) {
        // validate and normalize parameters by removing any spaces
        String[] srcPath = splitPath(srcField);
        srcField = makePathString(srcPath);
        destField = destField.trim();

        if (srcField.isEmpty() || destField.isEmpty() || srcField.equals(destField)) {
            throw new IllegalArgumentException("Invalid field mapping: \"" + srcField + "\" -> \"" + destField + "\"");
        }
        if (forward.put(srcField, destField) != null) {
            throw new IllegalArgumentException("Source fields names must be unique");
        }
        if (backward.put(destField, srcField) != null) {
            throw new IllegalArgumentException("Destination fields names must be unique");
        }
        sourcePaths.put(destField, srcPath);
    }