You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/12/22 07:12:42 UTC
[iotdb] 02/04: Merge branch 'master' of https://github.com/apache/iotdb into numpy_tablet_none
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch numpy_tablet_none
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 790a2947b7281a7a302d5929ea0b542d538a7b26
Merge: 89a219b1c6 3ec0e99992
Author: HTHou <hh...@outlook.com>
AuthorDate: Tue Dec 20 18:22:38 2022 +0800
Merge branch 'master' of https://github.com/apache/iotdb into numpy_tablet_none
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 6 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 15 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 20 +-
cli/src/assembly/resources/sbin/start-cli.bat | 2 +-
cli/src/assembly/resources/sbin/start-cli.sh | 2 -
client-py/iotdb/Session.py | 26 +-
client-py/tests/test_delete_data.py | 162 ++
.../confignode/client/ConfigNodeRequestType.java | 1 +
.../client/sync/SyncConfigNodeClientPool.java | 3 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 15 +-
.../confignode/conf/ConfigNodeDescriptor.java | 2 +
.../confignode/conf/SystemPropertiesUtils.java | 42 +-
.../consensus/response/ConfigurationResp.java | 6 +-
.../consensus/response/DataNodeRegisterResp.java | 44 +-
.../iotdb/confignode/manager/ConfigManager.java | 149 +-
.../iotdb/confignode/manager/ConsensusManager.java | 2 +-
.../apache/iotdb/confignode/manager/IManager.java | 22 +-
.../manager/node/ClusterNodeStartUtils.java | 380 +++
.../iotdb/confignode/manager/node/NodeManager.java | 156 +-
.../confignode/persistence/node/NodeInfo.java | 27 -
.../iotdb/confignode/service/ConfigNode.java | 74 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 50 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 36 +-
.../consensus/iot/client/DispatchLogHandler.java | 20 +-
.../{PendingBatch.java => Batch.java} | 32 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 88 +-
.../logdispatcher/LogDispatcherThreadMetrics.java | 2 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 18 +-
.../iot/service/IoTConsensusRPCService.java | 2 +-
.../service/IoTConsensusRPCServiceProcessor.java | 41 +-
.../apache/iotdb/consensus/iot/StabilityTest.java | 12 +-
.../iot/logdispatcher/SyncStatusTest.java | 121 +-
docs/Development/ContributeGuide.md | 14 -
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 4 +-
docs/zh/Development/ContributeGuide.md | 11 -
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 4 +-
.../apache/iotdb/trigger/old/TriggerExample.java | 147 --
integration-test/import-control.xml | 1 +
integration-test/pom.xml | 5 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 115 +-
.../apache/iotdb/it/env/AbstractNodeWrapper.java | 6 +-
.../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 11 +-
.../org/apache/iotdb/it/env/DataNodeWrapper.java | 5 +
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 49 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 32 +-
.../org/apache/iotdb/cli/it/AbstractScript.java | 105 +
.../apache/iotdb/cli/it}/StartClientScriptIT.java | 71 +-
.../confignode/it/IoTDBClusterAuthorityIT.java | 62 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 2 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 305 +++
.../IoTDBClusterNodeGetterIT.java} | 15 +-
.../it/{ => cluster}/IoTDBClusterRestartIT.java | 2 +-
.../IoTDBClusterRegionLeaderBalancingIT.java | 29 +-
.../{ => load}/IoTDBConfigNodeSwitchLeaderIT.java | 2 +-
.../it/partition/IoTDBPartitionDurableIT.java | 4 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 82 +
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 49 +-
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 1127 ---------
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 6 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 291 ---
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 796 ------
.../db/integration/IoTDBSequenceDataQueryIT.java | 329 ---
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 444 ----
.../aggregation/IoTDBUDFNestAggregationIT.java | 774 ------
.../IoTDBUserDefinedAggregationFunctionIT.java | 732 ------
.../db/integration/aligned/AlignedWriteUtil.java | 149 --
.../db/integration/aligned/IoTDBEmptyDataIT.java | 78 -
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 192 --
.../aligned/IoTDBGroupByFillQueryIT.java | 989 --------
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 1037 --------
.../aligned/IoTDBRawQueryWithValueFilter2IT.java | 65 -
.../aligned/IoTDBRawQueryWithValueFilterIT.java | 763 ------
...oTDBRawQueryWithValueFilterWithDeletion2IT.java | 82 -
...IoTDBRawQueryWithValueFilterWithDeletionIT.java | 778 ------
.../db/integration/groupby/IoTDBGroupByFillIT.java | 2657 --------------------
.../groupby/IoTDBGroupByFillMixPathsIT.java | 479 ----
.../groupby/IoTDBGroupByFillWithRangeIT.java | 179 --
.../groupby/IoTDBGroupByNaturalMonthFillIT.java | 273 --
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 42 -
.../java/org/apache/iotdb/jdbc/ListDataSet.java | 53 -
.../org/apache/iotdb/commons/cluster/NodeType.java | 31 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 2 +
.../schemaregion/rocksdb/RSchemaRegion.java | 129 +-
.../metadata/rocksdb/RocksDBBenchmarkEngine.java | 139 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 151 +-
.../tagSchemaRegion/TagSchemaRegionTest.java | 18 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 131 -
.../apache/iotdb/db/auth/AuthorizerManager.java | 7 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 10 +-
.../iotdb/db/auth/StandaloneAuthorityFetcher.java | 125 -
.../apache/iotdb/db/client/ConfigNodeClient.java | 57 +-
.../ConfigNodeClientManager.java} | 32 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 6 +-
.../iotdb/db/client/DataNodeInternalClient.java | 15 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 24 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 14 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 4 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 64 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 95 -
.../iotdb/db/localconfignode/LocalConfigNode.java | 9 +-
.../db/localconfignode/LocalDataPartitionInfo.java | 1 +
.../localconfignode/LocalDataPartitionTable.java | 1 +
.../localconfignode/LocalSchemaPartitionTable.java | 1 +
.../iotdb/db/metadata/LocalSchemaProcessor.java | 598 +----
.../iotdb/db/metadata/idtable/IDTableManager.java | 27 +-
.../iotdb/db/metadata/logfile/MLogReader.java | 75 -
.../iotdb/db/metadata/logfile/MLogWriter.java | 254 --
.../db/metadata/schemaregion/ISchemaRegion.java | 94 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 204 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 118 +-
.../storagegroup/StorageGroupLogWriter.java | 56 -
.../storagegroup/StorageGroupSchemaManager.java | 126 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 10 +-
.../iotdb/db/metadata/template/Template.java | 53 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 12 +
.../db/metadata/utils/ResourceByPathUtils.java | 34 -
.../metadata/visitor/SchemaExecutionVisitor.java | 2 +-
.../db/mpp/aggregation/AccumulatorFactory.java | 2 +-
.../SlidingWindowAggregatorFactory.java | 2 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 12 +
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../exchange/IMPPDataExchangeManager.java | 2 +
.../db/mpp/execution/exchange/ISinkHandle.java | 3 +
.../db/mpp/execution/exchange/ISourceHandle.java | 3 +
.../db/mpp/execution/exchange/LocalSinkHandle.java | 11 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 5 +
.../execution/exchange/MPPDataExchangeManager.java | 21 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 59 +-
.../db/mpp/execution/exchange/SinkHandle.java | 50 +-
.../db/mpp/execution/exchange/SourceHandle.java | 62 +-
.../mpp/execution/memory/LocalMemoryManager.java | 2 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 206 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 20 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 64 +
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 10 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 69 +
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 6 +-
.../plan/analyze/StandalonePartitionFetcher.java | 252 --
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 227 --
.../db/mpp/plan/execution/QueryExecution.java | 27 +-
.../mpp/plan/execution/config/ConfigExecution.java | 7 +-
.../executor/StandaloneConfigTaskExecutor.java | 728 ------
.../plan/execution/memory/MemorySourceHandle.java | 3 +
.../iotdb/db/mpp/plan/expression/Expression.java | 27 -
.../iotdb/db/mpp/plan/expression/ResultColumn.java | 61 -
.../plan/expression/binary/BinaryExpression.java | 96 -
.../mpp/plan/expression/leaf/ConstantOperand.java | 26 -
.../db/mpp/plan/expression/leaf/NullOperand.java | 27 -
.../plan/expression/leaf/TimeSeriesOperand.java | 31 -
.../mpp/plan/expression/leaf/TimestampOperand.java | 27 -
.../plan/expression/multi/FunctionExpression.java | 49 -
.../plan/expression/ternary/TernaryExpression.java | 50 -
.../mpp/plan/expression/unary/UnaryExpression.java | 37 -
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 88 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 30 +
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 2 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 9 +
.../plan/planner/MemoryDistributionCalculator.java | 490 ++++
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 1 +
.../plan/parameter/AggregationDescriptor.java | 1 -
.../planner/plan/parameter}/AggregationType.java | 2 +-
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 222 --
.../iotdb/db/mpp/plan/statement/AuthorType.java | 122 +
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
.../db/mpp/plan/statement/component/SortKey.java | 6 +-
.../db/mpp/plan/statement/sys/AuthorStatement.java | 12 +-
.../plan/statement/sys/ShowQueriesStatement.java | 74 +
.../mpp/transformation/dag/builder/DAGBuilder.java | 116 -
.../dag/input/QueryDataSetInputLayer.java | 41 -
.../protocol/influxdb/util/QueryResultUtils.java | 90 -
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 11 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 11 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 11 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 154 --
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 55 -
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 946 -------
.../org/apache/iotdb/db/qp/logical/Operator.java | 13 -
.../qp/logical/crud/AggregationQueryOperator.java | 155 --
.../db/qp/logical/crud/DeleteDataOperator.java | 73 -
.../db/qp/logical/crud/FillClauseComponent.java | 49 -
.../db/qp/logical/crud/FillQueryOperator.java | 92 -
.../db/qp/logical/crud/GroupByClauseComponent.java | 92 -
.../logical/crud/GroupByFillClauseComponent.java | 49 -
.../qp/logical/crud/GroupByFillQueryOperator.java | 80 -
.../db/qp/logical/crud/GroupByQueryOperator.java | 111 -
.../iotdb/db/qp/logical/crud/InOperator.java | 212 --
.../iotdb/db/qp/logical/crud/InsertOperator.java | 90 -
.../db/qp/logical/crud/LastQueryOperator.java | 64 -
.../iotdb/db/qp/logical/crud/LikeOperator.java | 134 -
.../iotdb/db/qp/logical/crud/QueryOperator.java | 421 ----
.../iotdb/db/qp/logical/crud/RegexpOperator.java | 133 -
.../db/qp/logical/crud/SelectIntoOperator.java | 133 -
.../db/qp/logical/crud/UDAFQueryOperator.java | 179 --
.../db/qp/logical/crud/UDTFQueryOperator.java | 48 -
.../qp/logical/sys/ActivateTemplateOperator.java | 51 -
.../db/qp/logical/sys/AlterTimeSeriesOperator.java | 116 -
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 233 --
.../db/qp/logical/sys/ClearCacheOperator.java | 39 -
.../iotdb/db/qp/logical/sys/CountOperator.java | 73 -
.../sys/CreateAlignedTimeSeriesOperator.java | 184 --
.../logical/sys/CreateContinuousQueryOperator.java | 108 -
.../db/qp/logical/sys/CreateFunctionOperator.java | 59 -
.../db/qp/logical/sys/CreateIndexOperator.java | 84 -
.../db/qp/logical/sys/CreatePipeOperator.java | 61 -
.../db/qp/logical/sys/CreatePipeSinkOperator.java | 54 -
.../db/qp/logical/sys/CreateTemplateOperator.java | 108 -
.../qp/logical/sys/CreateTimeSeriesOperator.java | 127 -
.../iotdb/db/qp/logical/sys/DataAuthOperator.java | 51 -
.../db/qp/logical/sys/DeletePartitionOperator.java | 61 -
.../qp/logical/sys/DeleteStorageGroupOperator.java | 50 -
.../qp/logical/sys/DeleteTimeSeriesOperator.java | 51 -
.../logical/sys/DropContinuousQueryOperator.java | 50 -
.../db/qp/logical/sys/DropFunctionOperator.java | 50 -
.../iotdb/db/qp/logical/sys/DropIndexOperator.java | 65 -
.../iotdb/db/qp/logical/sys/DropPipeOperator.java | 44 -
.../db/qp/logical/sys/DropPipeSinkOperator.java | 43 -
.../db/qp/logical/sys/DropTemplateOperator.java | 49 -
.../iotdb/db/qp/logical/sys/FlushOperator.java | 62 -
.../iotdb/db/qp/logical/sys/KillQueryOperator.java | 52 -
.../qp/logical/sys/LoadConfigurationOperator.java | 52 -
.../iotdb/db/qp/logical/sys/LoadDataOperator.java | 54 -
.../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 92 -
.../iotdb/db/qp/logical/sys/MergeOperator.java | 44 -
.../db/qp/logical/sys/RemoveFileOperator.java | 49 -
.../db/qp/logical/sys/SetStorageGroupOperator.java | 48 -
.../db/qp/logical/sys/SetSystemModeOperator.java | 54 -
.../iotdb/db/qp/logical/sys/SetTTLOperator.java | 61 -
.../db/qp/logical/sys/SetTemplateOperator.java | 65 -
.../iotdb/db/qp/logical/sys/SettleOperator.java | 71 -
.../db/qp/logical/sys/ShowChildNodesOperator.java | 47 -
.../db/qp/logical/sys/ShowChildPathsOperator.java | 47 -
.../logical/sys/ShowContinuousQueriesOperator.java | 28 -
.../db/qp/logical/sys/ShowDevicesOperator.java | 73 -
.../db/qp/logical/sys/ShowFunctionsOperator.java | 38 -
.../db/qp/logical/sys/ShowLockInfoOperator.java | 36 -
.../logical/sys/ShowNodesInTemplateOperator.java | 43 -
.../iotdb/db/qp/logical/sys/ShowOperator.java | 64 -
.../logical/sys/ShowPathsSetTemplateOperator.java | 43 -
.../sys/ShowPathsUsingTemplateOperator.java | 43 -
.../iotdb/db/qp/logical/sys/ShowPipeOperator.java | 45 -
.../db/qp/logical/sys/ShowPipeSinkOperator.java | 45 -
.../qp/logical/sys/ShowPipeSinkTypeOperator.java | 38 -
.../qp/logical/sys/ShowQueryResourceOperate.java | 39 -
.../qp/logical/sys/ShowStorageGroupOperator.java | 47 -
.../iotdb/db/qp/logical/sys/ShowTTLOperator.java | 48 -
.../db/qp/logical/sys/ShowTemplatesOperator.java | 27 -
.../db/qp/logical/sys/ShowTimeSeriesOperator.java | 103 -
.../db/qp/logical/sys/ShowTriggersOperator.java | 38 -
.../iotdb/db/qp/logical/sys/StartPipeOperator.java | 44 -
.../iotdb/db/qp/logical/sys/StopPipeOperator.java | 44 -
.../iotdb/db/qp/logical/sys/TracingOperator.java | 46 -
.../iotdb/db/qp/logical/sys/UnSetTTLOperator.java | 52 -
.../db/qp/logical/sys/UnloadFileOperator.java | 55 -
.../db/qp/logical/sys/UnsetTemplateOperator.java | 65 -
.../org/apache/iotdb/db/qp/physical/BatchPlan.java | 73 -
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 253 --
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 226 --
.../db/qp/physical/crud/AlignByDevicePlan.java | 285 ---
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 61 -
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 118 -
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 138 -
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 87 -
.../iotdb/db/qp/physical/crud/MeasurementInfo.java | 62 -
.../iotdb/db/qp/physical/crud/QueryIndexPlan.java | 88 -
.../iotdb/db/qp/physical/crud/QueryPlan.java | 257 --
.../db/qp/physical/crud/RawDataQueryPlan.java | 217 --
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 130 -
.../apache/iotdb/db/qp/physical/crud/UDAFPlan.java | 81 -
.../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 43 -
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 149 --
.../sys/ActivateTemplateInClusterPlan.java | 127 -
.../db/qp/physical/sys/ActivateTemplatePlan.java | 87 -
.../db/qp/physical/sys/AlterTimeSeriesPlan.java | 212 --
.../db/qp/physical/sys/AppendTemplatePlan.java | 218 --
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 406 ---
.../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 89 -
.../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 116 -
.../db/qp/physical/sys/ChangeTagOffsetPlan.java | 116 -
.../iotdb/db/qp/physical/sys/ClearCachePlan.java | 55 -
.../apache/iotdb/db/qp/physical/sys/CountPlan.java | 53 -
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 66 -
.../qp/physical/sys/CreateContinuousQueryPlan.java | 156 --
.../db/qp/physical/sys/CreateFunctionPlan.java | 81 -
.../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 180 --
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 398 ---
.../db/qp/physical/sys/CreateTemplatePlan.java | 516 ----
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 35 -
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 100 -
.../db/qp/physical/sys/DeleteStorageGroupPlan.java | 84 -
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 139 -
.../qp/physical/sys/DropContinuousQueryPlan.java | 63 -
.../iotdb/db/qp/physical/sys/DropFunctionPlan.java | 69 -
.../iotdb/db/qp/physical/sys/DropIndexPlan.java | 129 -
.../iotdb/db/qp/physical/sys/DropTemplatePlan.java | 78 -
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 244 --
.../iotdb/db/qp/physical/sys/KillQueryPlan.java | 45 -
.../db/qp/physical/sys/LoadConfigurationPlan.java | 144 --
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 73 -
.../apache/iotdb/db/qp/physical/sys/LogPlan.java | 75 -
.../apache/iotdb/db/qp/physical/sys/MNodePlan.java | 116 -
.../db/qp/physical/sys/MeasurementMNodePlan.java | 154 --
.../apache/iotdb/db/qp/physical/sys/MergePlan.java | 59 -
.../iotdb/db/qp/physical/sys/OperateFilePlan.java | 119 -
.../qp/physical/sys/PreDeleteTimeSeriesPlan.java | 80 -
.../db/qp/physical/sys/PruneTemplatePlan.java | 107 -
.../sys/RollbackPreDeleteTimeSeriesPlan.java | 81 -
.../db/qp/physical/sys/SetStorageGroupPlan.java | 100 -
.../db/qp/physical/sys/SetSystemModePlan.java | 76 -
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 102 -
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 107 -
.../iotdb/db/qp/physical/sys/SettlePlan.java | 65 -
.../db/qp/physical/sys/ShowChildNodesPlan.java | 39 -
.../db/qp/physical/sys/ShowChildPathsPlan.java | 39 -
.../qp/physical/sys/ShowContinuousQueriesPlan.java | 27 -
.../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 10 -
.../db/qp/physical/sys/ShowFunctionsPlan.java | 27 -
.../iotdb/db/qp/physical/sys/ShowLockInfoPlan.java | 36 -
.../qp/physical/sys/ShowNodesInTemplatePlan.java | 34 -
.../qp/physical/sys/ShowPathsSetTemplatePlan.java | 34 -
.../physical/sys/ShowPathsUsingTemplatePlan.java | 34 -
.../qp/physical/sys/ShowQueryProcesslistPlan.java | 26 -
.../db/qp/physical/sys/ShowQueryResourcePlan.java | 38 -
.../db/qp/physical/sys/ShowStorageGroupPlan.java | 36 -
.../db/qp/physical/sys/ShowTemplatesPlan.java | 27 -
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 14 -
.../iotdb/db/qp/physical/sys/ShowTriggersPlan.java | 27 -
.../db/qp/physical/sys/StorageGroupMNodePlan.java | 110 -
.../iotdb/db/qp/physical/sys/TracingPlan.java | 45 -
.../db/qp/physical/sys/UnsetTemplatePlan.java | 109 -
.../iotdb/db/qp/strategy/LogicalChecker.java | 46 -
.../iotdb/db/qp/strategy/LogicalGenerator.java | 131 -
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 59 -
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 408 ---
.../qp/strategy/optimizer/DnfFilterOptimizer.java | 163 --
.../db/qp/strategy/optimizer/IFilterOptimizer.java | 29 -
.../qp/strategy/optimizer/ILogicalOptimizer.java | 30 -
.../optimizer/MergeSingleFilterOptimizer.java | 179 --
.../qp/strategy/optimizer/RemoveNotOptimizer.java | 104 -
.../iotdb/db/qp/utils/EmptyOutputStream.java | 35 -
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 150 --
.../db/query/aggregation/AggregateResult.java | 377 ---
.../aggregation/RemovableAggregateResult.java | 30 -
.../db/query/aggregation/impl/AvgAggrResult.java | 222 --
.../db/query/aggregation/impl/CountAggrResult.java | 122 -
.../query/aggregation/impl/ExtremeAggrResult.java | 175 --
.../aggregation/impl/FirstValueAggrResult.java | 141 --
.../aggregation/impl/FirstValueDescAggrResult.java | 88 -
.../aggregation/impl/LastValueAggrResult.java | 131 -
.../aggregation/impl/LastValueDescAggrResult.java | 110 -
.../query/aggregation/impl/MaxTimeAggrResult.java | 119 -
.../aggregation/impl/MaxTimeDescAggrResult.java | 92 -
.../query/aggregation/impl/MaxValueAggrResult.java | 126 -
.../query/aggregation/impl/MinTimeAggrResult.java | 134 -
.../aggregation/impl/MinTimeDescAggrResult.java | 76 -
.../query/aggregation/impl/MinValueAggrResult.java | 124 -
.../db/query/aggregation/impl/SumAggrResult.java | 172 --
.../iotdb/db/query/context/QueryContext.java | 9 -
.../db/query/control/QueryResourceManager.java | 98 +-
.../iotdb/db/query/control/QueryTimeManager.java | 151 --
.../iotdb/db/query/control/SessionManager.java | 40 -
.../db/query/control/tracing/TracingConstant.java | 30 -
.../db/query/control/tracing/TracingInfo.java | 164 --
.../db/query/control/tracing/TracingManager.java | 88 -
.../db/query/dataset/AlignByDeviceDataSet.java | 281 ---
.../db/query/dataset/DirectAlignByTimeDataSet.java | 34 -
.../db/query/dataset/DirectNonAlignDataSet.java | 32 -
.../apache/iotdb/db/query/dataset/ListDataSet.java | 61 -
.../db/query/dataset/NonAlignEngineDataSet.java | 353 ---
.../dataset/RawQueryDataSetWithValueFilter.java | 264 --
.../dataset/RawQueryDataSetWithoutValueFilter.java | 728 ------
.../query/dataset/ShowContinuousQueriesResult.java | 75 -
.../apache/iotdb/db/query/dataset/ShowDataSet.java | 69 -
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 86 -
.../db/query/dataset/ShowTimeseriesDataSet.java | 109 -
.../iotdb/db/query/dataset/SingleDataSet.java | 56 -
.../iotdb/db/query/dataset/UDFInputDataSet.java | 67 -
.../UDFRawQueryInputDataSetWithoutValueFilter.java | 68 -
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 373 ---
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 145 --
.../db/query/dataset/UDTFNonAlignDataSet.java | 216 --
.../query/dataset/groupby/GroupByFillDataSet.java | 340 ---
.../query/dataset/groupby/GroupByLevelDataSet.java | 93 -
.../query/dataset/groupby/GroupByTimeDataSet.java | 165 --
.../dataset/groupby/GroupByTimeEngineDataSet.java | 93 -
.../groupby/GroupByWithValueFilterDataSet.java | 234 --
.../groupby/GroupByWithoutValueFilterDataSet.java | 161 --
.../db/query/executor/AggregationExecutor.java | 706 ------
.../iotdb/db/query/executor/FillQueryExecutor.java | 206 --
.../iotdb/db/query/executor/IQueryRouter.java | 74 -
.../iotdb/db/query/executor/LastQueryExecutor.java | 285 ---
.../iotdb/db/query/executor/QueryRouter.java | 274 --
.../db/query/executor/RawDataQueryExecutor.java | 185 --
.../iotdb/db/query/executor/UDFQueryExecutor.java | 112 -
.../executor/fill/AlignedLastPointReader.java | 58 -
.../apache/iotdb/db/query/executor/fill/IFill.java | 150 --
.../db/query/executor/fill/LastPointReader.java | 266 --
.../iotdb/db/query/executor/fill/LinearFill.java | 263 --
.../iotdb/db/query/executor/fill/PreviousFill.java | 138 -
.../iotdb/db/query/executor/fill/ValueFill.java | 152 --
.../executor/groupby/AlignedGroupByExecutor.java | 37 -
.../db/query/executor/groupby/GroupByExecutor.java | 40 -
.../groupby/SlidingWindowGroupByExecutor.java | 66 -
.../SlidingWindowGroupByExecutorFactory.java | 117 -
.../EmptyQueueSlidingWindowGroupByExecutor.java | 51 -
.../groupby/impl/LocalAlignedGroupByExecutor.java | 366 ---
.../groupby/impl/LocalGroupByExecutor.java | 367 ---
...MonotonicQueueSlidingWindowGroupByExecutor.java | 73 -
.../NormalQueueSlidingWindowGroupByExecutor.java | 61 -
.../SmoothQueueSlidingWindowGroupByExecutor.java | 55 -
.../db/query/externalsort/ExternalSortJob.java | 43 -
.../query/externalsort/ExternalSortJobEngine.java | 52 -
.../db/query/externalsort/ExternalSortJobPart.java | 43 -
.../externalsort/ExternalSortJobScheduler.java | 40 -
.../iotdb/db/query/externalsort/LineMerger.java | 55 -
.../MultiSourceExternalSortJobPart.java | 50 -
.../externalsort/SimpleExternalSortEngine.java | 178 --
.../SingleSourceExternalSortJobPart.java | 39 -
.../adapter/ByTimestampReaderAdapter.java | 73 -
.../serialize/IExternalSortFileDeserializer.java | 32 -
.../serialize/IExternalSortFileSerializer.java | 30 -
.../FixLengthIExternalSortFileDeserializer.java | 267 --
.../impl/FixLengthTimeValuePairSerializer.java | 169 --
.../db/query/factory/AggregateResultFactory.java | 150 --
.../iotdb/db/query/pool/QueryTaskManager.java | 90 -
.../db/query/pool/RawQueryReadTaskPoolManager.java | 104 -
.../pool/RawQueryReadTaskPoolManagerMetrics.java | 92 -
.../db/query/reader/chunk/ChunkDataIterator.java | 79 -
.../db/query/reader/chunk/ChunkReaderWrap.java | 95 -
.../reader/chunk/DiskChunkReaderByTimestamp.java | 82 -
.../resource/CachedUnseqResourceMergeReader.java | 43 -
.../series/AlignedSeriesAggregateReader.java | 189 --
.../reader/series/BaseManagedSeriesReader.java | 45 -
.../db/query/reader/series/IAggregateReader.java | 57 -
.../db/query/reader/series/IReaderByTimestamp.java | 47 -
.../query/reader/series/ManagedSeriesReader.java | 37 -
.../query/reader/series/SeriesAggregateReader.java | 175 --
.../reader/series/SeriesRawDataBatchReader.java | 63 +-
.../reader/series/SeriesRawDataPointReader.java | 87 -
.../iotdb/db/query/reader/series/SeriesReader.java | 51 -
.../reader/series/SeriesReaderByTimestamp.java | 189 --
.../reader/universal/PriorityMergeReader.java | 10 -
.../query/timegenerator/ServerTimeGenerator.java | 182 --
.../java/org/apache/iotdb/db/service/DataNode.java | 428 ++--
.../db/service/DataNodeServerCommandLine.java | 18 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 232 --
.../org/apache/iotdb/db/service/NewIoTDBMBean.java | 28 -
.../iotdb/db/service/basic/ServiceProvider.java | 100 -
.../service/basic/StandaloneServiceProvider.java | 55 -
.../db/service/metrics/IoTDBInternalReporter.java | 11 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 159 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 17 +-
.../db/service/thrift/impl/TSServiceImpl.java | 1424 -----------
.../iotdb/db/sync/pipedata/load/ILoader.java | 15 +-
.../db/sync/sender/manager/LocalSyncManager.java | 21 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 5 +
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 34 -
.../org/apache/iotdb/db/utils/SchemaUtils.java | 72 +-
.../iotdb/db/utils/writelog/BatchLogReader.java | 83 -
.../apache/iotdb/db/utils/writelog/ILogReader.java | 50 -
.../apache/iotdb/db/utils/writelog/LogWriter.java | 19 +-
.../db/utils/writelog/MultiFileLogReader.java | 76 -
.../db/utils/writelog/SingleFileLogReader.java | 166 --
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 264 --
.../iotdb/db/engine/cache/ChunkCacheTest.java | 19 -
.../InnerSeqCompactionWithFastPerformerTest.java | 17 -
.../InnerUnseqCompactionWithFastPerformerTest.java | 19 -
.../db/engine/storagegroup/DataRegionTest.java | 13 -
.../iotdb/db/engine/storagegroup/TTLTest.java | 76 +-
.../engine/storagegroup/TsFileProcessorTest.java | 2 -
.../LocalConfigNodeMultiDataRegionTest.java | 94 -
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 90 +
.../iotdb/db/metadata/SchemaAdvancedTest.java | 202 --
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 1294 ----------
.../iotdb/db/metadata/SchemaImproveTest.java | 187 --
.../org/apache/iotdb/db/metadata/TemplateTest.java | 180 --
.../db/metadata/mtree/disk/MemManagerTest.java | 111 -
.../db/metadata/multimode/SchemaDiskModeTest.java | 42 -
.../metadata/multimode/SchemaFullMemoryTest.java | 29 -
.../metadata/multimode/SchemaMemoryModeTest.java | 35 -
.../db/metadata/multimode/SchemaNonMemoryTest.java | 29 -
.../multimode/SchemaPartialMemoryTest.java | 28 -
.../plan/SchemaRegionPlanCompatibilityTest.java | 279 --
.../schemaRegion/AbstractSchemaRegionTest.java | 141 ++
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 531 ++++
.../schemaRegion/SchemaRegionBasicTest.java | 320 +--
.../schemaRegion/SchemaRegionManagementTest.java | 161 ++
.../schemaRegion/SchemaRegionTemplateTest.java | 185 ++
.../schemaRegion/SchemaRegionTestUtil.java | 107 +
.../multimode/SchemaRegionFullMemoryTest.java | 43 -
.../multimode/SchemaRegionMemoryTest.java | 46 -
.../multimode/SchemaRegionNonMemoryTest.java | 43 -
.../multimode/SchemaRegionPartialMemoryTest.java | 43 -
.../multimode/SchemaRegionSchemaFileTest.java | 46 -
.../iotdb/db/mpp/aggregation/AccumulatorTest.java | 2 +-
.../execution/exchange/LocalSinkHandleTest.java | 63 +-
.../execution/exchange/LocalSourceHandleTest.java | 4 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 5 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 77 +-
.../mpp/execution/exchange/SourceHandleTest.java | 10 +-
.../db/mpp/execution/exchange/StubSinkHandle.java | 3 +
.../iotdb/db/mpp/execution/exchange/Utils.java | 52 +-
.../db/mpp/execution/memory/MemoryPoolTest.java | 182 +-
.../operator/AggregationOperatorTest.java | 2 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 2 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 2 +-
.../operator/RawDataAggregationOperatorTest.java | 2 +-
.../SeriesAggregationScanOperatorTest.java | 2 +-
.../SlidingWindowAggregationOperatorTest.java | 2 +-
.../operator/VerticallyConcatOperatorTest.java | 2 +-
.../operator/schema/CountMergeOperatorTest.java | 2 +
.../operator/schema/SchemaCountOperatorTest.java | 2 +
.../schema/SchemaQueryScanOperatorTest.java | 2 +
.../db/mpp/plan/StandaloneCoordinatorTest.java | 155 --
.../plan/analyze/AggregationDescriptorTest.java | 2 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 2 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 2 +-
.../distribution/AggregationDistributionTest.java | 2 +-
.../node/process/AggregationNodeSerdeTest.java | 2 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 2 +-
.../plan/node/process/GroupByTagNodeSerdeTest.java | 2 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 2 +-
.../plan/scheduler/StandaloneSchedulerTest.java | 547 ----
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 289 ---
.../iotdb/db/qp/bench/QueryParseBenchmark.java | 45 -
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 365 ---
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 94 -
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 18 +-
.../db/query/aggregation/AggregateResultTest.java | 294 ---
.../query/aggregation/DescAggregateResultTest.java | 190 --
.../iotdb/db/query/dataset/ListDataSetTest.java | 164 --
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 700 ------
.../dataset/groupby/GroupByTimeDataSetTest.java | 492 ----
.../query/externalsort/ExternalSortEngineTest.java | 193 --
.../db/query/externalsort/FakeChunkReaderWrap.java | 43 -
...ExternalSortFileSerializerDeserializerTest.java | 131 -
.../reader/series/SeriesAggregateReaderTest.java | 141 --
.../reader/series/SeriesReaderByTimestampTest.java | 95 -
.../db/query/reader/series/SeriesReaderTest.java | 189 --
.../query/reader/series/SeriesReaderTestUtil.java | 21 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 87 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 2 -
.../iotdb/db/tools/TsFileSketchToolTest.java | 26 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 82 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 16 -
.../iotdb/db/utils/TsFileRewriteToolTest.java | 460 ----
.../db/utils/writelog/LogWriterReaderTest.java | 215 --
.../db/utils/writelog/MultiFileLogReaderTest.java | 97 -
.../db/wal/recover/WALRecoverManagerTest.java | 5 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 5 +-
.../java/org/apache/iotdb/session/ISession.java | 12 +-
.../java/org/apache/iotdb/session/Session.java | 29 +-
.../apache/iotdb/session/SessionConnection.java | 22 +
.../org/apache/iotdb/session/pool/SessionPool.java | 20 +
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 9 +-
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 14 +-
.../iotdb/spark/db/unit/DataFrameToolsTest.scala | 11 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 46 -
.../src/main/thrift/confignode.thrift | 86 +-
.../src/main/thrift/iotconsensus.thrift | 20 +-
thrift/src/main/thrift/client.thrift | 9 +
.../tsfile/read/query/dataset/EmptyDataSet.java | 40 -
.../tsfile/read/reader/FakedTimeGenerator.java | 83 -
565 files changed, 5895 insertions(+), 59776 deletions(-)