private TableDescriptor obtainTableSchema()

in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java [222:242]

21 lines of code
1 McCabe index (conditional complexity)


    private TableDescriptor obtainTableSchema(String tableName) {
        Schema schema =
                RestService.getSchema(dorisOptions, dorisOptions.getDatabase(), tableName, LOG);
        List<ColumnDescriptor> columnDescriptors = new ArrayList<>();
        schema.getProperties()
                .forEach(
                        column -> {
                            ColumnDescriptor columnDescriptor =
                                    ColumnDescriptor.builder()
                                            .columnName(column.getName())
                                            .typeName(column.getType())
                                            .comment(column.getComment())
                                            .build();
                            columnDescriptors.add(columnDescriptor);
                        });
        return TableDescriptor.builder()
                .tableName(tableName)
                .type(schema.getKeysType())
                .columns(columnDescriptors)
                .build();
    }