public static TableChanges.TableChange createTableChange(
            TableChanges.TableChange oldTableChange, Tables.ColumnNameFilter columnNameFilter) {
        Table table = oldTableChange.getTable();
        TableEditor tableEditor = table.edit();
        table.columns()
                .stream()
                .filter(column -> !columnNameFilter.matches(
                        table.id().catalog(),
                        table.id().schema(),
                        table.id().table(),
                        column.name()))
                .forEach(column -> tableEditor.removeColumn(column.name()));

        return new TableChanges.TableChange(oldTableChange.getType(), tableEditor.create());
    }
Utility class to Combining column.exclude.list/column.blacklist, column.include.list/column.whitelist parameters
to generate new TableChange object.
inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/util/ColumnFilterUtil.java