This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch split-query-type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 7fae56261a937ab0d1e74d79c20b99984cf7c228 Author: Yongzao <[email protected]> AuthorDate: Wed Apr 15 13:37:45 2026 +0800 seems finish --- .../db/queryengine/common/MPPQueryContext.java | 2 +- .../db/queryengine/plan/analyze/AnalyzeUtils.java | 2 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 28 +++--- .../db/queryengine/plan/analyze/QueryType.java | 1 + .../queryengine/plan/execution/QueryExecution.java | 6 +- .../plan/execution/config/ConfigExecution.java | 2 +- .../execution/config/TableConfigTaskVisitor.java | 104 ++++++++++----------- .../relational/RelationalAuthorizerTask.java | 2 +- .../plan/execution/config/sys/AuthorizerTask.java | 2 +- .../relational/analyzer/StatementAnalyzer.java | 4 +- .../sql/ast/RelationalAuthorStatement.java | 2 +- .../plan/scheduler/ClusterScheduler.java | 2 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 4 +- .../metadata/AlterEncodingCompressorStatement.java | 2 +- .../metadata/AlterTimeSeriesDataTypeStatement.java | 2 +- .../metadata/CreateContinuousQueryStatement.java | 2 +- .../metadata/CreateFunctionStatement.java | 2 +- .../statement/metadata/CreateTriggerStatement.java | 2 +- .../metadata/DatabaseSchemaStatement.java | 2 +- .../metadata/DeleteDatabaseStatement.java | 2 +- .../metadata/DeleteTimeSeriesStatement.java | 2 +- .../metadata/DropContinuousQueryStatement.java | 2 +- .../statement/metadata/DropFunctionStatement.java | 2 +- .../statement/metadata/DropTriggerStatement.java | 2 +- .../statement/metadata/RemoveAINodeStatement.java | 2 +- .../metadata/RemoveConfigNodeStatement.java | 2 +- .../metadata/RemoveDataNodeStatement.java | 2 +- .../plan/statement/metadata/SetTTLStatement.java | 2 +- .../CreateExternalServiceStatement.java | 2 +- .../DropExternalServiceStatement.java | 2 +- .../StartExternalServiceStatement.java | 2 +- .../StopExternalServiceStatement.java | 2 +- .../metadata/model/CreateModelStatement.java | 2 +- .../metadata/model/CreateTrainingStatement.java | 2 +- .../metadata/model/DropModelStatement.java | 2 +- .../metadata/model/LoadModelStatement.java | 2 +- .../metadata/model/UnloadModelStatement.java | 2 +- .../metadata/pipe/AlterPipeStatement.java | 2 +- .../metadata/pipe/CreatePipePluginStatement.java | 2 +- .../metadata/pipe/CreatePipeStatement.java | 2 +- .../metadata/pipe/DropPipePluginStatement.java | 2 +- .../statement/metadata/pipe/DropPipeStatement.java | 2 +- .../metadata/pipe/StartPipeStatement.java | 2 +- .../statement/metadata/pipe/StopPipeStatement.java | 2 +- .../metadata/region/ExtendRegionStatement.java | 2 +- .../metadata/region/MigrateRegionStatement.java | 2 +- .../region/ReconstructRegionStatement.java | 2 +- .../metadata/region/RemoveRegionStatement.java | 2 +- .../subscription/CreateTopicStatement.java | 2 +- .../subscription/DropSubscriptionStatement.java | 2 +- .../metadata/subscription/DropTopicStatement.java | 2 +- .../template/AlterSchemaTemplateStatement.java | 2 +- .../template/CreateSchemaTemplateStatement.java | 2 +- .../template/DeactivateTemplateStatement.java | 2 +- .../template/DropSchemaTemplateStatement.java | 2 +- .../template/SetSchemaTemplateStatement.java | 2 +- .../template/UnsetSchemaTemplateStatement.java | 2 +- .../metadata/view/AlterLogicalViewStatement.java | 2 +- .../metadata/view/DeleteLogicalViewStatement.java | 2 +- .../metadata/view/RenameLogicalViewStatement.java | 2 +- .../plan/statement/sys/AuthorStatement.java | 2 +- .../plan/statement/sys/ClearCacheStatement.java | 2 +- .../plan/statement/sys/FlushStatement.java | 2 +- .../plan/statement/sys/KillQueryStatement.java | 2 +- .../statement/sys/LoadConfigurationStatement.java | 2 +- .../plan/statement/sys/MergeStatement.java | 2 +- .../statement/sys/SetConfigurationStatement.java | 2 +- .../plan/statement/sys/SetSqlDialectStatement.java | 2 +- .../statement/sys/SetSystemStatusStatement.java | 2 +- .../statement/sys/StartRepairDataStatement.java | 2 +- .../statement/sys/StopRepairDataStatement.java | 2 +- .../sys/quota/SetSpaceQuotaStatement.java | 2 +- .../sys/quota/SetThrottleQuotaStatement.java | 2 +- .../queryengine/execution/ConfigExecutionTest.java | 2 +- .../statement/sys/pipe/PipeStatementTest.java | 8 +- 75 files changed, 147 insertions(+), 144 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/MPPQueryContext.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/MPPQueryContext.java index 88bd1998f68..a507b98008b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/MPPQueryContext.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/MPPQueryContext.java @@ -500,7 +500,7 @@ public class MPPQueryContext implements IAuditEntity { } public boolean isQuery() { - return queryType != QueryType.WRITE; + return queryType == QueryType.READ || queryType == QueryType.READ_WRITE; } public void setUserQuery(boolean userQuery) { diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeUtils.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeUtils.java index 2e0b0b52fdc..4c30067a9b5 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeUtils.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeUtils.java @@ -311,7 +311,7 @@ public class AnalyzeUtils { } public static void analyzeDelete(final Delete node, final MPPQueryContext queryContext) { - queryContext.setQueryType(QueryType.WRITE); + queryContext.setQueryType(QueryType.OTHER); validateSchema(node, queryContext); try (final ConfigNodeClient configNodeClient = diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java index dacdc69ba45..e38267ab223 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/AnalyzeVisitor.java @@ -2492,7 +2492,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> @Override public Analysis visitCreateTimeseries( CreateTimeSeriesStatement createTimeSeriesStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); if (createTimeSeriesStatement.getPath().getNodeLength() < 3) { throw new SemanticException( new IllegalPathException(createTimeSeriesStatement.getPath().getFullPath())); @@ -2594,7 +2594,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> @Override public Analysis visitCreateAlignedTimeseries( CreateAlignedTimeSeriesStatement createAlignedTimeSeriesStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); if (createAlignedTimeSeriesStatement.getDevicePath().getNodeLength() < 2) { throw new SemanticException( new IllegalPathException(createAlignedTimeSeriesStatement.getDevicePath().getFullPath())); @@ -2632,7 +2632,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> public Analysis visitInternalCreateTimeseries( InternalCreateTimeSeriesStatement internalCreateTimeSeriesStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); Analysis analysis = new Analysis(); analysis.setRealStatement(internalCreateTimeSeriesStatement); @@ -2660,7 +2660,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> public Analysis visitInternalCreateMultiTimeSeries( final InternalCreateMultiTimeSeriesStatement internalCreateMultiTimeSeriesStatement, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Analysis analysis = new Analysis(); analysis.setRealStatement(internalCreateMultiTimeSeriesStatement); @@ -2685,7 +2685,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> public Analysis visitCreateMultiTimeSeries( final CreateMultiTimeSeriesStatement createMultiTimeSeriesStatement, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Analysis analysis = new Analysis(); analysis.setRealStatement(createMultiTimeSeriesStatement); @@ -2713,7 +2713,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> @Override public Analysis visitAlterTimeSeries( AlterTimeSeriesStatement alterTimeSeriesStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); Analysis analysis = new Analysis(); analysis.setRealStatement(alterTimeSeriesStatement); @@ -2900,7 +2900,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> @Override public Analysis visitLoadFile(LoadTsFileStatement loadTsFileStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); try (final LoadTsFileAnalyzer loadTsFileAnalyzer = new LoadTsFileAnalyzer( @@ -3391,7 +3391,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> @Override public Analysis visitDeleteData( DeleteDataStatement deleteDataStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); Analysis analysis = new Analysis(); analysis.setRealStatement(deleteDataStatement); @@ -3471,7 +3471,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> public Analysis visitCreateSchemaTemplate( CreateSchemaTemplateStatement createTemplateStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); List<String> measurements = createTemplateStatement.getMeasurements(); Set<String> measurementsSet = new HashSet<>(measurements); if (measurementsSet.size() < measurements.size()) { @@ -3486,7 +3486,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> @Override public Analysis visitSetSchemaTemplate( SetSchemaTemplateStatement setSchemaTemplateStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); Analysis analysis = new Analysis(); analysis.setRealStatement(setSchemaTemplateStatement); return analysis; @@ -3495,7 +3495,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> @Override public Analysis visitActivateTemplate( ActivateTemplateStatement activateTemplateStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); Analysis analysis = new Analysis(); analysis.setRealStatement(activateTemplateStatement); @@ -3525,7 +3525,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> @Override public Analysis visitBatchActivateTemplate( BatchActivateTemplateStatement batchActivateTemplateStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); Analysis analysis = new Analysis(); analysis.setRealStatement(batchActivateTemplateStatement); @@ -3561,7 +3561,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> public Analysis visitInternalBatchActivateTemplate( InternalBatchActivateTemplateStatement internalBatchActivateTemplateStatement, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); Analysis analysis = new Analysis(); analysis.setRealStatement(internalBatchActivateTemplateStatement); @@ -3751,7 +3751,7 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext> public Analysis visitCreateLogicalView( CreateLogicalViewStatement createLogicalViewStatement, MPPQueryContext context) { Analysis analysis = new Analysis(); - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); analysis.setRealStatement(createLogicalViewStatement); if (createLogicalViewStatement.getViewExpressions() == null) { diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/QueryType.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/QueryType.java index 59221e2f1cd..b2cac890746 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/QueryType.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/QueryType.java @@ -20,6 +20,7 @@ package org.apache.iotdb.db.queryengine.plan.analyze; public enum QueryType { + OTHER, WRITE, READ, // Currently READ_WRITE is only used by insert into query, which means it behaves as a READ query diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java index 7500fbb9c34..97070e37357 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/QueryExecution.java @@ -212,7 +212,7 @@ public class QueryExecution implements IQueryExecution { // When some columns in one insert failed, other column will continue executing insertion. // The error message should be return to client, therefore we need to set it after the insertion // of other column finished. - if (context.getQueryType() == QueryType.WRITE && analysis.isFailed()) { + if (!context.isQuery() && analysis.isFailed()) { stateMachine.transitionToFailed(analysis.getFailStatus()); } } @@ -625,7 +625,7 @@ public class QueryExecution implements IQueryExecution { @SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity warning private ExecutionResult getExecutionResult(QueryState state) { TSStatusCode statusCode; - if (context.getQueryType() == QueryType.WRITE && analysis.isFailed()) { + if (!context.isQuery() && analysis.isFailed()) { // For WRITE, the state should be FINISHED statusCode = state == QueryState.FINISHED @@ -671,7 +671,7 @@ public class QueryExecution implements IQueryExecution { @Override public boolean isQuery() { - return context.getQueryType() != QueryType.WRITE; + return context.isQuery(); } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java index 75f5ddd25bf..a3fde74fa41 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/ConfigExecution.java @@ -306,7 +306,7 @@ public class ConfigExecution implements IQueryExecution { @Override public boolean isQuery() { - return context.getQueryType() != QueryType.WRITE; + return context.isQuery(); } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java index 320c904ac20..0bb2efa9fd5 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/TableConfigTaskVisitor.java @@ -331,7 +331,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont private IConfigTask visitDatabaseStatement( final DatabaseStatement node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final TDatabaseSchema schema = new TDatabaseSchema(); schema.setIsTableModel(true); @@ -398,7 +398,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitUse(final Use node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkCanShowOrUseDatabase( context.getSession().getUserName(), node.getDatabaseId().getValue(), context); return new UseDBTask(node, clientSession); @@ -406,7 +406,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropDB(final DropDB node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkCanDropDatabase( context.getSession().getUserName(), node.getDbName().getValue(), context); return new DropDBTask(node, clientSession); @@ -466,7 +466,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitRemoveDataNode( final RemoveDataNode removeDataNode, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); // As the implementation is identical, we'll simply translate to the // corresponding tree-model variant and execute that. @@ -478,7 +478,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitRemoveConfigNode( final RemoveConfigNode removeConfigNode, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); // As the implementation is identical, we'll simply translate to the // corresponding tree-model variant and execute that. @@ -490,7 +490,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitRemoveAINode( final RemoveAINode removeAINode, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); // As the implementation is identical, we'll simply translate to the // corresponding tree-model variant and execute that. @@ -534,7 +534,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitClearCache( final ClearCache clearCacheStatement, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new ClearCacheTask(clearCacheStatement); } @@ -564,7 +564,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont private Pair<String, TsTable> parseTable4CreateTableOrView( final CreateTable node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getName()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -665,7 +665,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitAlterColumnDataType( AlterColumnDataType node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getTableName()); final String columnName = node.getColumnName().getValue(); final DataType dataType = node.getDataType(); @@ -688,7 +688,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitRenameTable(final RenameTable node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getSource()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -712,7 +712,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitAddColumn(final AddColumn node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getTableName()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -745,7 +745,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitRenameColumn(final RenameColumn node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getTable()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -772,7 +772,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropColumn(final DropColumn node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getTable()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -793,7 +793,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitSetProperties( final SetProperties node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getName()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -813,7 +813,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitSetTableComment( final SetTableComment node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getTableName()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -833,7 +833,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitSetColumnComment( final SetColumnComment node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getTable()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -919,7 +919,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropTable(final DropTable node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final Pair<String, String> databaseTablePair = splitQualifiedName(node.getTableName()); final String database = databaseTablePair.getLeft(); final String tableName = databaseTablePair.getRight(); @@ -1012,14 +1012,14 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitFlush(final Flush node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new FlushTask(((FlushStatement) node.getInnerTreeStatement())); } @Override protected IConfigTask visitSetConfiguration(SetConfiguration node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); SetConfigurationStatement setConfigurationStatement = (SetConfigurationStatement) node.getInnerTreeStatement(); try { @@ -1049,28 +1049,28 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitStartRepairData(StartRepairData node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new StartRepairDataTask(((StartRepairDataStatement) node.getInnerTreeStatement())); } @Override protected IConfigTask visitStopRepairData(StopRepairData node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new StopRepairDataTask(((StopRepairDataStatement) node.getInnerTreeStatement())); } @Override protected IConfigTask visitLoadConfiguration(LoadConfiguration node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserIsAdmin(context.getSession().getUserEntity()); return new LoadConfigurationTask(((LoadConfigurationStatement) node.getInnerTreeStatement())); } @Override protected IConfigTask visitSetSystemStatus(SetSystemStatus node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new SetSystemStatusTask(((SetSystemStatusStatement) node.getInnerTreeStatement())); } @@ -1121,7 +1121,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitCreatePipe(final CreatePipe node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); final Map<String, String> sourceAttributes = node.getSourceAttributes(); @@ -1268,7 +1268,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitAlterPipe(final AlterPipe node, final MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); final String userName = context.getSession().getUserName(); accessControl.checkUserGlobalSysPrivilege(context); @@ -1315,21 +1315,21 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropPipe(DropPipe node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new DropPipeTask(node); } @Override protected IConfigTask visitStartPipe(StartPipe node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new StartPipeTask(node); } @Override protected IConfigTask visitStopPipe(StopPipe node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new StopPipeTask(node); } @@ -1342,7 +1342,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitCreatePipePlugin(CreatePipePlugin node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); if (node.getUriString() != null && isUriTrusted(node.getUriString())) { // 1. user specified uri and that uri is trusted @@ -1356,7 +1356,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropPipePlugin(DropPipePlugin node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new DropPipePluginTask(node); } @@ -1370,7 +1370,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitCreateTopic(CreateTopic node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); // Inject table model into the topic attributes @@ -1382,7 +1382,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropTopic(DropTopic node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new DropTopicTask(node); } @@ -1403,7 +1403,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropSubscription(DropSubscription node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new DropSubscriptionTask(node); } @@ -1423,19 +1423,19 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitSetSqlDialect(SetSqlDialect node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); return new SetSqlDialectTask(node.getSqlDialect()); } @Override protected IConfigTask visitPrepare(Prepare node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); return new PrepareTask(node.getStatementName().getValue(), node.getSql()); } @Override protected IConfigTask visitDeallocate(Deallocate node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); return new DeallocateTask(node.getStatementName().getValue()); } @@ -1500,7 +1500,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitKillQuery(KillQuery node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); String allowedUsername = context.getSession().getUserName(); if (accessControl.hasGlobalPrivilege( context.getSession().getUserEntity(), PrivilegeType.SYSTEM)) { @@ -1511,7 +1511,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitCreateFunction(CreateFunction node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); if (node.getUriString().map(ExecutableManager::isUriTrusted).orElse(true)) { // 1. user specified uri and that uri is trusted @@ -1531,7 +1531,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropFunction(DropFunction node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new DropFunctionTask(Model.TABLE, node.getUdfName()); } @@ -1539,7 +1539,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitCreateExternalService( CreateExternalService node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new CreateExternalServiceTask(node); } @@ -1547,7 +1547,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitStartExternalService( StartExternalService node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new StartExternalServiceTask(node.getServiceName()); } @@ -1555,7 +1555,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitStopExternalService( StopExternalService node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new StopExternalServiceTask(node.getServiceName()); } @@ -1563,14 +1563,14 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropExternalService( DropExternalService node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new DropExternalServiceTask(node.getServiceName(), node.isForcedly()); } @Override protected IConfigTask visitMigrateRegion(MigrateRegion migrateRegion, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); // As the implementation is identical, we'll simply translate to the // corresponding tree-model variant and execute that. @@ -1580,7 +1580,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitReconstructRegion( ReconstructRegion reconstructRegion, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); // As the implementation is identical, we'll simply translate to the // corresponding tree-model variant and execute that. @@ -1589,7 +1589,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitExtendRegion(ExtendRegion extendRegion, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); // As the implementation is identical, we'll simply translate to the // corresponding tree-model variant and execute that. @@ -1598,7 +1598,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitRemoveRegion(RemoveRegion removeRegion, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); // As the implementation is identical, we'll simply translate to the // corresponding tree-model variant and execute that. @@ -1607,7 +1607,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitCreateTraining(CreateTraining node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new CreateTuningTask( node.getModelId(), node.getParameters(), node.getExistingModelId(), node.getTargetSql()); @@ -1615,7 +1615,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitCreateModel(CreateModel node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); String uri = node.getUri(); if (uri != null && ExecutableManager.isUriTrusted(uri)) { @@ -1634,7 +1634,7 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitDropModel(DropModel node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new DropModelTask(node.getModelId()); } @@ -1654,14 +1654,14 @@ public class TableConfigTaskVisitor extends AstVisitor<IConfigTask, MPPQueryCont @Override protected IConfigTask visitLoadModel(LoadModel node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new LoadModelTask(node.getModelId(), node.getDeviceIdList()); } @Override protected IConfigTask visitUnloadModel(UnloadModel node, MPPQueryContext context) { - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); accessControl.checkUserGlobalSysPrivilege(context); return new UnloadModelTask(node.getModelId(), node.getDeviceIdList()); } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/RelationalAuthorizerTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/RelationalAuthorizerTask.java index a3f8fbd92b1..7b415406a92 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/RelationalAuthorizerTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/RelationalAuthorizerTask.java @@ -36,7 +36,7 @@ public class RelationalAuthorizerTask implements IConfigTask { @Override public ListenableFuture<ConfigTaskResult> execute(IConfigTaskExecutor configTaskExecutor) { - if (statement.getQueryType() == QueryType.WRITE) { + if (statement.getQueryType() != QueryType.READ && statement.getQueryType() != QueryType.READ_WRITE) { return AuthorityChecker.operatePermission(statement); } else { return AuthorityChecker.queryPermission(statement); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/AuthorizerTask.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/AuthorizerTask.java index 96a5414a4df..1f26ba5abf9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/AuthorizerTask.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/AuthorizerTask.java @@ -40,7 +40,7 @@ public class AuthorizerTask implements IConfigTask { public ListenableFuture<ConfigTaskResult> execute(IConfigTaskExecutor configTaskExecutor) { // If the action is executed successfully, return the Future. // If your operation is async, you can return the corresponding future directly. - if (authorStatement.getQueryType() == QueryType.WRITE) { + if (authorStatement.getQueryType() != QueryType.READ && authorStatement.getQueryType() != QueryType.READ_WRITE) { return AuthorityChecker.operatePermission(authorStatement); } else { return AuthorityChecker.queryPermission(authorStatement); diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java index cff29c0d83a..a438ef165ba 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/StatementAnalyzer.java @@ -827,7 +827,7 @@ public class StatementAnalyzer { @Override protected Scope visitLoadTsFile(final LoadTsFile node, final Optional<Scope> scope) { - queryContext.setQueryType(QueryType.WRITE); + queryContext.setQueryType(QueryType.OTHER); try (final LoadTsFileAnalyzer loadTsFileAnalyzer = new LoadTsFileAnalyzer(node, node.isGeneratedByPipe(), queryContext)) { @@ -4548,7 +4548,7 @@ public class StatementAnalyzer { @Override protected Scope visitCreateOrUpdateDevice( final CreateOrUpdateDevice node, final Optional<Scope> context) { - queryContext.setQueryType(QueryType.WRITE); + queryContext.setQueryType(QueryType.OTHER); DataNodeSchemaLockManager.getInstance() .takeReadLock(queryContext, SchemaLockType.VALIDATE_VS_DELETION_TABLE); // Check if the table exists diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/RelationalAuthorStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/RelationalAuthorStatement.java index 8509b21987d..f7791025492 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/RelationalAuthorStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/RelationalAuthorStatement.java @@ -261,7 +261,7 @@ public class RelationalAuthorStatement extends Statement { case REVOKE_USER_ROLE: case RENAME_USER: case ACCOUNT_UNLOCK: - return QueryType.WRITE; + return QueryType.OTHER; case LIST_ROLE: case LIST_USER: case LIST_ROLE_PRIV: diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/ClusterScheduler.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/ClusterScheduler.java index f8d288d8e87..5add18a59a9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/ClusterScheduler.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/ClusterScheduler.java @@ -175,6 +175,6 @@ public class ClusterScheduler implements IScheduler { } private boolean isQuery() { - return queryType != QueryType.WRITE; + return queryType == QueryType.READ || queryType == QueryType.READ_WRITE; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java index 18ab1cdc275..c52f8f94eb2 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/FragmentInstanceDispatcherImpl.java @@ -507,6 +507,7 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher { } break; case WRITE: + case OTHER: final TSendBatchPlanNodeReq sendPlanNodeReq = new TSendBatchPlanNodeReq( Collections.singletonList( @@ -644,6 +645,7 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher { } break; case WRITE: + case OTHER: final PlanNode planNode = instance.getFragment().getPlanNodeTree(); final RegionWriteExecutor writeExecutor = new RegionWriteExecutor(); final RegionExecutionResult writeResult = writeExecutor.execute(groupId, planNode); @@ -682,6 +684,6 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher { public void abort() {} private boolean isQuery() { - return type != QueryType.WRITE; + return type == QueryType.READ || type == QueryType.READ_WRITE; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java index a8dd88841a4..fbad38ec6f0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java @@ -121,6 +121,6 @@ public class AlterEncodingCompressorStatement extends Statement implements IConf @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterTimeSeriesDataTypeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterTimeSeriesDataTypeStatement.java index d2a740ae5ba..029b0e1ef07 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterTimeSeriesDataTypeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterTimeSeriesDataTypeStatement.java @@ -39,6 +39,6 @@ public class AlterTimeSeriesDataTypeStatement extends AlterTimeSeriesStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateContinuousQueryStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateContinuousQueryStatement.java index 92cd2e05722..a6261377c8c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateContinuousQueryStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateContinuousQueryStatement.java @@ -155,7 +155,7 @@ public class CreateContinuousQueryStatement extends Statement implements IConfig @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateFunctionStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateFunctionStatement.java index baa7a4a295b..c524cbc7902 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateFunctionStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateFunctionStatement.java @@ -63,7 +63,7 @@ public class CreateFunctionStatement extends Statement implements IConfigStateme @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateTriggerStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateTriggerStatement.java index 2a1affe577e..53ba59075fd 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateTriggerStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/CreateTriggerStatement.java @@ -110,7 +110,7 @@ public class CreateTriggerStatement extends Statement implements IConfigStatemen @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DatabaseSchemaStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DatabaseSchemaStatement.java index 53ff33e2437..9fc9f2704f0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DatabaseSchemaStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DatabaseSchemaStatement.java @@ -131,7 +131,7 @@ public class DatabaseSchemaStatement extends Statement implements IConfigStateme @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DeleteDatabaseStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DeleteDatabaseStatement.java index 6b538267555..0f7aed62ef7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DeleteDatabaseStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DeleteDatabaseStatement.java @@ -72,6 +72,6 @@ public class DeleteDatabaseStatement extends Statement implements IConfigStateme @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DeleteTimeSeriesStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DeleteTimeSeriesStatement.java index d51aee564a3..b24fe95096e 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DeleteTimeSeriesStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DeleteTimeSeriesStatement.java @@ -63,7 +63,7 @@ public class DeleteTimeSeriesStatement extends Statement implements IConfigState @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } public void setMayDeleteAudit(boolean mayDeleteAudit) { diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropContinuousQueryStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropContinuousQueryStatement.java index 12932d8a8d0..68336517a88 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropContinuousQueryStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropContinuousQueryStatement.java @@ -45,7 +45,7 @@ public class DropContinuousQueryStatement extends Statement implements IConfigSt @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropFunctionStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropFunctionStatement.java index 14a7d8b6868..d80af227e68 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropFunctionStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropFunctionStatement.java @@ -50,7 +50,7 @@ public class DropFunctionStatement extends Statement implements IConfigStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropTriggerStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropTriggerStatement.java index 96a07a11635..fd7a8b099f0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropTriggerStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/DropTriggerStatement.java @@ -49,7 +49,7 @@ public class DropTriggerStatement extends Statement implements IConfigStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveAINodeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveAINodeStatement.java index b8ee3d6f08b..2f4a9df4325 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveAINodeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveAINodeStatement.java @@ -53,7 +53,7 @@ public class RemoveAINodeStatement extends Statement implements IConfigStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveConfigNodeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveConfigNodeStatement.java index 3851ecb0e1e..54b906560d3 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveConfigNodeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveConfigNodeStatement.java @@ -47,7 +47,7 @@ public class RemoveConfigNodeStatement extends Statement implements IConfigState @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveDataNodeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveDataNodeStatement.java index 44a6ddc6907..23a03ca6aa3 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveDataNodeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/RemoveDataNodeStatement.java @@ -50,7 +50,7 @@ public class RemoveDataNodeStatement extends Statement implements IConfigStateme @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/SetTTLStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/SetTTLStatement.java index c71a7ecb35e..2e2284b12e9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/SetTTLStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/SetTTLStatement.java @@ -61,7 +61,7 @@ public class SetTTLStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/CreateExternalServiceStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/CreateExternalServiceStatement.java index 3e85b2ad0a2..f6466a86f07 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/CreateExternalServiceStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/CreateExternalServiceStatement.java @@ -58,7 +58,7 @@ public class CreateExternalServiceStatement extends Statement implements IConfig @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/DropExternalServiceStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/DropExternalServiceStatement.java index 64a72e3efbb..babcbd433fe 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/DropExternalServiceStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/DropExternalServiceStatement.java @@ -58,7 +58,7 @@ public class DropExternalServiceStatement extends Statement implements IConfigSt @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/StartExternalServiceStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/StartExternalServiceStatement.java index 37b6553e7cd..9565dabe186 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/StartExternalServiceStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/StartExternalServiceStatement.java @@ -52,7 +52,7 @@ public class StartExternalServiceStatement extends Statement implements IConfigS @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/StopExternalServiceStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/StopExternalServiceStatement.java index 6462210c6a3..928530bf5c4 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/StopExternalServiceStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/externalservice/StopExternalServiceStatement.java @@ -52,7 +52,7 @@ public class StopExternalServiceStatement extends Statement implements IConfigSt @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateModelStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateModelStatement.java index 2300af074a4..5d2bf56ce78 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateModelStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateModelStatement.java @@ -61,7 +61,7 @@ public class CreateModelStatement extends Statement implements IConfigStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateTrainingStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateTrainingStatement.java index 0628c22ae2b..4aed87dde33 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateTrainingStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateTrainingStatement.java @@ -120,7 +120,7 @@ public class CreateTrainingStatement extends Statement implements IConfigStateme @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/DropModelStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/DropModelStatement.java index 34ba98207e4..d3fd47344a4 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/DropModelStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/DropModelStatement.java @@ -47,7 +47,7 @@ public class DropModelStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/LoadModelStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/LoadModelStatement.java index e3e2e3bc4f4..02ea3fd9d02 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/LoadModelStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/LoadModelStatement.java @@ -49,7 +49,7 @@ public class LoadModelStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/UnloadModelStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/UnloadModelStatement.java index be5057a8f00..5aa65fb17c7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/UnloadModelStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/UnloadModelStatement.java @@ -49,7 +49,7 @@ public class UnloadModelStatement extends Statement implements IConfigStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/AlterPipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/AlterPipeStatement.java index a3738a15fbd..250b349b0e1 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/AlterPipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/AlterPipeStatement.java @@ -129,7 +129,7 @@ public class AlterPipeStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipePluginStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipePluginStatement.java index e1b22ea9de7..0147da9a643 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipePluginStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipePluginStatement.java @@ -74,7 +74,7 @@ public class CreatePipePluginStatement extends Statement implements IConfigState @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipeStatement.java index 718283182a7..e7d8591c71c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/CreatePipeStatement.java @@ -84,7 +84,7 @@ public class CreatePipeStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipePluginStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipePluginStatement.java index 24b44f85cf6..d37ff02f730 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipePluginStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipePluginStatement.java @@ -66,7 +66,7 @@ public class DropPipePluginStatement extends Statement implements IConfigStateme @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipeStatement.java index 3099a8d5dd5..39ee68fe9e1 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/DropPipeStatement.java @@ -65,7 +65,7 @@ public class DropPipeStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StartPipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StartPipeStatement.java index 1122310b001..df46daf3141 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StartPipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StartPipeStatement.java @@ -56,7 +56,7 @@ public class StartPipeStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StopPipeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StopPipeStatement.java index 23bb60ae39c..2930cfe3c29 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StopPipeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/pipe/StopPipeStatement.java @@ -56,7 +56,7 @@ public class StopPipeStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/ExtendRegionStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/ExtendRegionStatement.java index 353cb119553..4b2961038d1 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/ExtendRegionStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/ExtendRegionStatement.java @@ -54,7 +54,7 @@ public class ExtendRegionStatement extends Statement implements IConfigStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/MigrateRegionStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/MigrateRegionStatement.java index 616357f5379..f13323542bb 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/MigrateRegionStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/MigrateRegionStatement.java @@ -70,7 +70,7 @@ public class MigrateRegionStatement extends Statement implements IConfigStatemen @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/ReconstructRegionStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/ReconstructRegionStatement.java index cd22e61ad7f..f5b97f1ce3b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/ReconstructRegionStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/ReconstructRegionStatement.java @@ -52,7 +52,7 @@ public class ReconstructRegionStatement extends Statement implements IConfigStat @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/RemoveRegionStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/RemoveRegionStatement.java index f64d6d84fe1..44eec637c81 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/RemoveRegionStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/region/RemoveRegionStatement.java @@ -54,7 +54,7 @@ public class RemoveRegionStatement extends Statement implements IConfigStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/CreateTopicStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/CreateTopicStatement.java index 7d1d59c44f4..4dd493a963b 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/CreateTopicStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/CreateTopicStatement.java @@ -67,7 +67,7 @@ public class CreateTopicStatement extends Statement implements IConfigStatement @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/DropSubscriptionStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/DropSubscriptionStatement.java index fb64cfdeb8e..dfae59c61c8 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/DropSubscriptionStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/DropSubscriptionStatement.java @@ -66,7 +66,7 @@ public class DropSubscriptionStatement extends Statement implements IConfigState @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/DropTopicStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/DropTopicStatement.java index 5c7d7d115f6..9f745c72de4 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/DropTopicStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/subscription/DropTopicStatement.java @@ -66,7 +66,7 @@ public class DropTopicStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/AlterSchemaTemplateStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/AlterSchemaTemplateStatement.java index ef86d01d94e..ab352f84bd2 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/AlterSchemaTemplateStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/AlterSchemaTemplateStatement.java @@ -74,7 +74,7 @@ public class AlterSchemaTemplateStatement extends Statement implements IConfigSt @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/CreateSchemaTemplateStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/CreateSchemaTemplateStatement.java index 807a83491b3..72c4142ab71 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/CreateSchemaTemplateStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/CreateSchemaTemplateStatement.java @@ -112,6 +112,6 @@ public class CreateSchemaTemplateStatement extends Statement implements IConfigS @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/DeactivateTemplateStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/DeactivateTemplateStatement.java index 7057003d394..152873dda07 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/DeactivateTemplateStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/DeactivateTemplateStatement.java @@ -103,6 +103,6 @@ public class DeactivateTemplateStatement extends Statement implements IConfigSta @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/DropSchemaTemplateStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/DropSchemaTemplateStatement.java index ff4237fdb8e..e0c9500b528 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/DropSchemaTemplateStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/DropSchemaTemplateStatement.java @@ -54,7 +54,7 @@ public class DropSchemaTemplateStatement extends Statement implements IConfigSta @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/SetSchemaTemplateStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/SetSchemaTemplateStatement.java index e8a384cd820..743baca57bc 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/SetSchemaTemplateStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/SetSchemaTemplateStatement.java @@ -69,6 +69,6 @@ public class SetSchemaTemplateStatement extends Statement implements IConfigStat @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/UnsetSchemaTemplateStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/UnsetSchemaTemplateStatement.java index 4240007257d..834ab56dab7 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/UnsetSchemaTemplateStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/template/UnsetSchemaTemplateStatement.java @@ -64,7 +64,7 @@ public class UnsetSchemaTemplateStatement extends Statement implements IConfigSt @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/AlterLogicalViewStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/AlterLogicalViewStatement.java index 8bca6b8f5d1..ce7c1f906bc 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/AlterLogicalViewStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/AlterLogicalViewStatement.java @@ -126,6 +126,6 @@ public class AlterLogicalViewStatement extends Statement implements IConfigState @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/DeleteLogicalViewStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/DeleteLogicalViewStatement.java index f09ab0829f2..c1d960f6877 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/DeleteLogicalViewStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/DeleteLogicalViewStatement.java @@ -61,6 +61,6 @@ public class DeleteLogicalViewStatement extends Statement implements IConfigStat @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/RenameLogicalViewStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/RenameLogicalViewStatement.java index af1246d5339..115437f3a1c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/RenameLogicalViewStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/RenameLogicalViewStatement.java @@ -68,6 +68,6 @@ public class RenameLogicalViewStatement extends Statement implements IConfigStat @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/AuthorStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/AuthorStatement.java index ecc10a8ae7a..af6a94e9055 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/AuthorStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/AuthorStatement.java @@ -236,7 +236,7 @@ public class AuthorStatement extends Statement implements IConfigStatement { case UPDATE_USER: case RENAME_USER: case ACCOUNT_UNLOCK: - queryType = QueryType.WRITE; + queryType = QueryType.OTHER; break; case LIST_USER: case LIST_ROLE: diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ClearCacheStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ClearCacheStatement.java index 3b317396366..d2bcfc1e772 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ClearCacheStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/ClearCacheStatement.java @@ -58,7 +58,7 @@ public class ClearCacheStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/FlushStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/FlushStatement.java index 24d5458a1f0..894427eb9af 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/FlushStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/FlushStatement.java @@ -71,7 +71,7 @@ public class FlushStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/KillQueryStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/KillQueryStatement.java index f5f236f1b91..f2d6f59229a 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/KillQueryStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/KillQueryStatement.java @@ -69,6 +69,6 @@ public class KillQueryStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/LoadConfigurationStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/LoadConfigurationStatement.java index 12ccafacf80..e1fc1d13a70 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/LoadConfigurationStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/LoadConfigurationStatement.java @@ -46,7 +46,7 @@ public class LoadConfigurationStatement extends Statement implements IConfigStat @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/MergeStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/MergeStatement.java index 29d1fbc8f05..2b327c76094 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/MergeStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/MergeStatement.java @@ -47,7 +47,7 @@ public class MergeStatement extends Statement implements IConfigStatement { @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetConfigurationStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetConfigurationStatement.java index 06c438481a9..58e15e59cef 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetConfigurationStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetConfigurationStatement.java @@ -64,7 +64,7 @@ public class SetConfigurationStatement extends Statement implements IConfigState @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetSqlDialectStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetSqlDialectStatement.java index 75cbbee32e6..391301934fe 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetSqlDialectStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetSqlDialectStatement.java @@ -58,7 +58,7 @@ public class SetSqlDialectStatement extends Statement implements IConfigStatemen @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetSystemStatusStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetSystemStatusStatement.java index 4fdf7a2cd09..6a4b6a05bb0 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetSystemStatusStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/SetSystemStatusStatement.java @@ -57,7 +57,7 @@ public class SetSystemStatusStatement extends Statement implements IConfigStatem @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/StartRepairDataStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/StartRepairDataStatement.java index 24bed11fd6e..73fd1ddf8ea 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/StartRepairDataStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/StartRepairDataStatement.java @@ -52,7 +52,7 @@ public class StartRepairDataStatement extends Statement implements IConfigStatem @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/StopRepairDataStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/StopRepairDataStatement.java index 698c6dc0853..55a8426bf2f 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/StopRepairDataStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/StopRepairDataStatement.java @@ -52,7 +52,7 @@ public class StopRepairDataStatement extends Statement implements IConfigStateme @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/quota/SetSpaceQuotaStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/quota/SetSpaceQuotaStatement.java index bc92d45704b..eef29f36511 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/quota/SetSpaceQuotaStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/quota/SetSpaceQuotaStatement.java @@ -85,7 +85,7 @@ public class SetSpaceQuotaStatement extends Statement implements IConfigStatemen @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/quota/SetThrottleQuotaStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/quota/SetThrottleQuotaStatement.java index 5aa8b5bce41..2413d3edcd6 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/quota/SetThrottleQuotaStatement.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/quota/SetThrottleQuotaStatement.java @@ -79,7 +79,7 @@ public class SetThrottleQuotaStatement extends Statement implements IConfigState @Override public QueryType getQueryType() { - return QueryType.WRITE; + return QueryType.OTHER; } @Override diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/ConfigExecutionTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/ConfigExecutionTest.java index c49ea7cf35f..e2522b2730d 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/ConfigExecutionTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/ConfigExecutionTest.java @@ -159,7 +159,7 @@ public class ConfigExecutionTest { private MPPQueryContext genMPPQueryContext() { MPPQueryContext context = new MPPQueryContext(new QueryId("query1")); - context.setQueryType(QueryType.WRITE); + context.setQueryType(QueryType.OTHER); return context; } diff --git a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/statement/sys/pipe/PipeStatementTest.java b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/statement/sys/pipe/PipeStatementTest.java index 04fccc19560..9694c456373 100644 --- a/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/statement/sys/pipe/PipeStatementTest.java +++ b/iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/statement/sys/pipe/PipeStatementTest.java @@ -51,7 +51,7 @@ public class PipeStatementTest { Assert.assertEquals(processorAttributes, statement.getProcessorAttributes()); Assert.assertEquals(connectorAttributes, statement.getSinkAttributes()); - Assert.assertEquals(QueryType.WRITE, statement.getQueryType()); + Assert.assertEquals(QueryType.OTHER, statement.getQueryType()); } @Test @@ -59,7 +59,7 @@ public class PipeStatementTest { DropPipeStatement statement = new DropPipeStatement(StatementType.DROP_PIPE); statement.setPipeName("test"); Assert.assertEquals("test", statement.getPipeName()); - Assert.assertEquals(QueryType.WRITE, statement.getQueryType()); + Assert.assertEquals(QueryType.OTHER, statement.getQueryType()); } @Test @@ -77,7 +77,7 @@ public class PipeStatementTest { StartPipeStatement statement = new StartPipeStatement(StatementType.START_PIPE); statement.setPipeName("test"); Assert.assertEquals("test", statement.getPipeName()); - Assert.assertEquals(QueryType.WRITE, statement.getQueryType()); + Assert.assertEquals(QueryType.OTHER, statement.getQueryType()); } @Test @@ -85,6 +85,6 @@ public class PipeStatementTest { StopPipeStatement statement = new StopPipeStatement(StatementType.STOP_PIPE); statement.setPipeName("test"); Assert.assertEquals("test", statement.getPipeName()); - Assert.assertEquals(QueryType.WRITE, statement.getQueryType()); + Assert.assertEquals(QueryType.OTHER, statement.getQueryType()); } }
