You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by yo...@apache.org on 2023/02/14 01:57:39 UTC
[iotdb] branch Show-Region-creation-time-when-execute-show-regions updated (b5ef1f9c63 -> 9d56fd63dc)
This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch Show-Region-creation-time-when-execute-show-regions
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b5ef1f9c63 TimeZone
add 64af71b2e0 Fix a part of bad url in the official documentation (#8991)
add 86c46dca1a [IoTDB-5457]java native api has not been support modified template (#8965)
add df298dc83f [IOTDB-5495]Improve unit tests about show devices (#9006)
add ab9189c22b Eliminate useless isDefaultSchemaMemoryConfig (#9008)
add ce0ad2d483 [IOTDB-5021] Using Junit parameterized test to optimize schema IT framework (#8097)
add 4834c1fc3a [IOTDB-5496] Rename VerticallyConcatOperator as HorizontallyConcatOperator
add 0a68bb7f39 [IOTDB-5499] Eliminate useless log during auto creating schema (#9013)
add ed34105697 [IOTDB-5498] Fix SessionPool OOM when the numbers of devices and sessions are large (#9012)
add 302391ce82 Fix IT error by parallel suites (#9016)
add a77571f63a Correct DataPartiton Fetch request parameter contruction (#8953)
add 6944a5c3c0 [IOTDB-5451] Support cluster Database heterogeneous by ALTER SQL (#8971)
add dfd6d3d9fa [IOTDB-5479] Optimize the wal impl of confignode simple consensus (#8997)
add 3623ca006c change default cross performer and inner unseq performer to FAST (#9004)
add 4b5f4ff5ed Skip broken tsfile when recovering system (#9003)
add 61ef21ae22 [IOTDB-5510] Block and wait to create timeseries when releasing memory (#9030)
add 4abad1cdac [IOTDB-5477] Refactor the interaction between InsertNode and SchemaFetcher (#8993)
add f60fd2044f [IOTDB-5504] Fix illegal argument exception occurs when scheduling compaction
add 5dd2031ab4 [IOTDB-5474] Fix count nodes using level bug (#9035)
add 5f8f2b9f88 [IOTDB-5021] Adapting all schemaIT to add Schema_File mode (#9034)
add 87574002be [IOTDB-5488] Fix set system to readonly on local (#9032)
add 10fd7eb215 [IOTDB-5470] Refactor compaction metrics (#9033)
add 2b05d8ca35 [IOTDB-5501] Fix memory leak in MemoryPool
add e67f8909ec Bump spring-boot-starter-web in /grafana-connector (#5424)
add 6571374982 Bump commons-compress from 1.9 to 1.21 in /hive-connector (#9037)
add b239efe75d [IOTDB-5514] Fix race condition in MemoryPool without synchronized block (#9041)
add 66611b1d1c [IOTDB-5513] Fix duplicate LastQueryNode due to change of partition slot algorithm (#9040)
add 0ac0fb57e8 [IOTDB-5502] Source counters for construct batches in IoTConsensus (#9023)
add bca08f0f26 [IOTDB-5491] Add IoTConsumus memory control metric items (#9022)
add adf55e896e [IOTDB-4209] Use .pst to accelerate recovery in SchemaFile mode (#7995)
add 1e2da83d83 [IOTDB-5497] Test for ConfigNode consensus efficiency (#9015)
add ab8130a74e [IOTDB-5505] Bump Ratis version to latest 2.4.2-snapshot (#9027)
add 344962356b [IOTDB-5480] IoTConsensus sync lag may be negative under single copy (#9031)
add a9168656d6 [IOTDB-5337] Parallelization of write operation in FragmentInstanceDispatcher (#8920)
add 8a1eb28efa [IOTDB-5506] Refactor RatisConsensus(#9029)
add 33719b66b3 [IOTDB-5456]Implement COUNT_IF built-in aggregation function
add 8438f41d32 [IOTDB-5458] Add Performance Overview Metrics and Dashboard (#8982)
add 199b9367c3 [IOTDB-5485] Rename StorageGroup to Database in ConfigNode (#9028)
add 4f2cc1dab5 Merge branch 'master' into Show-Region-creation-time-when-execute-show-regions
add 9d56fd63dc Add column CreateTime
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 7 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 10 +
.../confignode/conf/ConfigNodeDescriptor.java | 8 +
.../consensus/request/ConfigPhysicalPlan.java | 33 +-
.../consensus/request/ConfigPhysicalPlanType.java | 14 +-
.../CountDatabasePlan.java} | 25 +-
.../GetDatabasePlan.java} | 13 +-
.../request/read/region/GetRegionInfoListPlan.java | 6 +-
...orageGroupPlan.java => DatabaseSchemaPlan.java} | 29 +-
...orageGroupPlan.java => DeleteDatabasePlan.java} | 19 +-
...geGroupPlan.java => PreDeleteDatabasePlan.java} | 33 +-
.../response/{ => auth}/PermissionInfoResp.java | 2 +-
.../consensus/response/{ => cq}/ShowCQResp.java | 3 +-
.../CountDatabaseResp.java} | 11 +-
.../DatabaseSchemaResp.java} | 25 +-
.../response/{ => datanode}/ConfigurationResp.java | 3 +-
.../{ => datanode}/DataNodeConfigurationResp.java | 3 +-
.../{ => datanode}/DataNodeRegisterResp.java | 3 +-
.../{ => datanode}/DataNodeToStatusResp.java | 4 +-
.../response/{ => function}/FunctionTableResp.java | 2 +-
.../{ => partition}/DataPartitionResp.java | 2 +-
.../response/{ => partition}/GetRegionIdResp.java | 2 +-
.../{ => partition}/GetSeriesSlotListResp.java | 2 +-
.../{ => partition}/GetTimeSlotListResp.java | 2 +-
.../response/{ => partition}/PathInfoResp.java | 2 +-
.../{ => partition}/RegionInfoListResp.java | 2 +-
.../{ => partition}/SchemaNodeManagementResp.java | 2 +-
.../{ => partition}/SchemaPartitionResp.java | 2 +-
.../consensus/response/{ => pipe}/PipeResp.java | 3 +-
.../response/{ => pipe}/PipeSinkResp.java | 3 +-
.../{ => template}/AllTemplateSetInfoResp.java | 2 +-
.../response/{ => template}/TemplateInfoResp.java | 2 +-
.../{ => template}/TemplateSetInfoResp.java | 2 +-
.../{ => trigger}/TransferringTriggersResp.java | 2 +-
.../{ => trigger}/TriggerLocationResp.java | 2 +-
.../response/{ => trigger}/TriggerTableResp.java | 2 +-
.../consensus/response/{ => udf}/JarResp.java | 2 +-
.../statemachine/ConfigNodeRegionStateMachine.java | 70 +-
.../confignode/manager/ClusterSchemaManager.java | 155 +-
.../iotdb/confignode/manager/ConfigManager.java | 66 +-
.../apache/iotdb/confignode/manager/IManager.java | 27 +-
.../confignode/manager/PermissionManager.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 6 +-
.../iotdb/confignode/manager/SyncManager.java | 4 +-
.../iotdb/confignode/manager/TriggerManager.java | 8 +-
.../iotdb/confignode/manager/UDFManager.java | 4 +-
.../iotdb/confignode/manager/cq/CQManager.java | 2 +-
.../manager/load/LoadManagerMetrics.java | 10 +-
.../iotdb/confignode/manager/node/NodeManager.java | 8 +-
.../manager/partition/PartitionManager.java | 30 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 2 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 8 +-
.../iotdb/confignode/persistence/UDFInfo.java | 4 +-
.../iotdb/confignode/persistence/cq/CQInfo.java | 2 +-
.../persistence/executor/ConfigPlanExecutor.java | 81 +-
.../persistence/metric/PartitionInfoMetrics.java | 43 +-
.../confignode/persistence/node/NodeInfo.java | 2 +-
...itionTable.java => DatabasePartitionTable.java} | 55 +-
.../persistence/partition/PartitionInfo.java | 100 +-
.../persistence/schema/ClusterSchemaInfo.java | 137 +-
.../persistence/sync/ClusterSyncInfo.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 11 +-
.../procedure/env/DataNodeRemoveHandler.java | 2 +-
.../impl/schema/DeleteStorageGroupProcedure.java | 16 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 181 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 71 +-
.../confignode/persistence/AuthorInfoTest.java | 2 +-
.../persistence/ClusterSchemaInfoTest.java | 49 +-
.../confignode/persistence/PartitionInfoTest.java | 20 +-
.../impl/DeleteStorageGroupProcedureTest.java | 4 +-
consensus/pom.xml | 2 +-
.../org/apache/iotdb/consensus/common/Utils.java | 23 +-
.../consensus/iot/IoTConsensusServerImpl.java | 13 +
.../consensus/iot/IoTConsensusServerMetrics.java | 67 +
.../iotdb/consensus/iot/logdispatcher/Batch.java | 9 +
.../logdispatcher/IoTConsensusMemoryManager.java | 24 +-
.../IoTConsensusMemoryManagerMetrics.java | 18 +
.../consensus/iot/logdispatcher/LogDispatcher.java | 25 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 4 +-
.../ratis/ApplicationStateMachineProxy.java | 9 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 16 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 19 +-
.../iotdb/consensus/ratis/RequestMessage.java | 6 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 6 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 9 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 44 -
docs/UserGuide/FAQ/Frequently-asked-questions.md | 2 +-
docs/UserGuide/Monitor-Alert/Alerting.md | 2 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 149 +-
.../Apache-IoTDB-DataNode-Dashboard.json | 5565 +++++++++++---------
...ache-IoTDB-Performance-Overview-Dashboard.json} | 2112 +++++---
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 445 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 98 +-
.../UserGuide/API/Programming-Java-Native-API.md | 36 -
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 2 +-
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 616 ++-
.../UserGuide/Operators-Functions/Aggregation.md | 92 +-
grafana-connector/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
integration-test/checkstyle.xml | 4 +-
integration-test/pom.xml | 12 +-
.../iotdb/it/env/cluster/MppCommonConfig.java | 6 +
.../it/env/cluster/MppSharedCommonConfig.java | 7 +
.../iotdb/it/env/remote/RemoteCommonConfig.java | 5 +
.../framework/IoTDBTestRunnerWithParameters.java | 59 +
.../IoTDBTestRunnerWithParametersFactory.java | 21 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
.../confignode/it/IoTDBClusterAuthorityIT.java | 1 +
.../it/IoTDBConfigNodeConsensusEfficiencyIT.java | 203 +
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 9 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 1 +
.../it/cluster/IoTDBClusterRestartIT.java | 5 +-
.../it/database/IoTDBDatabaseRegionControlIT.java | 236 +
.../IoTDBDatabaseSetAndDeleteIT.java} | 85 +-
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 9 +-
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 7 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 20 +-
.../IoTDBCustomRegionGroupExtensionIT.java | 10 +-
.../it/partition/IoTDBPartitionCreationIT.java | 6 +-
.../it/partition/IoTDBPartitionDurableIT.java | 6 +-
.../it/partition/IoTDBPartitionGetterIT.java | 16 +-
.../partition/IoTDBPartitionInheritPolicyIT.java | 6 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 7 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 16 +-
.../IoTDBCountIf2IT.java} | 30 +-
.../IoTDBCountIf3IT.java} | 34 +-
.../iotdb/db/it/aggregation/IoTDBCountIfIT.java | 241 +
.../iotdb/db/it/schema/AbstractSchemaIT.java | 92 +
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 59 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 65 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 82 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 23 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 297 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 211 +-
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 11 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 516 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 32 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 760 +--
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 28 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 13 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 33 +-
.../java/org/apache/iotdb/isession/ISession.java | 7 +
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 11 +-
.../metrics/metricsets/jvm/JvmMemoryMetrics.java | 12 +-
.../metrics/metricsets/jvm/JvmThreadMetrics.java | 14 +-
.../metricsets/logback/MetricsTurboFilter.java | 10 +-
.../reporter/prometheus/PrometheusReporter.java | 6 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 4 +-
.../micrometer/MicrometerMetricManager.java | 4 +-
.../resources/conf/iotdb-common.properties | 5 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 1 +
.../iotdb/commons/service/metric/enums/Metric.java | 5 +-
.../udf/builtin/BuiltinAggregationFunction.java | 47 +
...tinScalarFunction.java => BuiltinFunction.java} | 19 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 14 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 6 +-
.../rocksdb/mnode/RStorageGroupMNode.java | 6 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 10 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 60 +-
.../iotdb/db/client/DataNodeInternalClient.java | 1 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 43 +-
.../statemachine/DataRegionStateMachine.java | 8 +-
.../IoTConsensusDataRegionStateMachine.java | 8 +-
.../org/apache/iotdb/db/constant/SqlConstant.java | 1 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 12 +-
.../execute/task/AbstractCompactionTask.java | 14 +
.../execute/task/CrossSpaceCompactionTask.java | 6 +-
.../execute/task/InnerSpaceCompactionTask.java | 6 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 26 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 42 +-
.../utils/writer/AbstractCompactionWriter.java | 15 +-
.../compaction/schedule/CompactionTaskManager.java | 15 +-
.../compaction/schedule/CompactionWorker.java | 7 +-
.../iotdb/db/engine/flush/FlushManagerMetrics.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 8 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 136 +-
.../db/engine/storagegroup/TsFileProcessor.java | 21 +
.../apache/iotdb/db/metadata/MetadataConstant.java | 1 +
.../db/metadata/cache/DataNodeSchemaCache.java | 44 +
.../iotdb/db/metadata/logfile/MLogDescription.java | 63 +
.../db/metadata/logfile/MLogDescriptionReader.java | 39 +-
.../db/metadata/logfile/MLogDescriptionWriter.java | 53 +
.../iotdb/db/metadata/logfile/SchemaLogReader.java | 5 +
.../iotdb/db/metadata/logfile/SchemaLogWriter.java | 5 +-
.../db/metadata/mnode/IStorageGroupMNode.java | 6 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 6 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 10 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 26 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 17 +-
.../mtree/store/disk/cache/CacheMemoryManager.java | 49 +-
.../MemManagerNodeEstimatedSizeBasedImpl.java | 1 +
.../mtree/store/disk/schemafile/SchemaFile.java | 8 +-
.../rescon/SchemaResourceManagerMetrics.java | 2 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 123 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 8 +-
.../db/mpp/aggregation/AccumulatorFactory.java | 56 +-
.../db/mpp/aggregation/CountIfAccumulator.java | 156 +
.../SlidingWindowAggregatorFactory.java | 9 +-
.../iotdb/db/mpp/common/FragmentInstanceId.java | 7 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 1 +
.../db/mpp/common/header/DatasetHeaderFactory.java | 2 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 33 +
.../common/schematree/IMeasurementSchemaInfo.java | 20 +-
.../schematree/node/SchemaMeasurementNode.java | 3 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 23 +-
.../db/mpp/execution/exchange/SinkHandle.java | 23 +-
.../db/mpp/execution/exchange/SourceHandle.java | 25 +-
.../execution/executor/RegionWriteExecutor.java | 34 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 41 +-
.../operator/process/AggregationOperator.java | 6 +-
...erator.java => HorizontallyConcatOperator.java} | 11 +-
.../db/mpp/metric/PerformanceOverviewMetrics.java | 142 +
.../metric/PerformanceOverviewMetricsManager.java | 177 +
.../iotdb/db/mpp/metric/QueryMetricsManager.java | 4 +-
.../db/mpp/metric/QueryPlanCostMetricSet.java | 9 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 14 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 20 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 76 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 52 +-
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 4 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 16 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 178 +-
.../schema/ISchemaAutoCreation.java} | 24 +-
.../schema/ISchemaComputation.java} | 25 +-
.../schema/ISchemaComputationWithAutoCreation.java | 22 +-
.../db/mpp/plan/analyze/schema/ISchemaFetcher.java | 44 +-
.../mpp/plan/analyze/schema/ISchemaValidation.java | 31 +-
.../mpp/plan/analyze/schema/SchemaValidator.java | 34 +-
.../db/mpp/plan/execution/QueryExecution.java | 34 +-
.../plan/execution/config/ConfigTaskVisitor.java | 13 +-
.../config/executor/ClusterConfigTaskExecutor.java | 191 +-
.../config/executor/IConfigTaskExecutor.java | 7 +-
.../config/metadata/DatabaseSchemaTask.java | 80 +
.../config/metadata/SetStorageGroupTask.java | 74 -
.../execution/config/metadata/ShowRegionTask.java | 28 +-
.../plan/expression/multi/FunctionExpression.java | 40 +-
.../db/mpp/plan/expression/multi/FunctionType.java | 24 +-
.../visitor/ColumnTransformerVisitor.java | 6 +-
.../visitor/IntermediateLayerVisitor.java | 6 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 102 +-
.../db/mpp/plan/parser/StatementGenerator.java | 302 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 19 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 20 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 40 +-
.../distribution/DistributionPlanContext.java | 14 +
.../planner/distribution/ExchangeNodeAdder.java | 10 +-
.../plan/planner/distribution/SourceRewriter.java | 79 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 4 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 10 +
.../mpp/plan/planner/plan/node/PlanNodeType.java | 4 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 4 +-
...ConcatNode.java => HorizontallyConcatNode.java} | 14 +-
.../planner/plan/node/write/BatchInsertNode.java | 11 +-
.../plan/node/write/InsertMultiTabletsNode.java | 52 +-
.../plan/planner/plan/node/write/InsertNode.java | 76 +-
.../planner/plan/node/write/InsertRowNode.java | 100 +-
.../planner/plan/node/write/InsertRowsNode.java | 53 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 51 +-
.../planner/plan/node/write/InsertTabletNode.java | 83 +-
.../plan/parameter/AggregationDescriptor.java | 89 +-
.../CrossSeriesAggregationDescriptor.java | 110 +-
.../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 105 +
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 61 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 12 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 72 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 2 +-
.../db/mpp/plan/statement/StatementVisitor.java | 10 +-
...Statement.java => DatabaseSchemaStatement.java} | 27 +-
.../metadata/ShowStorageGroupStatement.java | 8 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 1 -
.../db/service/metrics/CompactionMetrics.java | 232 +
.../db/service/metrics/DataNodeMetricsHelper.java | 1 +
.../iotdb/db/service/metrics/FileMetrics.java | 30 +-
.../metrics/IoTDBInternalLocalReporter.java | 4 +-
.../metrics/recorder/CompactionMetricsManager.java | 225 +
.../recorder/CompactionMetricsRecorder.java | 190 -
.../service/thrift/impl/ClientRPCServiceImpl.java | 40 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 21 +-
.../db/sync/transport/server/ReceiverManager.java | 5 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 1 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 105 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 18 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 12 +-
.../schemaRegion/SchemaRegionBasicTest.java | 45 +-
.../iotdb/db/mpp/aggregation/AccumulatorTest.java | 71 +-
.../execution/exchange/LocalSinkHandleTest.java | 14 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 28 +-
.../mpp/execution/exchange/SourceHandleTest.java | 10 +-
.../operator/AggregationOperatorTest.java | 14 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 112 +-
...st.java => HorizontallyConcatOperatorTest.java} | 32 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 24 +-
.../operator/RawDataAggregationOperatorTest.java | 8 +-
.../SeriesAggregationScanOperatorTest.java | 112 +-
.../SlidingWindowAggregationOperatorTest.java | 9 +-
.../plan/analyze/AggregationDescriptorTest.java | 53 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 6 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 24 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 2 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 18 +
.../iotdb/db/mpp/plan/plan/QueryPlannerTest.java | 17 +-
.../distribution/AggregationDistributionTest.java | 30 +-
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 21 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 2 +
.../plan/node/process/GroupByTagNodeSerdeTest.java | 4 +
.../java/org/apache/iotdb/session/Session.java | 31 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 16 +-
thrift-commons/src/main/thrift/common.thrift | 3 +-
.../src/main/thrift/confignode.thrift | 122 +-
313 files changed, 12910 insertions(+), 7457 deletions(-)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{storagegroup/CountStorageGroupPlan.java => database/CountDatabasePlan.java} (79%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{storagegroup/GetStorageGroupPlan.java => database/GetDatabasePlan.java} (71%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/{SetStorageGroupPlan.java => DatabaseSchemaPlan.java} (75%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/{DeleteStorageGroupPlan.java => DeleteDatabasePlan.java} (83%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/storagegroup/{PreDeleteStorageGroupPlan.java => PreDeleteDatabasePlan.java} (75%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => auth}/PermissionInfoResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => cq}/ShowCQResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{CountStorageGroupResp.java => database/CountDatabaseResp.java} (82%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{StorageGroupSchemaResp.java => database/DatabaseSchemaResp.java} (65%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => datanode}/ConfigurationResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => datanode}/DataNodeConfigurationResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => datanode}/DataNodeRegisterResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => datanode}/DataNodeToStatusResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => function}/FunctionTableResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/DataPartitionResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/GetRegionIdResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/GetSeriesSlotListResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/GetTimeSlotListResp.java (96%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/PathInfoResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/RegionInfoListResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/SchemaNodeManagementResp.java (98%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => partition}/SchemaPartitionResp.java (97%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => pipe}/PipeResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => pipe}/PipeSinkResp.java (95%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => template}/AllTemplateSetInfoResp.java (94%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => template}/TemplateInfoResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => template}/TemplateSetInfoResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => trigger}/TransferringTriggersResp.java (95%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => trigger}/TriggerLocationResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => trigger}/TriggerTableResp.java (97%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/{ => udf}/JarResp.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/partition/{StorageGroupPartitionTable.java => DatabasePartitionTable.java} (93%)
copy docs/UserGuide/Monitor-Alert/{Apache-IoTDB-ConfigNode-Dashboard.json => Apache-IoTDB-Performance-Overview-Dashboard.json} (63%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParameters.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/storagegroup/GetStorageGroupPlan.java => integration-test/src/main/java/org/apache/iotdb/it/framework/IoTDBTestRunnerWithParametersFactory.java (62%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/IoTDBConfigNodeConsensusEfficiencyIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/database/IoTDBDatabaseRegionControlIT.java
rename integration-test/src/test/java/org/apache/iotdb/confignode/it/{IoTDBStorageGroupIT.java => database/IoTDBDatabaseSetAndDeleteIT.java} (70%)
rename integration-test/src/test/java/org/apache/iotdb/db/it/{schema/IoTDBDeleteTimeseriesSchemaFileIT.java => aggregation/IoTDBCountIf2IT.java} (62%)
rename integration-test/src/test/java/org/apache/iotdb/db/it/{schema/IoTDBMetadataFetchSchemaFileIT.java => aggregation/IoTDBCountIf3IT.java} (62%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBCountIfIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/AbstractSchemaIT.java
rename node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/{BuiltinScalarFunction.java => BuiltinFunction.java} (77%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogDescription.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/JarResp.java => server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogDescriptionReader.java (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/logfile/MLogDescriptionWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/aggregation/CountIfAccumulator.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/AllTemplateSetInfoResp.java => server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/IMeasurementSchemaInfo.java (64%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/join/{VerticallyConcatOperator.java => HorizontallyConcatOperator.java} (95%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/PerformanceOverviewMetrics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/metric/PerformanceOverviewMetricsManager.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/{planner/plan/node/write/BatchInsertNode.java => analyze/schema/ISchemaAutoCreation.java} (63%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/{planner/plan/node/write/BatchInsertNode.java => analyze/schema/ISchemaComputation.java} (54%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/AllTemplateSetInfoResp.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ISchemaComputationWithAutoCreation.java (63%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PathInfoResp.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ISchemaValidation.java (54%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/DatabaseSchemaTask.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/SetStorageGroupTask.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/AllTemplateSetInfoResp.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/multi/FunctionType.java (64%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{VerticallyConcatNode.java => HorizontallyConcatNode.java} (86%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/AsyncPlanNodeSender.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/AsyncSendPlanNodeHandler.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{SetStorageGroupStatement.java => DatabaseSchemaStatement.java} (85%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/CompactionMetrics.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CompactionMetricsManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/service/metrics/recorder/CompactionMetricsRecorder.java
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/{VerticallyConcatOperatorTest.java => HorizontallyConcatOperatorTest.java} (88%)