private Schema prepareSchema()

in paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoMetadataBase.java [189:206]

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(TrinoTableOptions.getPrimaryKeys(properties))
                        .partitionKeys(TrinoTableOptions.getPartitionedKeys(properties));

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

        TrinoTableOptionUtils.buildOptions(builder, properties);

        return builder.build();
    }