public static void createTable()

in paimon-web-api/src/main/java/org/apache/paimon/web/api/table/TableManager.java [77:104]

23 lines of code
5 McCabe index (conditional complexity)


    public static void createTable(
            Catalog catalog, String dbName, String tableName, TableMetadata tableMetadata)
            throws Catalog.TableAlreadyExistException, Catalog.DatabaseNotExistException {
        checkNotNull(catalog, dbName, tableName);

        Schema.Builder schemaBuilder =
                Schema.newBuilder()
                        .partitionKeys(
                                tableMetadata.primaryKeys() == null
                                        ? ImmutableList.of()
                                        : ImmutableList.copyOf(tableMetadata.primaryKeys()))
                        .partitionKeys(
                                tableMetadata.partitionKeys() == null
                                        ? ImmutableList.of()
                                        : ImmutableList.copyOf(tableMetadata.partitionKeys()))
                        .comment(tableMetadata.comment() == null ? "" : tableMetadata.comment())
                        .options(handleOptions(tableMetadata.options()));

        for (ColumnMetadata column : tableMetadata.columns()) {
            schemaBuilder.column(column.name(), column.type(), column.description());
        }

        Schema schema = schemaBuilder.build();

        Identifier identifier = Identifier.create(dbName, tableName);

        catalog.createTable(identifier, schema, false);
    }