public Map deserializeKeyAndValue()

in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/SimpleKeyValueDeserializationSchema.java [50:61]

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

    public Map<String, String> deserializeKeyAndValue(byte[] key, byte[] value) {
        HashMap<String, String> map = new HashMap<>(2);
        if (keyField != null) {
            String k = key != null ? new String(key, StandardCharsets.UTF_8) : null;
            map.put(keyField, k);
        }
        if (valueField != null) {
            String v = value != null ? new String(value, StandardCharsets.UTF_8) : null;
            map.put(valueField, v);
        }
        return map;
    }