public Builder setProperties()

in src/main/java/org/apache/flink/connector/rocketmq/legacy/common/serialization/RowKeyValueDeserializationSchema.java [334:379]
46 lines of code
7 McCabe index (conditional complexity)

        public Builder setProperties(Map<String, String> properties) {
            this.properties = properties;
            if (null == properties) {
                return this;
            }
            Configuration configuration = new Configuration();
            for (String key : properties.keySet()) {
                configuration.setString(key, properties.get(key));
            }
            String lengthCheck = configuration.get(CollectorOption.LENGTH_CHECK);
            switch (lengthCheck.toUpperCase()) {
                case "SKIP":
                    {
                        this.setFormatErrorStrategy(DirtyDataStrategy.SKIP);
                        this.setFieldMissingStrategy(DirtyDataStrategy.SKIP);
                        this.setFieldIncrementStrategy(DirtyDataStrategy.SKIP);
                    }
                    break;
                case "PAD":
                    {
                        this.setFormatErrorStrategy(DirtyDataStrategy.SKIP);
                        this.setFieldMissingStrategy(DirtyDataStrategy.PAD);
                        this.setFieldIncrementStrategy(DirtyDataStrategy.CUT);
                    }
                    break;
                case "EXCEPTION":
                    {
                        this.setFormatErrorStrategy(DirtyDataStrategy.EXCEPTION);
                        this.setFieldMissingStrategy(DirtyDataStrategy.EXCEPTION);
                        this.setFieldIncrementStrategy(DirtyDataStrategy.EXCEPTION);
                    }
                    break;
                case "SKIP_SILENT":
                    {
                        this.setFormatErrorStrategy(DirtyDataStrategy.SKIP_SILENT);
                        this.setFieldMissingStrategy(DirtyDataStrategy.SKIP_SILENT);
                        this.setFieldIncrementStrategy(DirtyDataStrategy.SKIP_SILENT);
                    }
                    break;
                default:
            }
            this.setEncoding(configuration.getString(CollectorOption.ENCODING));
            this.setFieldDelimiter(configuration.getString(CollectorOption.FIELD_DELIMITER));
            this.setColumnErrorDebug(configuration.getBoolean(CollectorOption.COLUMN_ERROR_DEBUG));
            return this;
        }