private FilteredUsageReport buildFilteredUsageReportFromMap()

in src/main/java/com/epam/grid/engine/provider/utils/sge/usage/SgeSummaryFilteredAccountingDataParser.java [101:124]

24 lines of code
4 McCabe index (conditional complexity)


    private FilteredUsageReport buildFilteredUsageReportFromMap(final List<String> headers,
                                                                final EnumMap<SgeAccountingHeaders, String> enumMap) {
        final FilteredUsageReport report = FilteredUsageReport.builder()
                .wallClock(Integer.parseInt(enumMap.get(SgeAccountingHeaders.WALL_CLOCK)))
                .userTime(Double.parseDouble(enumMap.get(SgeAccountingHeaders.USER_TIME)))
                .systemTime(Double.parseDouble(enumMap.get(SgeAccountingHeaders.SYSTEM_TIME)))
                .cpuTime(Double.parseDouble(enumMap.get(SgeAccountingHeaders.CPU_TIME)))
                .memory(Double.parseDouble(enumMap.get(SgeAccountingHeaders.MEMORY)))
                .ioData(Double.parseDouble(enumMap.get(SgeAccountingHeaders.IO_DATA)))
                .ioWaiting(Double.parseDouble(enumMap.get(SgeAccountingHeaders.IO_WAITING)))
                .build();
        if (headers.contains(SgeAccountingHeaders.OWNER.name())) {
            report.setOwners(Set.of(enumMap.get(SgeAccountingHeaders.OWNER)));
        }
        if (headers.contains(SgeAccountingHeaders.QUEUE.name())) {
            report.setHosts(Set.of(enumMap.get(SgeAccountingHeaders.HOST)));
            report.setCluster(enumMap.get(SgeAccountingHeaders.CLUSTER));
            report.setQueues(Set.of(enumMap.get(SgeAccountingHeaders.QUEUE)));
        }
        if (headers.contains(SgeAccountingHeaders.PARALLEL_ENV.name())) {
            report.setQueues(Set.of(enumMap.get(SgeAccountingHeaders.PARALLEL_ENV)));
        }
        return report;
    }