public void addColumn()

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

17 lines of code
2 McCabe index (conditional complexity)


    public void addColumn(
            ConnectorSession session, ConnectorTableHandle tableHandle, ColumnMetadata column) {
        PrestoSqlTableHandle prestosqlTableHandle = (PrestoSqlTableHandle) tableHandle;
        Identifier identifier =
                new Identifier(
                        prestosqlTableHandle.getSchemaName(), prestosqlTableHandle.getTableName());
        List<SchemaChange> changes = new ArrayList<>();
        changes.add(
                SchemaChange.addColumn(
                        column.getName(), PrestoSqlTypeUtils.toPaimonType(column.getType())));
        try {
            catalog.alterTable(identifier, changes, false);
        } catch (Exception e) {
            throw new RuntimeException(
                    format("table not exists: '%s'", prestosqlTableHandle.getTableName()));
        }
    }