in paimon-trino-common/src/main/java/org/apache/paimon/trino/TrinoMetadataBase.java [90:104]
public void createSchema(
ConnectorSession session,
String schemaName,
Map<String, Object> properties,
TrinoPrincipal owner) {
checkArgument(
!StringUtils.isNullOrWhitespaceOnly(schemaName),
"schemaName cannot be null or empty");
try {
catalog.createDatabase(schemaName, true);
} catch (Catalog.DatabaseAlreadyExistException e) {
throw new RuntimeException(format("database already existed: '%s'", schemaName));
}
}