private void init()

in src/main/java/org/opensearch/performanceanalyzer/rca/stats/collectors/SampleAggregator.java [103:139]

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

    private void init() {
        startTimeMillis = new AtomicLong(0L);
        Map<MeasurementSet, Set<IStatistic>> initializer = new ConcurrentHashMap<>();

        for (MeasurementSet elem : recognizedSet) {
            Set<IStatistic> impls = new HashSet<>();
            for (Statistics stats : elem.getStatsList()) {
                switch (stats) {
                    case COUNT:
                        impls.add(new Count());
                        break;
                    case MAX:
                        impls.add(new Max());
                        break;
                    case MEAN:
                        impls.add(new Mean());
                        break;
                    case MIN:
                        impls.add(new Min());
                        break;
                    case NAMED_COUNTERS:
                        impls.add(new NamedCounter());
                        break;
                    case SAMPLE:
                        impls.add(new Sample());
                        break;
                    case SUM:
                        impls.add(new Sum());
                        break;
                    default:
                        throw new IllegalArgumentException("Unimplemented stat: " + stats);
                }
            }
            initializer.put(elem, impls);
        }
        this.statMap = ImmutableMap.copyOf(initializer);
    }