private static UpdateSchema applySchemaChange(UpdateSchema updateSchema, SchemaChange change) {
        switch (change.getType()) {
            case ADD_COLUMN:
                if (change.getParentName() == null) {
                    return updateSchema
                        .addColumn(change.getColumnName(), change.getNewType());
                } else {
                    return updateSchema
                        .addColumn(change.getParentName(), change.getColumnName(), change.getNewType());
                }
            case MAKE_OPTIONAL:
                return updateSchema
                    .makeColumnOptional(change.getColumnName());
            case PROMOTE_TYPE:
                return updateSchema
                    .updateColumn(change.getColumnName(), change.getNewType());
            default:
                return updateSchema;
        }
    }
Apply schema changes to the table

@param changes list of schema changes
core/src/main/java/kafka/automq/table/worker/IcebergTableManager.java