This is an automated email from the ASF dual-hosted git repository. snuyanzin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 52fd09662d6ca6be38fc5b5c048486c60c018024 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Thu Apr 2 14:55:17 2026 +0200 [FLINK-39393][table] Add `TableChange` for comment --- .../apache/flink/table/catalog/TableChange.java | 34 ++++++++++++++++++++++ 1 file changed, 34 insertions(+) diff --git a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/TableChange.java b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/TableChange.java index c890b3b8adf..818c5b2d6ce 100644 --- a/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/TableChange.java +++ b/flink-table/flink-table-common/src/main/java/org/apache/flink/table/catalog/TableChange.java @@ -1517,4 +1517,38 @@ public interface TableChange { return "ModifyStartMode{" + "startMode=" + startMode + '}'; } } + + /** A table change to modify comment for table or materialized table. */ + @PublicEvolving + class ModifyTableComment implements CatalogTableChange, MaterializedTableChange { + + private final String comment; + + public ModifyTableComment(String comment) { + this.comment = comment; + } + + public String getComment() { + return comment; + } + + @Override + public boolean equals(Object o) { + if (o == null || getClass() != o.getClass()) { + return false; + } + ModifyTableComment that = (ModifyTableComment) o; + return Objects.equals(comment, that.comment); + } + + @Override + public int hashCode() { + return Objects.hashCode(comment); + } + + @Override + public String toString() { + return "ModifyTableComment{" + "comment='" + comment + '\'' + '}'; + } + } }
