public Map getProperties()

in src/main/java/org/apache/flink/connector/rocketmq/common/config/RocketMQConfiguration.java [55:77]

• 18 lines of code
• 4 McCabe index (conditional complexity)

    public Map<String, String> getProperties(ConfigOption<Map<String, String>> option) {
        Map<String, String> properties = new HashMap<>();
        if (contains(option)) {
            Map<String, String> map = get(option);
            properties.putAll(map);
        }

        // Filter the sub config option. These options could be provided by SQL.
        String prefix = option.key() + ".";
        List<String> keys =
                keySet().stream()
                        .filter(key -> key.startsWith(prefix) && key.length() > prefix.length())
                        .collect(toList());

        // Put these config options' value into return result.
        for (String key : keys) {
            ConfigOption<String> o = ConfigOptions.key(key).stringType().noDefaultValue();
            String value = get(o);
            properties.put(key.substring(prefix.length()), value);
        }

        return properties;
    }