private Schema prepareSchema()

in paimon-prestosql-common/src/main/java/org/apache/paimon/prestosql/PrestoSqlMetadataBase.java [196:213]

15 lines of code
2 McCabe index (conditional complexity)


    private Schema prepareSchema(ConnectorTableMetadata tableMetadata) {
        Map<String, Object> properties = new HashMap<>(tableMetadata.getProperties());
        Schema.Builder builder =
                Schema.newBuilder()
                        .primaryKey(PrestoSqlTableOptions.getPrimaryKeys(properties))
                        .partitionKeys(PrestoSqlTableOptions.getPartitionedKeys(properties));

        for (ColumnMetadata column : tableMetadata.getColumns()) {
            builder.column(
                    column.getName(),
                    PrestoSqlTypeUtils.toPaimonType(column.getType()),
                    column.getComment());
        }

        PrestoSqlTableOptionUtils.buildOptions(builder, properties);

        return builder.build();
    }