From 33550128400d533f72953859065d2d5b01098cb0 Mon Sep 17 00:00:00 2001 From: fanng Date: Fri, 22 Mar 2024 11:34:52 +0800 Subject: [PATCH] fix comment --- .../spark/connector/SparkTransformConverter.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/spark-connector/src/main/java/com/datastrato/gravitino/spark/connector/SparkTransformConverter.java b/spark-connector/src/main/java/com/datastrato/gravitino/spark/connector/SparkTransformConverter.java index 2889459e8c0..ce02bf31d8d 100644 --- a/spark-connector/src/main/java/com/datastrato/gravitino/spark/connector/SparkTransformConverter.java +++ b/spark-connector/src/main/java/com/datastrato/gravitino/spark/connector/SparkTransformConverter.java @@ -77,11 +77,6 @@ public static Transform[] toGravitinoPartitionings( .toArray(Transform[]::new); } - public static boolean isBucketTransform( - org.apache.spark.sql.connector.expressions.Transform transform) { - return transform instanceof BucketTransform || transform instanceof SortedBucketTransform; - } - public static DistributionAndSortOrdersInfo toGravitinoDistributionAndSortOrders( org.apache.spark.sql.connector.expressions.Transform[] transforms) { DistributionAndSortOrdersInfo distributionAndSortOrdersInfo = @@ -247,4 +242,9 @@ private static String getFieldNameFromGravitinoNamedReference( NamedReference gravitinoNamedReference) { return String.join(ConnectorConstants.DOT, gravitinoNamedReference.fieldName()); } + + private static boolean isBucketTransform( + org.apache.spark.sql.connector.expressions.Transform transform) { + return transform instanceof BucketTransform || transform instanceof SortedBucketTransform; + } }