You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/12/05 03:02:55 UTC
[iotdb] branch master updated: [IOTDB-5102] Support Align by deivce in VisitExplain (#8287)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 985b1bb16d [IOTDB-5102] Support Align by deivce in VisitExplain (#8287)
985b1bb16d is described below
commit 985b1bb16d20caf270edd80740d7ed24c06e032a
Author: YangCaiyin <yc...@gmail.com>
AuthorDate: Mon Dec 5 11:02:49 2022 +0800
[IOTDB-5102] Support Align by deivce in VisitExplain (#8287)
---
.../plan/execution/memory/StatementMemorySourceVisitor.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/memory/StatementMemorySourceVisitor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/memory/StatementMemorySourceVisitor.java
index 81a07bad51..44a131ec02 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/memory/StatementMemorySourceVisitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/memory/StatementMemorySourceVisitor.java
@@ -68,6 +68,13 @@ public class StatementMemorySourceVisitor
new TsBlock(0), datasetHeader == null ? EMPTY_HEADER : datasetHeader);
}
+ private boolean sourceNotExist(StatementMemorySourceContext context) {
+ return (context.getAnalysis().getSourceExpressions() == null
+ || context.getAnalysis().getSourceExpressions().isEmpty())
+ && (context.getAnalysis().getDeviceToSourceExpressions() == null
+ || context.getAnalysis().getDeviceToSourceExpressions().isEmpty());
+ }
+
@Override
public StatementMemorySource visitExplain(
ExplainStatement node, StatementMemorySourceContext context) {
@@ -77,8 +84,7 @@ public class StatementMemorySourceVisitor
Collections.singletonList(
new ColumnHeader(IoTDBConstant.COLUMN_DISTRIBUTION_PLAN, TSDataType.TEXT)),
true);
- if (context.getAnalysis().getSourceExpressions() == null
- || context.getAnalysis().getSourceExpressions().isEmpty()) {
+ if (sourceNotExist(context)) {
return new StatementMemorySource(new TsBlock(0), header);
}
LogicalQueryPlan logicalPlan =