diff --git a/src/main/java/com/snowflake/kafka/connector/internal/streaming/schemaevolution/iceberg/IcebergColumnTree.java b/src/main/java/com/snowflake/kafka/connector/internal/streaming/schemaevolution/iceberg/IcebergColumnTree.java index 35a0847be..300ddbd97 100644 --- a/src/main/java/com/snowflake/kafka/connector/internal/streaming/schemaevolution/iceberg/IcebergColumnTree.java +++ b/src/main/java/com/snowflake/kafka/connector/internal/streaming/schemaevolution/iceberg/IcebergColumnTree.java @@ -23,6 +23,7 @@ String getColumnName() { this.rootNode = new IcebergFieldNode(columnName, pair.getJsonNode()); } + /** Add fields from other tree. Do not override nor modify any already existing nodes. */ IcebergColumnTree merge(IcebergColumnTree modifiedTree) { Preconditions.checkArgument( this.getColumnName().equals(modifiedTree.getColumnName()),