public Map listWritableMetadata()

in flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/KafkaDynamicSink.java [264:274]

• 10 lines of code
• 5 McCabe index (conditional complexity)

    public Map<String, DataType> listWritableMetadata() {
        final Map<String, DataType> metadataMap = new LinkedHashMap<>();
        for (WritableMetadata m : WritableMetadata.values()) {
            if (topics != null && topics.size() == 1 && WritableMetadata.TOPIC.key.equals(m.key)) {
                // When `topic` is a singleton list, TOPIC metadata is not writable
                continue;
            }
            metadataMap.put(m.key, m.dataType);
        }
        return metadataMap;
    }