This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch OptGroupByQuery in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7980fdb84b7f4e257d4d34462d9c430b519fa3e1 Author: JackieTien97 <[email protected]> AuthorDate: Fri Mar 21 11:41:01 2025 +0800 ignore mods --- .../apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java | 5 ++++- .../queryengine/execution/fragment/FakedFragmentInstanceContext.java | 4 ++++ .../apache/iotdb/db/queryengine/execution/fragment/QueryContext.java | 2 +- 3 files changed, 9 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java index e66e626c109..e5822c5c6cf 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/ClientRPCServiceImpl.java @@ -650,6 +650,9 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler { } } + private final List<InputLocation[]> inputLocationList = + Collections.singletonList(new InputLocation[] {new InputLocation(0, 0)}); + @SuppressWarnings("java:S2095") // close() do nothing private List<TsBlock> executeGroupByQueryInternal( SessionInfo sessionInfo, @@ -697,7 +700,7 @@ public class ClientRPCServiceImpl implements IClientRPCServiceWithHandler { true, true), AggregationStep.SINGLE, - Collections.singletonList(new InputLocation[] {new InputLocation(0, 0)})); + inputLocationList); GroupByTimeParameter groupByTimeParameter = new GroupByTimeParameter( diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FakedFragmentInstanceContext.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FakedFragmentInstanceContext.java index b814fe96885..143d78dfa20 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FakedFragmentInstanceContext.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FakedFragmentInstanceContext.java @@ -98,4 +98,8 @@ public class FakedFragmentInstanceContext extends FragmentInstanceContext { sharedQueryDataSource = null; } } + + protected boolean checkIfModificationExists(TsFileResource tsFileResource) { + return false; + } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryContext.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryContext.java index c8352d5f5e5..f0a210e1edf 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryContext.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/QueryContext.java @@ -83,7 +83,7 @@ public class QueryContext { this.timeout = timeout; } - private boolean checkIfModificationExists(TsFileResource tsFileResource) { + protected boolean checkIfModificationExists(TsFileResource tsFileResource) { if (nonExistentModFiles.contains(tsFileResource.getTsFileID())) { return false; }
