Flink: Required Iceberg core changes to rewrite PartitionSpecs and test schema updates

Author: mxm

api/src/main/java/org/apache/iceberg/expressions/NamedReference.java

@@ -26,7 +26,7 @@
 public class NamedReference<T> implements UnboundTerm<T>, Reference<T> {
   private final String name;
 
-  NamedReference(String name) {
+  public NamedReference(String name) {
     Preconditions.checkNotNull(name, "Name cannot be null");
     this.name = name;
   }

api/src/main/java/org/apache/iceberg/expressions/UnboundTransform.java

@@ -26,7 +26,7 @@ public class UnboundTransform<S, T> implements UnboundTerm<T>, Term {
   private final NamedReference<S> ref;
   private final Transform<S, T> transform;
 
-  UnboundTransform(NamedReference<S> ref, Transform<S, T> transform) {
+  public UnboundTransform(NamedReference<S> ref, Transform<S, T> transform) {
     this.ref = ref;
     this.transform = transform;
   }

core/src/main/java/org/apache/iceberg/SchemaUpdate.java

@@ -46,7 +46,7 @@
 import org.slf4j.LoggerFactory;
 
 /** Schema evolution API implementation. */
-class SchemaUpdate implements UpdateSchema {
+public class SchemaUpdate implements UpdateSchema {
   private static final Logger LOG = LoggerFactory.getLogger(SchemaUpdate.class);
   private static final int TABLE_ROOT_ID = -1;
 
@@ -71,7 +71,7 @@ class SchemaUpdate implements UpdateSchema {
   }
 
   /** For testing only. */
-  SchemaUpdate(Schema schema, int lastColumnId) {
+  public SchemaUpdate(Schema schema, int lastColumnId) {
     this(null, null, schema, lastColumnId);
   }