File tree Expand file tree Collapse file tree
opensearch/src/main/java/org/opensearch/sql/opensearch/planner/rules Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2727import org .immutables .value .Value ;
2828import org .opensearch .sql .calcite .plan .rule .OpenSearchRuleConfig ;
2929import org .opensearch .sql .calcite .utils .PlanUtils ;
30- import org .opensearch . sql . opensearch . planner . physical . CalciteEnumerableTopK ;
30+ import org .apache . calcite . adapter . enumerable . EnumerableLimitSort ;
3131import org .opensearch .sql .opensearch .storage .scan .AbstractCalciteIndexScan ;
3232import org .opensearch .sql .opensearch .storage .scan .CalciteLogicalIndexScan ;
3333import org .opensearch .sql .opensearch .storage .scan .context .SortExprDigest ;
@@ -48,9 +48,9 @@ protected SortExprIndexScanRule(SortExprIndexScanRule.Config config) {
4848 @ Override
4949 protected void onMatchImpl (RelOptRuleCall call ) {
5050 final Sort sort = call .rel (0 );
51- // CalciteEnumerableTopK carries fetch semantics; this rule doesn't preserve it on physical
51+ // EnumerableLimitSort carries fetch semantics; this rule doesn't preserve it on physical
5252 // scans because limit pushdown path is logical-only.
53- if (sort instanceof CalciteEnumerableTopK ) {
53+ if (sort instanceof EnumerableLimitSort ) {
5454 return ;
5555 }
5656 final Project project = call .rel (1 );
You can’t perform that action at this time.
0 commit comments