File tree Expand file tree Collapse file tree
core/src/main/java/org/opensearch/sql/executor Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2727import org .apache .calcite .rel .RelCollation ;
2828import org .apache .calcite .rel .RelCollations ;
2929import org .apache .calcite .rel .RelNode ;
30- import org .apache .calcite .rel .RelRoot ;
3130import org .apache .calcite .rel .core .Sort ;
3231import org .apache .calcite .rel .logical .LogicalSort ;
3332import org .apache .calcite .rel .rel2sql .RelToSqlConverter ;
@@ -399,8 +398,8 @@ public SqlNode visit(SqlIdentifier id) {
399398 cluster ,
400399 PplConvertletTable .INSTANCE ,
401400 sql2relConfig );
402- RelRoot validatedRelRoot = sql2rel .convertQuery (rewritten , false , true );
403- return validatedRelRoot . rel .accept (new PplRelToSqlRelShuttle (context .rexBuilder , false ));
401+ RelNode validatedRel = sql2rel .convertQuery (rewritten , false , true ). project ( );
402+ return validatedRel .accept (new PplRelToSqlRelShuttle (context .rexBuilder , false ));
404403 }
405404
406405 /** Translate {@link LogicalPlan} to {@link PhysicalPlan}. */
You can’t perform that action at this time.
0 commit comments