You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2025/08/06 16:59:18 UTC
(pinot) branch master updated: Fix typo in semi-join distinct project optimization rule (#16520)
This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 021368c5374 Fix typo in semi-join distinct project optimization rule (#16520)
021368c5374 is described below
commit 021368c5374b93a980c5b6fee36ab2b0809e6091
Author: Yash Mayya <ya...@gmail.com>
AuthorDate: Wed Aug 6 22:29:13 2025 +0530
Fix typo in semi-join distinct project optimization rule (#16520)
---
.../apache/pinot/calcite/rel/rules/PinotQueryRuleSets.java | 4 ++--
...rojectRule.java => PinotSemiJoinDistinctProjectRule.java} | 12 ++++++------
.../java/org/apache/pinot/spi/utils/CommonConstants.java | 2 +-
3 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotQueryRuleSets.java b/pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotQueryRuleSets.java
index e07de5a53e9..b9d2604b83e 100644
--- a/pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotQueryRuleSets.java
+++ b/pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotQueryRuleSets.java
@@ -116,8 +116,8 @@ public class PinotQueryRuleSets {
// join and semi-join rules
SemiJoinRule.ProjectToSemiJoinRule.ProjectToSemiJoinRuleConfig.DEFAULT
.withDescription(PlannerRuleNames.PROJECT_TO_SEMI_JOIN).toRule(),
- PinotSeminJoinDistinctProjectRule
- .instanceWithDescription(PlannerRuleNames.SEMIN_JOIN_DISTINCT_PROJECT),
+ PinotSemiJoinDistinctProjectRule
+ .instanceWithDescription(PlannerRuleNames.SEMI_JOIN_DISTINCT_PROJECT),
// Consider semijoin optimizations first before push transitive predicate
// Pinot version doesn't push predicates to the right in case of lookup join
diff --git a/pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotSeminJoinDistinctProjectRule.java b/pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotSemiJoinDistinctProjectRule.java
similarity index 85%
rename from pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotSeminJoinDistinctProjectRule.java
rename to pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotSemiJoinDistinctProjectRule.java
index 95f25b7f78e..0b1766fe704 100644
--- a/pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotSeminJoinDistinctProjectRule.java
+++ b/pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/PinotSemiJoinDistinctProjectRule.java
@@ -38,15 +38,15 @@ import org.apache.pinot.calcite.rel.hint.PinotHintStrategyTable;
* {@link org.apache.calcite.rel.logical.LogicalProject} on top of a Semi join
* {@link org.apache.calcite.rel.core.Join} to ensure the correctness of the query.
*/
-public class PinotSeminJoinDistinctProjectRule extends RelOptRule {
- public static final PinotSeminJoinDistinctProjectRule INSTANCE =
- new PinotSeminJoinDistinctProjectRule(PinotRuleUtils.PINOT_REL_FACTORY, null);
+public class PinotSemiJoinDistinctProjectRule extends RelOptRule {
+ public static final PinotSemiJoinDistinctProjectRule INSTANCE =
+ new PinotSemiJoinDistinctProjectRule(PinotRuleUtils.PINOT_REL_FACTORY, null);
- public static PinotSeminJoinDistinctProjectRule instanceWithDescription(String description) {
- return new PinotSeminJoinDistinctProjectRule(PinotRuleUtils.PINOT_REL_FACTORY, description);
+ public static PinotSemiJoinDistinctProjectRule instanceWithDescription(String description) {
+ return new PinotSemiJoinDistinctProjectRule(PinotRuleUtils.PINOT_REL_FACTORY, description);
}
- public PinotSeminJoinDistinctProjectRule(RelBuilderFactory factory, @Nullable String description) {
+ public PinotSemiJoinDistinctProjectRule(RelBuilderFactory factory, @Nullable String description) {
super(operand(LogicalJoin.class, operand(AbstractRelNode.class, any()), operand(LogicalProject.class, any())),
factory, description);
}
diff --git a/pinot-spi/src/main/java/org/apache/pinot/spi/utils/CommonConstants.java b/pinot-spi/src/main/java/org/apache/pinot/spi/utils/CommonConstants.java
index 894c73f8dd9..367c9370446 100644
--- a/pinot-spi/src/main/java/org/apache/pinot/spi/utils/CommonConstants.java
+++ b/pinot-spi/src/main/java/org/apache/pinot/spi/utils/CommonConstants.java
@@ -783,7 +783,7 @@ public class CommonConstants {
public static final String EVALUATE_LITERAL_FILTER = "EvaluateFilterLiteral";
public static final String JOIN_PUSH_EXPRESSIONS = "JoinPushExpressions";
public static final String PROJECT_TO_SEMI_JOIN = "ProjectToSemiJoin";
- public static final String SEMIN_JOIN_DISTINCT_PROJECT = "SeminJoinDistinctProject";
+ public static final String SEMI_JOIN_DISTINCT_PROJECT = "SemiJoinDistinctProject";
public static final String UNION_TO_DISTINCT = "UnionToDistinct";
public static final String AGGREGATE_REMOVE = "AggregateRemove";
public static final String AGGREGATE_JOIN_TRANSPOSE = "AggregateJoinTranspose";
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org