replace deprecated Calcite api with new one

apache · Oct 18, 2024 · fa959f2 · fa959f2
1 parent daeda75
commit fa959f2
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java
@@ -5605,16 +5605,15 @@ RelNode sortLimit(RexNode offsetRN, RexNode fetchRN) throws SemanticException {
       // 4. Construct SortRel
       RelOptCluster cluster = calcitePlannerAction.cluster;
       RelTraitSet traitSet = cluster.traitSetOf(HiveRelNode.CONVENTION);
-      RelCollation canonizedCollation = traitSet.canonize(RelCollationImpl.of(fieldCollations));
+      RelCollation canonizedCollation = RelCollations.of(fieldCollations);
       RelNode sortRel = new HiveSortLimit(cluster, traitSet, obInputRel, canonizedCollation, offsetRN, fetchRN);
       return endGenOBLogicalPlan(sortRel);
     }
 
     RelNode sortExchange() throws SemanticException {
       genOBProject();
 
-      RelTraitSet traitSet = calcitePlannerAction.cluster.traitSetOf(HiveRelNode.CONVENTION);
-      RelCollation canonizedCollation = traitSet.canonize(RelCollationImpl.of(fieldCollations));
+      RelCollation canonizedCollation = RelCollations.of(fieldCollations);
       ImmutableList.Builder<RexNode> builder = ImmutableList.builder();
       for (RelFieldCollation relFieldCollation : canonizedCollation.getFieldCollations()) {
         int index = relFieldCollation.getFieldIndex();