public List getColumnsFromMessages()

in timescaledb-connector/src/main/java/com/epam/deltix/timebase/connector/service/timebase/TimebaseDescriptorService.java [52:66]

12 lines of code
2 McCabe index (conditional complexity)


    public List<TimescaleColumn> getColumnsFromMessages(List<ClassDescriptorInfo> descriptorMessages) {
        List<TimescaleColumn> columns = new ArrayList<>();

        List<com.epam.deltix.timebase.messages.schema.RecordClassDescriptor> baseDescriptors = RecordClassDescriptorUtils
                .getBaseClassDescriptors(descriptorMessages.toArray(new ClassDescriptor[descriptorMessages.size()]));

        Map<CharSequence, ClassDescriptorInfo> descriptorsMap = descriptorMessages
                .stream()
                .collect(Collectors.toMap(com.epam.deltix.timebase.messages.schema.ClassDescriptorInfo::getName, Function.identity()));
        for (com.epam.deltix.timebase.messages.schema.RecordClassDescriptor descriptor : baseDescriptors) {
            columns.addAll(getColumns(descriptor, null, descriptorsMap));
        }

        return filterTimescaleColumns(columns);
    }