Skip to content

Commit

Permalink
fix comment
Browse files Browse the repository at this point in the history
  • Loading branch information
FANNG1 committed Mar 22, 2024
1 parent 6e36146 commit 3355012
Showing 1 changed file with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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 =
Expand Down Expand Up @@ -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;
}
}

0 comments on commit 3355012

Please sign in to comment.