You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ma...@apache.org on 2023/03/01 02:11:38 UTC
[iotdb] branch IOTDB-5517 updated (cc272d1fbe -> 20445866f4)
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a change to branch IOTDB-5517
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard cc272d1fbe update dashboard
discard 5a544742eb fix getting merge read and merge write mistakenly
add 16c1c9efab Fix python IT fail caused by the database root.__system (#9116)
add bb7973f564 [IOTDB-5516] Try sync delete schema region when dropping database (#9108)
add 99ea2c9f7e [IOTDB-5546] Allow consumeAllOperator to run when only some of children is blocked
add 63e88d9221 feat(site): 1. Add Page RightMenu 2. Enable Algolia Search 3. Add ESLint And Fix config.js (#9125)
add ee49665f4d [IOTDB-5524] Add Metrics for Schema Module (#9109)
add b20758ac56 [IOTDB-5516] Accelerate async delete DataRegion during dropping database (#9120)
add 3a4aee19cc Fix CI error by ignore license check for some site files (#9127)
add 92358e9d30 [IOTDB-5577] Metric dashboard for Schema Module (#9135)
add a2c935aa68 [IOTDB-5533] Add IoTDB Internal Reporter params back and Modify the config of root.__system (#9119)
add 081b44d4d6 feat(WebSite) :DocSearch Filter By Version (#9134)
add 8238428d3c [IOTDB-4005] Allow the following child pipeline to run in advance
add 753d3f29fb [IOTDB-5559] Implement metric exporters for RatisConsensus (#9099)
add 6f02e5888a Remove 0.8-0.12 docs & fix the bad urls on the master branch (#9091)
add a25af89278 Add a paper to the Publication_zh doc (#9067)
add 854e4c8b9c [IOTDB-5454] Support shuffle function of DataExchangeModule
add a3869ec324 [IOTDB-5147]Optimize compaction schedule when priority is BALANCE (#9103)
add 2f385d4067 Update nifi doc (#9051)
add 1c040f28db Fix some broken links in README (#9066)
add de6d1526bd [IOTDB-5578] Keep CacheMemoryManager monitor alive when exception (#9133)
add ce0c43263f [IOTDB-5524] Update metric docs for schema module (#9136)
add 06bb621a99 Modify Group-By UserGuide
add 468c0fbd19 [IOTDB-5542] ConfigNode counter dashboard (#9129)
add 5920e65a20 [IOTDB-5581] Missing reset of aggregators in RawDataAggregationOperator
add ad93ca04fb [IOTDB-5575] Pipe SDK: PipeProcessor & PipeConnector (#9131)
add 415f68e36b [IOTDB-4898] Push offset and limit down to ScanOperator if possible
add 2bc29bb0d1 [IOTDB-5582] Add region type in ratis metric prefix (#9140)
add b6afc6e768 [IOTDB-5538] Deprecate configuration parameter `max_deduplicated_path_num`
add a14022a294 [IOTDB-5585] Change InternalReporterType from IoTDB to Memory to reduce performance degradation
add c5bea4166e Use req.getName() as templateName in ClientRpcServiceImpl (#9142)
add 74c950d165 [IOTDB-5584] Fix wrong intialization in GROUP BY CONDITION
add 12d9e73d6f [IOTDB-5462] Optimize the memory estimation of ExchangeOperator in the pipelin
add 67accf77f9 fix exception caused by pre deleted db (#9151)
add 53431766c6 [IOTDB-5081] Implement model management on ConfigNode (#9090)
add 9d1a076aef [IOTDB-5458] Add Session Idle Time Metrics and Upgrade Thrift related Metrics (#9124)
add 9cd09d903f [IOTDB-5587] Add dataRegionId into Memtable and update flush point metrics (#9148)
add 5148854eaa Bump http-cache-semantics from 4.1.0 to 4.1.1 in /grafana-plugin (#8980)
add a5b2362f31 Bump decode-uri-component from 0.2.0 to 0.2.2 in /grafana-plugin (#8292)
add 94ad9f32a9 [IOTDB-5587] Update the cluster info and node info of metrics (#9147)
add 4cb5ff1b2c [IOTDB-5590] convert __endTime to UTC in cli
add 7959c1d769 [IOTDB-5555] Enable modify external RPC EndPoint of DataNode (#9155)
add 4ae7b3ab89 [IOTDB-5592] Fix unexpected error when use full path in having/where (#9157)
add 4fd995957f [IOTDB-5593] Improve efficiency of DistributionPlanner by recording map instead of recursive search
add fc8d05baa1 [IOTDB-5545] Implement SchemaRegionLoader for SchemaEngine (#9156)
add cbddb29bbd [IOTDB-5595] Fix memory leak for TsFileProcessorInfoMetrics in TsFileProcessorInfo (#9162)
add cff9a6437c Add TsFileResource back to TsFileResourceManager when all time index are file level (#9164)
add 2ba24ca41c [IOTDB-5147]Optimize compaction schedule when priority is BALANCE (#9163)
add 11837a29ad [IOTDB-5516] Fix delete schema region bug during drop database (#9170)
add 3ef36de873 [IOTDB-5596] Rename ConfigNodeRegion to ConfigRegion (#9168)
new 20445866f4 fix mistake in DiskMetrics tags
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (cc272d1fbe)
\
N -- N -- N refs/heads/IOTDB-5517 (20445866f4)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/site-build.yml | 6 +-
README.md | 4 +-
README_ZH.md | 4 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 14 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 8 +
client-py/iotdb/sqlalchemy/tests/test_dialect.py | 2 +-
client-py/tests/test_dataframe.py | 4 +-
client-py/tests/test_todf.py | 6 +-
.../confignode/client/DataNodeRequestType.java | 5 +-
.../client/async/AsyncDataNodeClientPool.java | 7 +
.../client/sync/SyncDataNodeClientPool.java | 3 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 10 +-
.../iotdb/confignode/conf/ConfigNodeConstant.java | 11 +-
.../confignode/conf/ConfigNodeDescriptor.java | 3 +-
.../consensus/request/ConfigPhysicalPlan.java | 28 +
.../consensus/request/ConfigPhysicalPlanType.java | 11 +-
.../model/ShowModelPlan.java} | 58 +-
.../request/read/model/ShowTrailPlan.java | 97 +
.../request/write/datanode/UpdateDataNodePlan.java | 32 +-
.../CreateModelPlan.java} | 47 +-
.../DropModelPlan.java} | 50 +-
.../request/write/model/UpdateModelInfoPlan.java | 98 +
.../request/write/model/UpdateModelStatePlan.java | 105 +
.../region/PollSpecificRegionMaintainTaskPlan.java | 70 +
.../consensus/response/ModelTableResp.java | 55 +
.../consensus/response/TrailTableResp.java | 55 +
...eMachine.java => ConfigRegionStateMachine.java} | 89 +-
.../confignode/manager/ClusterSchemaManager.java | 63 +-
.../iotdb/confignode/manager/ConfigManager.java | 99 +-
.../apache/iotdb/confignode/manager/IManager.java | 36 +-
.../iotdb/confignode/manager/ModelManager.java | 158 +
.../confignode/manager/PermissionManager.java | 6 +-
.../iotdb/confignode/manager/ProcedureManager.java | 38 +-
.../iotdb/confignode/manager/SyncManager.java | 6 +-
.../iotdb/confignode/manager/TriggerManager.java | 2 +
.../manager/{ => consensus}/ConsensusManager.java | 57 +-
.../iotdb/confignode/manager/load/LoadManager.java | 35 +-
.../manager/load/LoadManagerMetrics.java | 326 --
.../manager/node/ClusterNodeStartUtils.java | 88 +-
.../iotdb/confignode/manager/node/NodeManager.java | 67 +-
.../iotdb/confignode/manager/node/NodeMetrics.java | 104 +
.../manager/partition/PartitionManager.java | 386 +-
.../manager/partition/PartitionMetrics.java | 353 ++
.../iotdb/confignode/persistence/ModelInfo.java | 214 +
.../persistence/executor/ConfigPlanExecutor.java | 31 +-
.../persistence/metric/PartitionInfoMetrics.java | 197 -
.../confignode/persistence/node/NodeInfo.java | 6 +-
.../partition/DatabasePartitionTable.java | 38 +-
.../persistence/partition/PartitionInfo.java | 249 +-
.../partition/maintainer/RegionCreateTask.java | 6 +
.../partition/maintainer/RegionMaintainTask.java | 3 +
.../persistence/schema/ClusterSchemaInfo.java | 100 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 4 +-
.../procedure/env/DataNodeRemoveHandler.java | 15 +-
.../procedure/impl/model/CreateModelProcedure.java | 224 +
.../procedure/impl/model/DropModelProcedure.java | 240 +
...Procedure.java => DeleteDatabaseProcedure.java} | 116 +-
.../procedure/state/model/CreateModelState.java | 11 +-
.../procedure/state/model/DropModelState.java | 13 +-
.../procedure/store/ConfigProcedureStore.java | 2 +-
.../procedure/store/ProcedureFactory.java | 14 +-
.../confignode/procedure/store/ProcedureType.java | 6 +-
.../iotdb/confignode/service/ConfigNode.java | 28 +-
.../thrift/ConfigNodeRPCServiceHandlerMetrics.java | 4 +-
.../thrift/ConfigNodeRPCServiceMetrics.java | 5 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 44 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 49 +-
...eTest.java => DeleteDatabaseProcedureTest.java} | 11 +-
consensus/README.md | 2 +-
.../iotdb/consensus/config/ConsensusConfig.java | 15 +
.../iotdb/consensus/ratis/RatisConsensus.java | 13 +-
.../consensus/ratis/metrics/CounterProxy.java | 42 +-
.../iotdb/consensus/ratis/metrics/GaugeProxy.java | 29 +-
.../ratis/metrics/IoTDBMetricRegistry.java | 206 +
.../ratis/metrics/MetricRegistryManager.java | 105 +
.../consensus/ratis/metrics/RatisMetricSet.java | 48 +
.../consensus/ratis/metrics/RefCountingMap.java | 97 +
.../iotdb/consensus/ratis/metrics/TimerProxy.java | 26 +-
.../org.apache.ratis.metrics.MetricRegistries | 17 +
.../apache/iotdb/consensus/iot/ReplicateTest.java | 2 +
.../apache/iotdb/consensus/iot/StabilityTest.java | 2 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 2 +
.../apache/iotdb/consensus/ratis/UtilsTest.java | 4 +-
.../iotdb/consensus/simple/RecoveryTest.java | 2 +
.../consensus/simple/SimpleConsensusTest.java | 4 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 2 +-
docs/UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 4 +-
docs/UserGuide/Monitor-Alert/Alerting.md | 2 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 5186 +++++++++++++-------
.../Apache-IoTDB-DataNode-Dashboard.json | 2796 +++++++++--
...pache-IoTDB-Performance-Overview-Dashboard.json | 363 +-
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 234 +-
docs/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
docs/UserGuide/Query-Data/Group-By.md | 169 +-
docs/UserGuide/Query-Data/Overview.md | 4 +-
docs/UserGuide/Query-Data/Select-Expression.md | 2 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 17 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 2 +-
.../UserGuide/Ecosystem-Integration/NiFi-IoTDB.md | 4 +-
.../zh/UserGuide/IoTDB-Introduction/Publication.md | 1 +
docs/zh/UserGuide/Monitor-Alert/Alerting.md | 2 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 246 +-
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 2 +-
docs/zh/UserGuide/Query-Data/Group-By.md | 167 +-
docs/zh/UserGuide/Query-Data/Overview.md | 4 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 2 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 40 +-
docs/zh/UserGuide/Write-Data/Batch-Load-Tool.md | 2 +-
grafana-plugin/yarn.lock | 12 +-
.../apache/iotdb/it/env/cluster/AbstractEnv.java | 8 +-
.../iotdb/it/env/cluster/AbstractNodeWrapper.java | 6 +-
.../iotdb/it/env/cluster/ConfigNodeWrapper.java | 42 +-
.../iotdb/it/env/cluster/DataNodeWrapper.java | 65 +-
.../iotdb/it/env/cluster/MppCommonConfig.java | 8 +-
.../it/env/cluster/MppSharedCommonConfig.java | 13 +-
.../iotdb/it/env/remote/RemoteCommonConfig.java | 7 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 4 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 7 +-
.../it/cluster/IoTDBClusterRestartIT.java | 117 +-
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 2 +-
.../it/partition/IoTDBPartitionGetterIT.java | 6 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 27 +-
.../db/it/aggregation/IoTDBTagAggregation2IT.java | 51 +
.../db/it/aggregation/IoTDBTagAggregationIT.java | 4 +-
.../db/it/alignbydevice/IoTDBShuffleSink1IT.java | 150 +
.../db/it/alignbydevice/IoTDBShuffleSink2IT.java | 205 +
...ySeriesIT.java => IoTDBGroupByConditionIT.java} | 78 +-
.../iotdb/db/it/groupby/IoTDBGroupBySessionIT.java | 21 +-
.../db/it/groupby/IoTDBGroupByVariationIT.java | 37 +
.../apache/iotdb/db/it/path/IoTDBFullPathIT.java | 82 +
.../iotdb/db/it/{ => path}/IoTDBQuotedPathIT.java | 2 +-
.../iotdb/db/it/query/IoTDBPaginationIT.java | 9 -
.../db/integration/IoTDBQueryMemoryControlIT.java | 277 --
.../db/integration/env/StandaloneEnvConfig.java | 7 -
.../apache/iotdb/metrics/config/MetricConfig.java | 42 +-
.../metrics/config/MetricConfigDescriptor.java | 6 +-
.../apache/iotdb/metrics/config/ReloadLevel.java | 2 +
.../reporter/iotdb/IoTDBSessionReporter.java | 12 +-
.../reporter/prometheus/PrometheusTextWriter.java | 11 +
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 8 +-
.../org/apache/iotdb/metrics/utils/NodeType.java | 14 +-
.../iotdb/metrics/config/MetricConfigTest.java | 3 +
node-commons/pom.xml | 5 +
.../resources/conf/iotdb-common.properties | 13 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 1 +
.../org/apache/iotdb/commons/cluster/NodeType.java | 3 +-
.../iotdb/commons/cluster/RegionRoleType.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 20 +
.../iotdb/commons/conf/CommonDescriptor.java | 14 +
...ConfigNodeRegionId.java => ConfigRegionId.java} | 6 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 8 +-
.../iotdb/commons/model/ModelHyperparameter.java | 71 +
.../iotdb/commons/model/ModelInformation.java | 229 +
.../org/apache/iotdb/commons/model/ModelTable.java | 91 +
.../iotdb/commons/model/TrailInformation.java | 101 +
.../model/exception/ModelManagementException.java | 10 +-
.../iotdb/commons/service/metric/enums/Metric.java | 21 +-
.../commons/utils/ThriftCommonsSerDeUtils.java | 19 +
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 32 +-
pipe-api/pom.xml | 68 +
.../org/apache/iotdb/pipe/api/PipeConnector.java | 136 +
.../org/apache/iotdb/pipe/api/PipeProcessor.java | 117 +
.../java/org/apache/iotdb/pipe/api/access/Row.java | 154 +
.../apache/iotdb/pipe/api/access/RowIterator.java | 75 +
.../iotdb/pipe/api/collector/EventCollector.java | 62 +
.../iotdb/pipe/api/collector/RowCollector.java | 34 +-
.../api/customizer/PipeParameterValidator.java | 99 +
.../iotdb/pipe/api/customizer/PipeParameters.java | 112 +
.../api/customizer/PipeRuntimeConfiguration.java | 12 +-
.../iotdb/pipe/api/customizer/PipeStrategy.java | 12 +-
.../PipeConnectorRuntimeConfiguration.java | 84 +
.../connector/parallel/ParallelStrategy.java | 10 +-
.../retry/EqualRetryIntervalStrategy.java | 63 +
.../retry/ExponentialRetryIntervalStrategy.java | 70 +
.../customizer/connector/retry/RetryStrategy.java | 29 +-
.../customizer/connector/reuse/ReuseStrategy.java | 10 +-
.../PipeProcessorRuntimeConfiguration.java | 21 +-
.../org/apache/iotdb/pipe/api/event/Event.java | 9 +-
.../pipe/api/event/deletion/DeletionEvent.java | 31 +-
.../api/event/insertion/TabletInsertionEvent.java | 56 +
.../api/event/insertion/TsFileInsertionEvent.java | 44 +
.../PipeAttributeNotProvidedException.java | 11 +-
.../iotdb/pipe/api/exception/PipeException.java | 15 +-
.../exception/PipeParameterNotValidException.java | 11 +-
.../exception/PipeStrategyNotValidException.java | 11 +-
.../org/apache/iotdb/pipe/api/type/Binary.java | 151 +
.../java/org/apache/iotdb/pipe/api/type/Type.java | 32 +-
pom.xml | 4 +
.../schemaregion/rocksdb/RSchemaRegion.java | 18 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 6 +
.../resources/conf/iotdb-datanode.properties | 7 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 4 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 14 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 46 +-
.../iotdb/db/client/ConfigNodeClientManager.java | 8 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 8 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 14 +-
.../org/apache/iotdb/db/client/MLNodeClient.java | 134 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 21 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 37 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 22 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 +
.../db/consensus/SchemaRegionConsensusImpl.java | 2 +
.../execute/task/InnerSpaceCompactionTask.java | 9 +-
.../compaction/schedule/CompactionScheduler.java | 131 +-
.../compaction/schedule/CompactionTaskManager.java | 13 +-
.../DefaultCompactionTaskComparatorImpl.java | 21 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 63 +-
.../impl/SizeTieredCompactionSelector.java | 26 +-
.../utils/CrossSpaceCompactionCandidate.java | 6 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 17 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../db/engine/storagegroup/TsFileProcessor.java | 6 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 14 +-
.../storagegroup/TsFileProcessorInfoMetrics.java | 4 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 5 +
.../ISchemaEngineMetric.java} | 9 +-
.../ISchemaRegionMetric.java} | 9 +-
.../metadata/metric/SchemaEngineCachedMetric.java | 187 +
.../db/metadata/metric/SchemaEngineMemMetric.java | 131 +
.../db/metadata/metric/SchemaMetricManager.java | 85 +
.../metadata/metric/SchemaRegionCachedMetric.java | 188 +
.../db/metadata/metric/SchemaRegionMemMetric.java | 80 +
.../db/metadata/mtree/store/CachedMTreeStore.java | 12 +-
.../mtree/store/disk/cache/CacheManager.java | 13 +
.../mtree/store/disk/cache/CacheMemoryManager.java | 48 +-
.../mtree/store/disk/cache/ICacheManager.java | 4 +
.../mtree/store/disk/cache/LRUCacheManager.java | 15 +
.../mtree/store/disk/cache/PlainCacheManager.java | 5 +
.../ReleaseFlushStrategyNumBasedImpl.java | 4 +-
.../ReleaseFlushStrategySizeBasedImpl.java | 4 +-
.../traverser/TraverserWithLimitOffsetWrapper.java | 6 +-
.../impl/read/AbstractShowSchemaPlanImpl.java | 10 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 6 +-
.../impl/read/ShowDevicesPlanImpl.java | 2 +-
.../impl/read/ShowTimeSeriesPlanImpl.java | 4 +-
.../plan/schemaregion/read/IShowSchemaPlan.java | 4 +-
.../rescon/CachedSchemaEngineStatistics.java | 13 +-
.../rescon/CachedSchemaRegionStatistics.java | 36 +-
.../metadata/rescon/ISchemaEngineStatistics.java | 3 +-
.../metadata/rescon/MemSchemaEngineStatistics.java | 19 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 16 +-
.../rescon/SchemaEngineStatisticsHolder.java | 41 -
.../db/metadata/rescon/SchemaResourceManager.java | 14 +-
.../rescon/SchemaResourceManagerMetrics.java | 96 -
.../db/metadata/schemaregion/ISchemaRegion.java | 3 +
...emaEngineMode.java => ISchemaRegionParams.java} | 18 +-
.../metadata/schemaregion/RSchemaRegionLoader.java | 24 +-
.../db/metadata/schemaregion/SchemaEngine.java | 99 +-
.../db/metadata/schemaregion/SchemaEngineMode.java | 16 +-
.../{SchemaEngineMode.java => SchemaRegion.java} | 13 +-
.../metadata/schemaregion/SchemaRegionLoader.java | 124 +
.../schemaregion/SchemaRegionMemoryImpl.java | 25 +-
.../metadata/schemaregion/SchemaRegionParams.java | 67 +
.../schemaregion/SchemaRegionSchemaFileImpl.java | 25 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 4 +-
.../metadata/template/ClusterTemplateManager.java | 16 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 33 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 18 +-
.../db/mpp/execution/driver/DriverContext.java | 12 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 6 +-
.../exchange/IMPPDataExchangeManager.java | 34 +-
.../execution/exchange/MPPDataExchangeManager.java | 334 +-
.../exchange/MPPDataExchangeServiceMetrics.java | 2 +-
...MppDataExchangeServiceThriftHandlerMetrics.java | 6 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 33 +-
.../exchange/sink/DownStreamChannelIndex.java | 19 +-
.../exchange/sink/DownStreamChannelLocation.java | 111 +
.../exchange/{ISinkHandle.java => sink/ISink.java} | 41 +-
.../mpp/execution/exchange/sink/ISinkChannel.java | 18 +-
.../execution/exchange/sink/ISinkHandle.java} | 23 +-
.../LocalSinkChannel.java} | 89 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 299 ++
.../{SinkHandle.java => sink/SinkChannel.java} | 169 +-
.../exchange/{ => source}/ISourceHandle.java | 2 +-
.../exchange/{ => source}/LocalSourceHandle.java | 24 +-
.../exchange/{ => source}/SourceHandle.java | 49 +-
.../fragment/FragmentInstanceExecution.java | 20 +-
.../fragment/FragmentInstanceManager.java | 14 +-
.../process/AbstractConsumeAllOperator.java | 126 +
.../operator/process/AggregationOperator.java | 78 +-
.../operator/process/DeviceMergeOperator.java | 1 +
.../operator/process/MergeSortOperator.java | 103 +-
.../process/RawDataAggregationOperator.java | 5 +-
.../operator/process/TagAggregationOperator.java | 93 +-
.../process/join/HorizontallyConcatOperator.java | 68 +-
.../process/join/RowBasedTimeJoinOperator.java | 125 +-
.../operator/process/join/TimeJoinOperator.java | 4 +-
.../operator/schema/source/DeviceSchemaSource.java | 6 +-
.../schema/source/SchemaSourceFactory.java | 6 +-
.../schema/source/TimeSeriesSchemaSource.java | 8 +-
.../operator/sink/IdentitySinkOperator.java | 132 +
.../operator/sink/ShuffleHelperOperator.java | 134 +
.../operator/source/ExchangeOperator.java | 25 +-
.../operator/window/SeriesWindowManager.java | 4 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 4 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 4 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 2 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 18 +-
.../plan/analyze/ColumnPaginationController.java | 36 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 34 +
.../db/mpp/plan/analyze/cache/PartitionCache.java | 10 +-
.../db/mpp/plan/execution/QueryExecution.java | 5 +-
.../config/executor/ClusterConfigTaskExecutor.java | 99 +-
.../plan/execution/memory/MemorySourceHandle.java | 2 +-
.../memory/StatementMemorySourceVisitor.java | 5 +-
.../db/mpp/plan/expression/ExpressionFactory.java | 4 +
.../mpp/plan/optimization/LimitOffsetPushDown.java | 241 +
.../db/mpp/plan/optimization/PlanOptimizer.java | 3 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 93 +-
.../db/mpp/plan/parser/StatementGenerator.java | 2 +-
.../plan/planner/LocalExecutionPlanContext.java | 10 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 10 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 8 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 2 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 131 +-
.../planner/distribution/DistributionPlanner.java | 146 +-
.../planner/distribution/ExchangeNodeAdder.java | 201 +-
.../planner/distribution/NodeGroupContext.java | 46 +-
.../SimpleFragmentParallelPlanner.java | 56 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 15 -
.../db/mpp/plan/planner/plan/PlanFragment.java | 18 -
.../plan/planner/plan/node/PlanGraphPrinter.java | 43 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 13 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 66 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 8 +-
.../node/metedata/read/SchemaQueryScanNode.java | 12 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 8 +-
.../planner/plan/node/process/ExchangeNode.java | 31 +-
.../plan/node/process/HorizontallyConcatNode.java | 2 +-
.../plan/planner/plan/node/process/LimitNode.java | 10 +-
.../plan/planner/plan/node/process/OffsetNode.java | 10 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 202 -
.../planner/plan/node/sink/IdentitySinkNode.java | 99 +
.../plan/node/sink/MultiChildrenSinkNode.java | 121 +
.../planner/plan/node/sink/ShuffleSinkNode.java | 105 +
.../plan/node/source/AlignedSeriesScanNode.java | 24 +-
.../planner/plan/node/source/SeriesScanNode.java | 20 +-
.../iotdb/db/mpp/plan/statement/Statement.java | 2 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 37 +-
.../mpp/plan/statement/metadata/ShowStatement.java | 12 +-
.../plan/statement/sys/ShowQueriesStatement.java | 17 +-
.../iotdb/db/query/control/SessionManager.java | 55 +-
.../iotdb/db/rescon/TsFileResourceManager.java | 5 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 19 +-
.../service/DataNodeInternalRPCServiceMetrics.java | 2 +-
.../db/service/DataNodeServerCommandLine.java | 6 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 2 +-
.../apache/iotdb/db/service/RPCServiceMetrics.java | 2 +-
.../iotdb/db/service/RegionMigrateService.java | 2 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 4 +-
.../thrift/handler/BaseServerContextHandler.java | 4 +-
.../InternalServiceThriftHandlerMetrics.java | 6 +-
.../handler/RPCServiceThriftHandlerMetrics.java | 9 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 461 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 12 +-
.../db/trigger/executor/TriggerFireVisitor.java | 8 +-
.../trigger/service/TriggerInformationUpdater.java | 8 +-
.../file/UnsealedTsFileRecoverPerformer.java | 5 +-
.../engine/compaction/CompactionSchedulerTest.java | 2 +-
.../CompactionSchedulerWithFastPerformerTest.java | 2 +-
.../inner/InnerCompactionSchedulerTest.java | 6 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 10 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 8 +-
.../schemaRegion/SchemaStatisticsTest.java | 30 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 16 +-
...nkHandleTest.java => LocalSinkChannelTest.java} | 96 +-
.../execution/exchange/LocalSourceHandleTest.java | 1 +
.../exchange/MPPDataExchangeManagerTest.java | 65 +-
.../{SinkHandleTest.java => SinkChannelTest.java} | 270 +-
.../mpp/execution/exchange/SourceHandleTest.java | 6 +
.../{StubSinkHandle.java => StubSink.java} | 10 +-
.../operator/AlignedSeriesScanOperatorTest.java | 18 +-
.../operator/HorizontallyConcatOperatorTest.java | 3 +-
.../mpp/execution/operator/LimitOperatorTest.java | 10 +-
.../execution/operator/MergeSortOperatorTest.java | 82 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 26 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 52 +-
.../operator/RawDataAggregationOperatorTest.java | 47 +-
.../operator/SingleDeviceViewOperatorTest.java | 8 +-
.../execution/operator/TimeJoinOperatorTest.java | 3 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 299 ++
.../db/mpp/plan/optimization/TestPlanBuilder.java | 184 +
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 1 -
.../distribution/AggregationDistributionTest.java | 17 +-
.../plan/distribution/AlignedByDeviceTest.java | 1390 +++++-
.../read/DeviceSchemaScanNodeSerdeTest.java | 22 +-
.../NodeManagementMemoryMergeNodeSerdeTest.java | 24 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 44 +-
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 24 +-
.../plan/node/process/ExchangeNodeSerdeTest.java | 24 +-
...rdeTest.java => IdentitySinkNodeSerdeTest.java} | 45 +-
...st.java => ShuffleSinkHandleNodeSerdeTest.java} | 46 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 56 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 6 +-
site/pom.xml | 320 --
site/src/main/.eslintignore | 4 +
site/src/main/.eslintrc.cjs | 73 +
site/src/main/.vuepress/config.js | 3959 ++++++---------
.../theme/components/AlgoliaSearchBox.vue | 77 +-
site/src/main/.vuepress/theme/components/Page.vue | 182 +-
.../main/.vuepress/theme/components/RightMenu.vue | 136 +
site/src/main/.vuepress/theme/styles/palette.styl | 1 +
site/src/main/package.json | 16 +-
thrift-commons/src/main/thrift/common.thrift | 21 +-
.../src/main/thrift/confignode.thrift | 63 +-
thrift-mlnode/src/main/thrift/mlnode.thrift | 2 +-
thrift/src/main/thrift/datanode.thrift | 6 +-
411 files changed, 22181 insertions(+), 10473 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/datanode/UpdateDataNodePlan.java => read/model/ShowModelPlan.java} (51%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/model/ShowTrailPlan.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{datanode/UpdateDataNodePlan.java => model/CreateModelPlan.java} (55%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{datanode/UpdateDataNodePlan.java => model/DropModelPlan.java} (55%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/UpdateModelInfoPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/UpdateModelStatePlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/region/PollSpecificRegionMaintainTaskPlan.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ModelTableResp.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/TrailTableResp.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/{ConfigNodeRegionStateMachine.java => ConfigRegionStateMachine.java} (93%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/ModelManager.java
rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{ => consensus}/ConsensusManager.java (90%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/LoadManagerMetrics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/node/NodeMetrics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/partition/PartitionMetrics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/ModelInfo.java
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/metric/PartitionInfoMetrics.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/CreateModelProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/DropModelProcedure.java
rename confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/{DeleteStorageGroupProcedure.java => DeleteDatabaseProcedure.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/model/CreateModelState.java (84%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/model/DropModelState.java (80%)
rename confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/{DeleteStorageGroupProcedureTest.java => DeleteDatabaseProcedureTest.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/client/ConfigNodeClientManager.java => consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/CounterProxy.java (55%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/optimization/PlanOptimizer.java => consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/GaugeProxy.java (57%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/IoTDBMetricRegistry.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/MetricRegistryManager.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricSet.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/RefCountingMap.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/optimization/PlanOptimizer.java => consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/TimerProxy.java (59%)
create mode 100644 consensus/src/main/resources/META-INF/services/org.apache.ratis.metrics.MetricRegistries
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBTagAggregation2IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBShuffleSink1IT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/alignbydevice/IoTDBShuffleSink2IT.java
rename integration-test/src/test/java/org/apache/iotdb/db/it/groupby/{IoTDBGroupBySeriesIT.java => IoTDBGroupByConditionIT.java} (90%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/path/IoTDBFullPathIT.java
rename integration-test/src/test/java/org/apache/iotdb/db/it/{ => path}/IoTDBQuotedPathIT.java (99%)
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBQueryMemoryControlIT.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractProcessOperator.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/NodeType.java (73%)
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConfigNodeRegionId.java => ConfigRegionId.java} (87%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/model/ModelHyperparameter.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/model/ModelInformation.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/model/ModelTable.java
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/model/TrailInformation.java
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => node-commons/src/main/java/org/apache/iotdb/commons/model/exception/ModelManagementException.java (80%)
create mode 100644 pipe-api/pom.xml
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeConnector.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/PipeProcessor.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/access/Row.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/access/RowIterator.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/EventCollector.java
copy server/src/main/java/org/apache/iotdb/db/metadata/rescon/ISchemaEngineStatistics.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java (55%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeParameterValidator.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeParameters.java
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeRuntimeConfiguration.java (75%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/PipeStrategy.java (74%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/PipeConnectorRuntimeConfiguration.java
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/parallel/ParallelStrategy.java (81%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/EqualRetryIntervalStrategy.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/ExponentialRetryIntervalStrategy.java
copy consensus/src/test/java/org/apache/iotdb/consensus/ratis/UtilsTest.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/retry/RetryStrategy.java (55%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/connector/reuse/ReuseStrategy.java (82%)
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConfigNodeRegionId.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/customizer/processor/PipeProcessorRuntimeConfiguration.java (58%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/Event.java (85%)
copy server/src/main/java/org/apache/iotdb/db/metadata/rescon/ISchemaEngineStatistics.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/deletion/DeletionEvent.java (59%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/insertion/TabletInsertionEvent.java
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/event/insertion/TsFileInsertionEvent.java
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeAttributeNotProvidedException.java (74%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeException.java (76%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeParameterNotValidException.java (80%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngineMode.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeStrategyNotValidException.java (80%)
create mode 100644 pipe-api/src/main/java/org/apache/iotdb/pipe/api/type/Binary.java
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConfigNodeRegionId.java => pipe-api/src/main/java/org/apache/iotdb/pipe/api/type/Type.java (68%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/client/MLNodeClient.java
copy server/src/main/java/org/apache/iotdb/db/metadata/{schemaregion/SchemaEngineMode.java => metric/ISchemaEngineMetric.java} (83%)
copy server/src/main/java/org/apache/iotdb/db/metadata/{schemaregion/SchemaEngineMode.java => metric/ISchemaRegionMetric.java} (83%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaEngineCachedMetric.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaEngineMemMetric.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaMetricManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaRegionCachedMetric.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/metric/SchemaRegionMemMetric.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaEngineStatisticsHolder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/rescon/SchemaResourceManagerMetrics.java
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/{SchemaEngineMode.java => ISchemaRegionParams.java} (65%)
copy server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/{SchemaEngineMode.java => SchemaRegion.java} (75%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaRegionParams.java
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConfigNodeRegionId.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/DownStreamChannelIndex.java (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/DownStreamChannelLocation.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{ISinkHandle.java => sink/ISink.java} (59%)
rename node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConfigNodeRegionId.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ISinkChannel.java (68%)
rename server/src/main/java/org/apache/iotdb/db/{exception/sql/PathNumOverLimitException.java => mpp/execution/exchange/sink/ISinkHandle.java} (58%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{LocalSinkHandle.java => sink/LocalSinkChannel.java} (69%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/sink/ShuffleSinkHandle.java
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{SinkHandle.java => sink/SinkChannel.java} (83%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{ => source}/ISourceHandle.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{ => source}/LocalSourceHandle.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/{ => source}/SourceHandle.java (93%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractConsumeAllOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/sink/IdentitySinkOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/sink/ShuffleHelperOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/optimization/LimitOffsetPushDown.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/FragmentSinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/IdentitySinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/MultiChildrenSinkNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/sink/ShuffleSinkNode.java
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/{LocalSinkHandleTest.java => LocalSinkChannelTest.java} (64%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/{SinkHandleTest.java => SinkChannelTest.java} (73%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/exchange/{StubSinkHandle.java => StubSink.java} (91%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/optimization/LimitOffsetPushDownTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/optimization/TestPlanBuilder.java
copy server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/sink/{FragmentSinkNodeSerdeTest.java => IdentitySinkNodeSerdeTest.java} (54%)
rename server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/node/sink/{FragmentSinkNodeSerdeTest.java => ShuffleSinkHandleNodeSerdeTest.java} (57%)
create mode 100644 site/src/main/.eslintignore
create mode 100644 site/src/main/.eslintrc.cjs
create mode 100644 site/src/main/.vuepress/theme/components/RightMenu.vue
create mode 100644 site/src/main/.vuepress/theme/styles/palette.styl
[iotdb] 01/01: fix mistake in DiskMetrics tags
Posted by ma...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a commit to branch IOTDB-5517
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 20445866f42ad4f92c4c28071466573f9aed2c17
Author: Liu Xuxin <li...@outlook.com>
AuthorDate: Wed Mar 1 10:11:31 2023 +0800
fix mistake in DiskMetrics tags
---
.../java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java b/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java
index 00d550be49..92552914dd 100644
--- a/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java
+++ b/metrics/interface/src/main/java/org/apache/iotdb/metrics/metricsets/disk/DiskMetrics.java
@@ -106,7 +106,7 @@ public class DiskMetrics implements IMetricSet {
diskMetricsManager,
x -> x.getMergedReadOperationForDisk().getOrDefault(diskID, 0L),
TYPE,
- MERGED_WRITE,
+ MERGED_READ,
NAME,
diskID);
metricService.createAutoGauge(
@@ -115,7 +115,7 @@ public class DiskMetrics implements IMetricSet {
diskMetricsManager,
x -> x.getMergedWriteOperationForDisk().getOrDefault(diskID, 0L),
TYPE,
- MERGED_READ,
+ MERGED_WRITE,
NAME,
diskID);
metricService.createAutoGauge(