Skip to content

Commit 4b414a2

Browse files
committed
fix
Signed-off-by: Weihao Li <18110526956@163.com>
1 parent c145cf0 commit 4b414a2

1 file changed

Lines changed: 3 additions & 11 deletions

File tree

  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/SortElimination.java

Lines changed: 3 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -121,7 +121,9 @@ public PlanNode visitSort(SortNode node, Context context) {
121121
&& orderingScheme.getOrderBy().get(0).getName().equals(context.getTimeColumnName())) {
122122
return child;
123123
}
124-
return node.replaceChildren(Collections.singletonList(child));
124+
return context.canEliminateSort() && node.isOrderByAllIdsAndTime()
125+
? child
126+
: node.replaceChildren(Collections.singletonList(child));
125127
}
126128

127129
@Override
@@ -196,8 +198,6 @@ private static class Context {
196198

197199
private String timeColumnName = null;
198200

199-
private boolean sortEliminated = false;
200-
201201
Context() {}
202202

203203
public void addDeviceEntrySize(int deviceEntrySize) {
@@ -223,13 +223,5 @@ public String getTimeColumnName() {
223223
public void setTimeColumnName(String timeColumnName) {
224224
this.timeColumnName = timeColumnName;
225225
}
226-
227-
public boolean isSortEliminated() {
228-
return sortEliminated;
229-
}
230-
231-
public void markSortEliminated() {
232-
this.sortEliminated = true;
233-
}
234226
}
235227
}

0 commit comments

Comments
 (0)