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 2024/04/19 01:22:04 UTC
(iotdb) branch ty/TableModelGrammar updated: fix init
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch ty/TableModelGrammar
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ty/TableModelGrammar by this push:
new 6b657db3d83 fix init
6b657db3d83 is described below
commit 6b657db3d83bd2bf46b12d21749ec401791cbe2f
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri Apr 19 09:21:54 2024 +0800
fix init
---
.../execution/operator/source/relational/TableScanOperator.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableScanOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableScanOperator.java
index 43267e3005f..89853d8d6bb 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableScanOperator.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/TableScanOperator.java
@@ -75,7 +75,7 @@ public class TableScanOperator extends AbstractDataSourceOperator {
private final List<TSDataType> measurementColumnTSDataTypes;
- private final TsBlockBuilder measurementDataBuilder;
+ private TsBlockBuilder measurementDataBuilder;
private final int maxTsBlockLineNum;
@@ -120,9 +120,6 @@ public class TableScanOperator extends AbstractDataSourceOperator {
this.maxTsBlockLineNum = maxTsBlockLineNum;
this.seriesScanUtil = constructAlignedSeriesScanUtil(deviceEntries.get(currentDeviceIndex));
-
- this.measurementDataBuilder = new TsBlockBuilder(this.measurementColumnTSDataTypes);
- this.resultTsBlockBuilder.setMaxTsBlockLineNumber(this.maxTsBlockLineNum);
}
@Override
@@ -334,6 +331,8 @@ public class TableScanOperator extends AbstractDataSourceOperator {
this.seriesScanUtil.initQueryDataSource(dataSource);
this.resultTsBlockBuilder = new TsBlockBuilder(getResultDataTypes());
this.resultTsBlockBuilder.setMaxTsBlockLineNumber(this.maxTsBlockLineNum);
+ this.measurementDataBuilder = new TsBlockBuilder(this.measurementColumnTSDataTypes);
+ this.measurementDataBuilder.setMaxTsBlockLineNumber(this.maxTsBlockLineNum);
}
private void prepareForNextDevice() {