[apache#2587] feat(spark-connector): Support iceberg metadataColumns

caican00 · Mar 28, 2024 · d0bd521 · d0bd521
1 parent 0aba061
commit d0bd521
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/...ector/src/main/java/com/datastrato/gravitino/spark/connector/SparkTransformConverter.java b/...ector/src/main/java/com/datastrato/gravitino/spark/connector/SparkTransformConverter.java
@@ -21,7 +21,17 @@
 import lombok.Getter;
 import org.apache.commons.lang3.ArrayUtils;
 import org.apache.commons.lang3.tuple.Pair;
-import org.apache.spark.sql.connector.expressions.*;
+import org.apache.spark.sql.connector.expressions.ApplyTransform;
+import org.apache.spark.sql.connector.expressions.BucketTransform;
+import org.apache.spark.sql.connector.expressions.DaysTransform;
+import org.apache.spark.sql.connector.expressions.Expressions;
+import org.apache.spark.sql.connector.expressions.HoursTransform;
+import org.apache.spark.sql.connector.expressions.IdentityTransform;
+import org.apache.spark.sql.connector.expressions.Literal;
+import org.apache.spark.sql.connector.expressions.LogicalExpressions;
+import org.apache.spark.sql.connector.expressions.MonthsTransform;
+import org.apache.spark.sql.connector.expressions.SortedBucketTransform;
+import org.apache.spark.sql.connector.expressions.YearsTransform;
 import org.apache.spark.sql.types.IntegerType;
 import org.apache.spark.sql.types.LongType;
 import scala.collection.JavaConverters;