private void applyChanges(Table table, List<SchemaChange> changes) {
        table.refresh();
        UpdateSchema updateSchema = table.updateSchema();
        changes.stream().filter(c -> !shouldSkipChange(table.schema(), c))
            .forEach(c -> applySchemaChange(updateSchema, c));
        updateSchema.commit();
    }
Apply schema changes to the table

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