Revert unrelated change

apache · Jan 6, 2025 · 76887a1 · 76887a1
1 parent fe6038a
commit 76887a1
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/api/src/main/java/org/apache/iceberg/transforms/Identity.java b/api/src/main/java/org/apache/iceberg/transforms/Identity.java
@@ -19,17 +19,14 @@
 package org.apache.iceberg.transforms;
 
 import java.io.ObjectStreamException;
-import java.util.Set;
 import org.apache.iceberg.expressions.BoundPredicate;
 import org.apache.iceberg.expressions.Expressions;
 import org.apache.iceberg.expressions.UnboundPredicate;
 import org.apache.iceberg.relocated.com.google.common.base.Preconditions;
 import org.apache.iceberg.types.Type;
-import org.apache.iceberg.types.Types;
 import org.apache.iceberg.util.SerializableFunction;
 
 class Identity<T> implements Transform<T, T> {
-  private static final Set<Type> UNSUPPORTED_TYPES = Set.of(Types.VariantType.get());
   private static final Identity<?> INSTANCE = new Identity<>();
 
   private final Type type;
@@ -42,7 +39,7 @@ class Identity<T> implements Transform<T, T> {
   @Deprecated
   public static <I> Identity<I> get(Type type) {
     Preconditions.checkArgument(
-        !UNSUPPORTED_TYPES.contains(type), "Unsupported type for identity: %s", type);
+        type.typeId() != Type.TypeID.VARIANT, "Unsupported type for identity: %s", type);
 
     return new Identity<>(type);
   }