This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch QueryPerformace in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1acd200a77d9aeefe3f2430358c8efdb67583ed2 Author: Minghui Liu <[email protected]> AuthorDate: Wed Jun 22 22:44:18 2022 +0800 fix descendingAggregations --- .../iotdb/db/mpp/plan/planner/LogicalPlanBuilder.java | 2 +- .../iotdb/db/mpp/plan/statement/component/OrderBy.java | 13 ++++++++++++- 2 files changed, 13 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanBuilder.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanBuilder.java index 3f0eed38de..5a9dbd4dac 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanBuilder.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LogicalPlanBuilder.java @@ -325,7 +325,7 @@ public class LogicalPlanBuilder { createAggregationScanNode( pathAggregationsEntry.getKey(), pathAggregationsEntry.getValue(), - scanOrder, + scanOrder.reverse(), null, timeFilter)); } diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java index 87ccef0959..e72029b7d4 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java @@ -24,5 +24,16 @@ public enum OrderBy { TIMESTAMP_ASC, TIMESTAMP_DESC, DEVICE_ASC, - DEVICE_DESC + DEVICE_DESC; + + public OrderBy reverse() { + switch (this) { + case TIMESTAMP_ASC: + return TIMESTAMP_DESC; + case TIMESTAMP_DESC: + return TIMESTAMP_ASC; + default: + throw new UnsupportedOperationException(); + } + } }
