[cdc-common] Support adding Column directly in schema builder

This closes apache#2739
PatrickRen · Nov 23, 2023 · 15393eb · 15393eb
1 parent b4deda9
commit 15393eb
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/flink-cdc-common/src/main/java/com/ververica/cdc/common/schema/Schema.java b/flink-cdc-common/src/main/java/com/ververica/cdc/common/schema/Schema.java
@@ -298,6 +298,12 @@ public Builder metadataColumn(
             return this;
         }
 
+        public Builder column(Column column) {
+            checkColumn(column.getName(), column.getType());
+            columns.add(column);
+            return this;
+        }
+
         private void checkColumn(String columnName, DataType type) {
             Preconditions.checkNotNull(columnName, "Column name must not be null.");
             Preconditions.checkNotNull(type, "Data type must not be null.");