This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/MLSQL
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 71fb614bb1 fix bug & finish
add afa24f2f4a Python client should throw exception when meets error
(#9301)
add 33ad44f5d7 [IOTDB-5660] Update deprecated storage group name (#9285)
add 57c47f9d19 [IOTDB-5657] Fix LIMIT&OFFSET does not take effect in last
query (#9309)
add 5fe8f285cf [IOTDB-5612] [doc] Remove some functions which are not
built-in from doc (#9313)
add b15630b48b [IOTDB-5663] Add connection num metrics (#9307)
add 7158cadfe6 [hotfix][REST Service] Fix the display error of the swagger
page (#9303)
add 4e8dc909fd change log in ShuffleSinkHandle (#9314)
add 1ebbd19168 [IOTDB-5519] Improve the concurrency control of
DatabaseSchema (#9306)
add 2b48e40706 [IOTDB-5643] Add REPLACE as a built-in scalar function
add 6d33b748dd [UserGuide]Update markdown table style (#9319)
add 0a53a0399d [IOTDB-5668] fix loading the tsfile which is from
export-tsfile failed when the specified encoding type is different from default
add 9539c76e1d allow submitting tasks when queue is full (#9304)
add 9508efe3c7 Update github action site-build commit information (#9330)
add aba7f06e53 remove useless log (#9329)
add 31b79973f9 fix(website): fix editlink error (#9333)
add 6b2aab0fc7 added Workbench-doc to IoTDB website and modified an
article of community (#9308)
add 78b2b279f5 [IOTDB-5674] Multi-Mode IMNode Management (#9243)
add 9ee40a1226 [IOTDB-5676] Improve ConfigurationException description and
analyzing of cluster parameters (#9334)
add 687da0ec0d [IOTDB-4439] Support GROUP BY COUNT in aggregation query
add 92549f8f30 [IOTDB-5616] Fix some code smells (#9320)
add 279b775b85 [CLIENT-PY] Optimize array concatenation performance in
`todf()` (#9001)
add d14f37af86 [IOTDB-5682] Fix the update of nodeId in Metrics (#9344)
add 81b365b9ce [IOTDB-5651] Fix compaction UT
add 53d06b296b [IoTDB-5636] Add round as built-in scalar function
add 637cd48803 [IOTDB-5683] Support aggregation function Mode for query
add 8c4f80046b [IOTDB-5671] Fix inode cannot be released after deletion
causing waste of disk space
add b54a3ef136 [IOTDB-5684] Standardize log folder of ConfigNode's Simple
consensus protocol
add eae04ab624 Fix dispatch result collection logic (#9323) (#9347)
add b167e06d85 fix erros of Community doc (#9355)
add 387404d1e3 [IOTDB-5618] Add RatisConsensus metrics in dashboard (#9212)
add 94178d766e Seperate IO Dashboard apart (#9357)
add be23689cce [IOTDB-5681] Fix the creation of system database used by
IoTDB Internal Reporter (#9339)
add e03f6f9a76 fix the video of Community doc (#9362)
add 1660de2635 feat(site): change pc width to 1280px (#9361)
add ad47b919f1 [IOTDB-5695] Ensures backward compatibility between 1.0 and
1.1 for ConfigNode when using SimpleConsensus
add 48fc278c89 Bump webpack from 5.75.0 to 5.76.1 in /grafana-plugin
(#9331)
add d28f667dc9 [IOTDB-5368] add port check for confignode and datanode
(#9270)
add d0e2b3f108 [IOTDB-5690] PipePlugin: CreatePipePluginProcedure &
DropPipePluginProcedure (#9363)
add adb16f8a5a [hotfix] Fix a SQL in Aggregation.md (#9228)
add 2abf541e5e [doc](readme)Enhancement in links (#9368)
add 77e57f0e38 [IOTDB-5697] Only record engine cost for DataRegion in
Performance Overview Dashboard (#9366)
add 487dd31417 [IOTDB-5689] Close Isink when ISourceHandle is closed
add ad8940cbef [IOTDB-5692] Pipe: DataNode skeleton code framework (#9373)
add 524cac789e [IOTDB-5700] Clean temporary files created by UDF query
after it finishes (#9376)
add 806fc7c156 fix show queries after introduce Shuffle
add dc016d8368 Fix possible npe when closing IdentitySinkOperator
add ca307b14ce [IOTDB-5685] Fix error msg of failing to create a
timeseries on an existing path when ReadOnly state (#9382)
add 94ac27b57f [IOTDB-5675] Metric of Schema Template (#9390)
add e646d3d87e [IOTDB-5705] Replace data_region_per_processor by
data_region_per_data_node (#9386)
add 8441842899 [IOTDB-5686] Fix devices with the same name but different
alignment properties meets error in inner seq compaction
add 2d843366e8 [IOTDB-5701] Optimize the management of performance
overview related metrics (#9381)
add dc6c722dc1 [IOTDB-5707] Support Activate Template for Session API
(#9392)
add 19f46a8f2e Fix compilation (#9401)
add f741a6e9c3 Ignore flaky test testMemoryStatistics (#9402)
add 7fba344e2b [IOTDB-5711] Support connecting multiple nodes in Python
API (#9400)
add 9bfa61b427 Remove redundent template example in Python example (#9404)
add b03e385c5e Update NodeName-In-Path.md (#9379)
add 64986085e3 Correct CQ example in docs (#9408)
add b938a67c7d Revert "[IOTDB-5586] Reduce the scope of lock in MemoryPool"
add ff283c8f49 disable multi value selection for disk dashboard (#9415)
add 659fa27eaa Update IoTDBDescriptor.java (#9420)
add 788c58dd7b [IOTDB-5715] Improve the performance of query order by time
desc
add 1b9c9eff30 [IOTDB-5716] Wrong dependency when pipeline
consumeOneByOneOperator
add 09c7fa77c4 remove aligned time series id in nonAligned measurement
iterator (#9410)
add 6ed01068d0 [IOTDB-5718] Fix wrong time order due to overflow in
MergeSort
add 244f7feb37 Merge remote-tracking branch 'origin/master' into lmh/MLSQL
add abf5d82de6 merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/site-build.yml | 2 +-
README.md | 4 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 10 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../java/org/apache/iotdb/tool/ExportTsFile.java | 10 +
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 12 +-
client-py/SessionExample.py | 76 +-
client-py/iotdb/Session.py | 1069 ++-
client-py/iotdb/utils/IoTDBRpcDataSet.py | 37 +-
client-py/iotdb/utils/NumpyTablet.py | 4 +-
client-py/tests/tablet_performance_comparison.py | 4 +-
client-py/tests/test_aligned_timeseries.py | 20 +-
client-py/tests/test_dataframe.py | 6 +-
client-py/tests/test_delete_data.py | 8 +-
client-py/tests/test_numpy_tablet.py | 7 +-
client-py/tests/test_session.py | 12 +-
client-py/tests/test_template.py | 12 +-
.../client/async/AsyncDataNodeClientPool.java | 14 +
.../client/sync/SyncConfigNodeClientPool.java | 2 +
.../client/sync/SyncDataNodeClientPool.java | 4 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 10 +-
.../confignode/conf/ConfigNodeDescriptor.java | 6 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 98 +-
.../confignode/conf/SystemPropertiesUtils.java | 32 +-
.../consensus/request/ConfigPhysicalPlan.java | 32 +-
.../request/read/database/CountDatabasePlan.java | 2 +-
.../read/partition/GetSeriesSlotListPlan.java | 2 +-
.../read/partition/GetTimeSlotListPlan.java | 2 +-
.../request/read/region/GetRegionIdPlan.java | 2 +-
.../AdjustMaxRegionGroupNumPlan.java | 11 +-
.../DatabaseSchemaPlan.java | 6 +-
.../DeleteDatabasePlan.java | 2 +-
.../PreDeleteDatabasePlan.java | 2 +-
.../SetDataReplicationFactorPlan.java | 30 +-
.../SetSchemaReplicationFactorPlan.java | 29 +-
.../{storagegroup => database}/SetTTLPlan.java | 33 +-
.../SetTimePartitionIntervalPlan.java | 13 +-
.../write/pipe/plugin/CreatePipePluginPlan.java | 4 +
.../statemachine/ConfigRegionStateMachine.java | 9 +-
.../confignode/manager/ClusterSchemaManager.java | 215 +-
.../iotdb/confignode/manager/ConfigManager.java | 103 +-
.../apache/iotdb/confignode/manager/IManager.java | 26 +-
.../iotdb/confignode/manager/ProcedureManager.java | 48 +-
.../manager/consensus/ConsensusManager.java | 63 +-
.../iotdb/confignode/manager/node/NodeManager.java | 9 +
.../manager/partition/PartitionManager.java | 75 +-
.../manager/pipe/PipePluginCoordinator.java | 120 +-
.../persistence/executor/ConfigPlanExecutor.java | 18 +-
.../partition/DatabasePartitionTable.java | 15 +-
.../persistence/partition/PartitionInfo.java | 110 +-
.../persistence/schema/ClusterSchemaInfo.java | 191 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 48 +-
.../procedure/env/DataNodeRemoveHandler.java | 3 +
.../pipe/plugin/CreatePipePluginProcedure.java | 306 +
.../impl/pipe/plugin/DropPipePluginProcedure.java | 251 +
.../impl/schema/DeleteDatabaseProcedure.java | 90 +-
.../state/pipe/plugin/CreatePipePluginState.java | 13 +-
.../state/pipe/plugin/DropPipePluginState.java | 13 +-
.../state/schema/DeleteStorageGroupState.java | 5 +-
.../procedure/store/ProcedureFactory.java | 12 +
.../confignode/procedure/store/ProcedureType.java | 6 +-
.../iotdb/confignode/service/ConfigNode.java | 19 +-
.../confignode/service/ConfigNodeCommandLine.java | 7 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 30 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 18 +-
.../persistence/ClusterSchemaInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 2 +-
.../impl/pipe/CreatePipePluginProcedureTest.java | 60 +
.../impl/pipe/DropPipePluginProcedureTest.java | 53 +
.../confignode1conf/iotdb-common.properties | 1 +
.../confignode2conf/iotdb-common.properties | 1 +
.../confignode3conf/iotdb-common.properties | 1 +
.../iotdb/consensus/config/ConsensusConfig.java | 15 -
.../consensus/iot/IoTConsensusServerImpl.java | 11 +-
.../ratis/ApplicationStateMachineProxy.java | 37 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 31 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 15 +
.../ratis/metrics/IoTDBMetricRegistry.java | 65 +-
.../ratis/metrics/MetricRegistryManager.java | 13 +-
.../consensus/ratis/metrics/RatisMetricSet.java | 79 +-
.../ratis/metrics/RatisMetricsManager.java | 89 +
.../iotdb/consensus/simple/SimpleConsensus.java | 26 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 2 -
.../apache/iotdb/consensus/iot/StabilityTest.java | 2 -
.../iotdb/consensus/ratis/RatisConsensusTest.java | 2 -
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 11 +-
.../iotdb/consensus/simple/RecoveryTest.java | 2 -
docs/Community/Materials.md | 285 +-
.../UserGuide/API/Programming-Python-Native-API.md | 34 +-
.../Administration-Management/Administration.md | 2 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 2 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 4184 +++++----
.../Apache-IoTDB-DataNode-Dashboard.json | 6615 +++++++------
.../Apache-IoTDB-Disk-IO-Dashboard.json | 894 ++
.../Apache-IoTDB-Network-Dashboard.json | 93 +-
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 99 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 32 +-
docs/UserGuide/Operators-Functions/Mathematical.md | 65 +-
docs/UserGuide/Operators-Functions/String.md | 8 +-
docs/UserGuide/Query-Data/Group-By.md | 67 +
docs/UserGuide/Query-Data/Overview.md | 11 +-
.../Syntax-Conventions/NodeName-In-Path.md | 2 +-
.../UserGuide/API/Programming-Python-Native-API.md | 36 +-
.../Administration-Management/Administration.md | 2 +-
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 2 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 4 +-
.../UserGuide/Ecosystem-Integration/Workbench.md | 420 +
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 79 +-
.../UserGuide/Operators-Functions/Aggregation.md | 2 +-
.../UserGuide/Operators-Functions/Mathematical.md | 63 +-
docs/zh/UserGuide/Operators-Functions/Overview.md | 50 +-
docs/zh/UserGuide/Operators-Functions/String.md | 8 +-
docs/zh/UserGuide/Query-Data/Group-By.md | 66 +
docs/zh/UserGuide/Query-Data/Overview.md | 9 +-
grafana-plugin/yarn.lock | 6 +-
.../itbase/constant/BuiltinScalarFunctionEnum.java | 2 +
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 -
.../apache/iotdb/itbase/constant/TestConstant.java | 4 +
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 47 +
.../it/cluster/IoTDBClusterNodeGetterIT.java | 4 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 2 +-
.../iotdb/db/it/aggregation/IoTDBModeIT.java | 160 +
.../IoTDBOrderByWithAlignByDeviceIT.java | 54 +
.../scalar/IoTDBReplaceFunctionIT.java | 171 +
.../scalar/IoTDBRoundFunctionIT.java | 327 +
.../iotdb/db/it/groupby/IoTDBGroupByCountIT.java | 407 +
.../it/last/IoTDBLastQueryWithLimitOffsetIT.java | 193 +
.../iotdb/db/it/schema/AbstractSchemaIT.java | 2 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 2 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 2 +-
.../iotdb/libudf/it/dprofile/DProfileIT.java | 3 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 61 +
.../java/org/apache/iotdb/isession/ISession.java | 3 +
.../apache/iotdb/isession/pool/ISessionPool.java | 3 +
library-udf/src/assembly/tools/register-UDF.bat | 1 -
library-udf/src/assembly/tools/register-UDF.sh | 1 -
.../apache/iotdb/library/dprofile/UDAFMode.java | 178 -
.../apache/iotdb/metrics/config/MetricConfig.java | 7 +-
.../iotdb/metrics/metricsets/disk/DiskMetrics.java | 30 +-
.../metrics/metricsets/net/INetMetricManager.java | 4 +
.../metricsets/net/LinuxNetMetricManager.java | 37 +
.../iotdb/metrics/metricsets/net/NetMetrics.java | 16 +
.../micrometer/type/MicrometerAutoGauge.java | 2 -
.../resources/conf/iotdb-common.properties | 25 +-
.../commons/exception/ConfigurationException.java | 27 +-
.../service/PipePluginClassLoaderManager.java | 2 +-
.../task/meta/PipeTaskMetaAccessor.java} | 10 +-
.../apache/iotdb/commons/schema/node}/IMNode.java | 68 +-
.../iotdb/commons/schema/node}/MNodeType.java | 2 +-
.../node/common/AbstractAboveDatabaseMNode.java | 191 +
.../node/common/AbstractDatabaseDeviceMNode.java | 290 +
.../schema/node/common/AbstractDatabaseMNode.java | 215 +
.../schema/node/common/AbstractDeviceMNode.java | 280 +
.../node/common/AbstractMeasurementMNode.java | 256 +
.../schema/node/info/IDatabaseDeviceInfo.java | 9 +-
.../commons/schema/node/info/IDatabaseInfo.java | 21 +-
.../commons/schema/node/info/IDeviceInfo.java | 31 +-
.../commons/schema/node/info/IMeasurementInfo.java | 20 +-
.../commons/schema/node/role/IDatabaseMNode.java | 12 +-
.../commons/schema/node/role/IDeviceMNode.java | 22 +-
.../schema/node/role}/IMeasurementMNode.java | 16 +-
.../schema/node/utils}/IMNodeContainer.java | 6 +-
.../commons/schema/node/utils/IMNodeFactory.java | 34 +-
.../commons/schema/node/utils}/IMNodeIterator.java | 6 +-
.../commons/schema/node/visitor/MNodeVisitor.java | 42 +
.../iotdb/commons/service/StartupChecks.java | 33 +-
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../metric/enums/PerformanceOverviewMetrics.java | 256 +-
.../udf/builtin/BuiltinAggregationFunction.java | 5 +-
.../commons/udf/builtin/BuiltinScalarFunction.java | 6 +
.../BuiltinTimeSeriesGeneratingFunction.java | 1 -
.../commons/udf/service/UDFManagementService.java | 2 +-
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 8 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 4 +-
pom.xml | 3 +-
.../rocksdb/RSchemaReadWriteHandler.java | 4 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 10 +-
.../schemaregion/rocksdb/RSchemaUtils.java | 10 +-
...RStorageGroupMNode.java => RDatabaseMNode.java} | 45 +-
.../mnode/{REntityMNode.java => RDeviceMNode.java} | 55 +-
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 30 +-
.../schemaregion/rocksdb/mnode/RMNode.java | 101 +-
.../rocksdb/mnode/RMeasurementMNode.java | 47 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 6 +-
server/src/main/codegen/dataModel/AllDataType.tdd | 24 +-
.../src/main/codegen/templates/ModeAccumulator.ftl | 179 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 7 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 16 +
.../apache/iotdb/db/conf/DataNodeStartupCheck.java | 69 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 34 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 65 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 5 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 -
.../db/consensus/SchemaRegionConsensusImpl.java | 2 -
.../statemachine/DataRegionStateMachine.java | 3 +-
.../org/apache/iotdb/db/constant/SqlConstant.java | 8 +-
.../execute/task/CrossSpaceCompactionTask.java | 7 +-
.../execute/task/InnerSpaceCompactionTask.java | 264 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 7 +
.../readchunk/AlignedSeriesCompactionExecutor.java | 3 +-
.../compaction/schedule/CompactionScheduler.java | 100 +-
.../compaction/schedule/CompactionTaskManager.java | 3 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 5 +-
.../impl/SizeTieredCompactionSelector.java | 27 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 3 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 16 +-
.../db/engine/storagegroup/TsFileProcessor.java | 25 +-
.../idtable/entry/InsertMeasurementMNode.java | 287 -
.../db/metadata/metric/SchemaEngineMemMetric.java | 16 +-
.../db/metadata/metric/SchemaRegionMemMetric.java | 34 +
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 200 -
.../apache/iotdb/db/metadata/mnode/MNodeUtils.java | 77 -
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 233 -
.../db/metadata/mnode/StorageGroupEntityMNode.java | 90 -
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 102 -
.../IConfigMNode.java} | 26 +-
.../mnode/config/basic/ConfigBasicMNode.java | 279 +
.../container/ConfigMNodeContainer.java} | 45 +-
.../mnode/config/factory/ConfigMNodeFactory.java | 81 +
.../impl/ConfigBasicInternalMNode.java} | 134 +-
.../mnode/config/impl/ConfigDatabaseMNode.java | 80 +
.../mnode/config/info/ConfigDatabaseInfo.java | 70 +
.../mnode/config/info/ConfigMNodeInfo.java | 82 +
.../mnode/container/MNodeContainerMapImpl.java | 26 -
.../mnode/estimator/BasicMNodSizeEstimator.java | 114 -
.../iotdb/db/metadata/mnode/mem/IMemMNode.java | 11 +-
.../db/metadata/mnode/mem/basic/BasicMNode.java | 252 +
.../container/MemMNodeContainer.java} | 44 +-
.../mnode/mem/estimator/MNodeSizeEstimator.java | 10 +-
.../mnode/mem/factory/MemMNodeFactory.java | 84 +
.../impl/AboveDatabaseMNode.java} | 33 +-
.../impl/BasicInternalMNode.java} | 134 +-
.../mnode/mem/impl/DatabaseDeviceMNode.java} | 20 +-
.../impl/DatabaseMNode.java} | 35 +-
.../impl/DeviceMNode.java} | 32 +-
.../metadata/mnode/mem/impl/MeasurementMNode.java | 49 +
.../db/metadata/mnode/mem/info/BasicMNodeInfo.java | 25 +-
.../mnode/mem/info/DatabaseDeviceInfo.java | 59 +
.../info/DatabaseInfo.java} | 38 +-
.../{EntityMNode.java => mem/info/DeviceInfo.java} | 131 +-
.../metadata/mnode/mem/info/MeasurementInfo.java | 113 +
.../iterator/AbstractTraverserIterator.java | 35 +-
.../mnode/{ => mem}/iterator/MNodeIterator.java | 13 +-
.../iterator/MemoryTraverserIterator.java | 16 +-
.../mnode/schemafile/ICachedMNode.java} | 13 +-
.../mnode/schemafile/basic/CachedBasicMNode.java | 264 +
.../container}/CachedMNodeContainer.java | 166 +-
.../container}/ICachedMNodeContainer.java | 35 +-
.../schemafile/factory/CacheMNodeFactory.java | 84 +
.../impl/CachedAboveDatabaseMNode.java} | 31 +-
.../impl/CachedBasicInternalMNode.java} | 140 +-
.../schemafile/impl/CachedDatabaseDeviceMNode.java | 49 +
.../mnode/schemafile/impl/CachedDatabaseMNode.java | 54 +
.../mnode/schemafile/impl/CachedDeviceMNode.java | 48 +
.../schemafile/impl/CachedMeasurementMNode.java | 60 +
.../info/CacheMNodeInfo.java} | 31 +-
.../iterator/CachedTraverserIterator.java | 18 +-
.../iotdb/db/metadata/mnode/utils/MNodeUtils.java | 123 +
.../db/metadata/mnode/visitor/MNodeVisitor.java | 39 -
.../iotdb/db/metadata/mtree/ConfigMTree.java | 279 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 195 -
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 435 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 391 +-
.../mtree/snapshot/MemMTreeSnapshotUtil.java | 154 +-
.../db/metadata/mtree/store/CachedMTreeStore.java | 169 +-
.../db/metadata/mtree/store/ConfigMTreeStore.java | 143 +
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 44 +-
.../db/metadata/mtree/store/MemMTreeStore.java | 151 +-
.../store/ReentrantReadOnlyCachedMTreeStore.java | 44 +-
.../mtree/store/disk/cache/CacheManager.java | 139 +-
.../mtree/store/disk/cache/ICacheManager.java | 28 +-
.../mtree/store/disk/cache/LRUCacheManager.java | 24 +-
.../mtree/store/disk/cache/PlainCacheManager.java | 10 +-
.../disk/memcontrol/CachedMNodeSizeEstimator.java | 72 -
.../mtree/store/disk/memcontrol/MemManager.java | 26 +-
.../mtree/store/disk/schemafile/ISchemaFile.java | 17 +-
.../store/disk/schemafile/ISegmentedPage.java | 8 +-
.../store/disk/schemafile/MockSchemaFile.java | 128 +-
.../mtree/store/disk/schemafile/RecordUtils.java | 84 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 57 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 41 +-
.../store/disk/schemafile/WrappedSegment.java | 20 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 30 +-
.../disk/schemafile/pagemgr/IPageManager.java | 13 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 34 +-
.../db/metadata/mtree/traverser/Traverser.java | 52 +-
.../traverser/TraverserWithLimitOffsetWrapper.java | 18 +-
.../mtree/traverser/basic/DatabaseTraverser.java | 22 +-
.../mtree/traverser/basic/EntityTraverser.java | 19 +-
.../mtree/traverser/basic/MNodeTraverser.java | 21 +-
.../traverser/basic/MeasurementTraverser.java | 14 +-
.../traverser/collector/DatabaseCollector.java | 14 +-
.../mtree/traverser/collector/EntityCollector.java | 14 +-
...SGCollector.java => MNodeAboveDBCollector.java} | 26 +-
.../mtree/traverser/collector/MNodeCollector.java | 10 +-
.../traverser/collector/MeasurementCollector.java | 22 +-
.../mtree/traverser/counter/DatabaseCounter.java | 10 +-
.../mtree/traverser/counter/EntityCounter.java | 9 +-
.../traverser/counter/MeasurementCounter.java | 9 +-
.../mtree/traverser/updater/EntityUpdater.java | 15 +-
.../traverser/updater/MeasurementUpdater.java | 13 +-
.../plan/schemaregion/result/ShowNodesResult.java | 2 +-
.../db/metadata/query/info/INodeSchemaInfo.java | 2 +-
.../metadata/rescon/ISchemaEngineStatistics.java | 2 +
.../metadata/rescon/ISchemaRegionStatistics.java | 4 +
.../metadata/rescon/MemSchemaEngineStatistics.java | 26 +-
.../metadata/rescon/MemSchemaRegionStatistics.java | 36 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 57 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 107 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 55 +-
.../metadata/template/ClusterTemplateManager.java | 7 +
.../iotdb/db/metadata/template/Template.java | 4 +
.../metadata/template/TemplateMNodeGenerator.java | 51 -
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 9 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 2 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 20 +
.../db/mpp/aggregation/AccumulatorFactory.java | 21 +
.../SlidingWindowAggregatorFactory.java | 2 +
.../db/mpp/common/header/ColumnHeaderConstant.java | 2 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 13 +-
.../execution/exchange/MPPDataExchangeManager.java | 67 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 6 +-
.../db/mpp/execution/exchange/sink/ISink.java | 4 +
.../mpp/execution/exchange/sink/ISinkHandle.java | 3 +
.../execution/exchange/sink/LocalSinkChannel.java | 7 +
.../execution/exchange/sink/ShuffleSinkHandle.java | 44 +-
.../mpp/execution/exchange/sink/SinkChannel.java | 11 +-
.../execution/exchange/source/SourceHandle.java | 59 +-
.../execution/executor/RegionWriteExecutor.java | 207 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 237 +-
.../iotdb/db/mpp/execution/operator/Operator.java | 10 +-
.../process/AbstractConsumeAllOperator.java | 4 +-
.../operator/process/AbstractIntoOperator.java | 7 +-
.../operator/process/AggregationOperator.java | 6 +-
.../operator/process/DeviceMergeOperator.java | 6 +-
.../operator/process/DeviceViewOperator.java | 17 +-
.../execution/operator/process/FillOperator.java | 6 +-
.../operator/process/FilterAndProjectOperator.java | 6 +-
.../execution/operator/process/LimitOperator.java | 6 +-
.../operator/process/LinearFillOperator.java | 8 +-
.../operator/process/MergeSortOperator.java | 8 +-
.../execution/operator/process/OffsetOperator.java | 6 +-
.../process/RawDataAggregationOperator.java | 9 +-
.../operator/process/SingleDeviceViewOperator.java | 6 +-
.../process/SingleInputAggregationOperator.java | 6 +-
.../process/SlidingWindowAggregationOperator.java | 4 +-
.../execution/operator/process/SortOperator.java | 6 +-
.../operator/process/TagAggregationOperator.java | 8 +-
.../operator/process/TransformOperator.java | 16 +-
.../process/join/HorizontallyConcatOperator.java | 8 +-
.../process/join/RowBasedTimeJoinOperator.java | 13 +-
.../operator/process/join/TimeJoinOperator.java | 9 +-
.../process/join/merge/AscTimeComparator.java | 5 +
.../process/join/merge/DescTimeComparator.java | 5 +
.../process/join/merge/MergeSortComparator.java | 28 +-
.../process/join/merge/TimeComparator.java | 3 +
.../last/AbstractUpdateLastCacheOperator.java | 4 +-
.../last/AlignedUpdateLastCacheOperator.java | 2 +-
.../process/last/LastQueryCollectOperator.java | 6 +-
.../process/last/LastQueryMergeOperator.java | 12 +-
.../operator/process/last/LastQueryOperator.java | 7 +-
.../process/last/LastQuerySortOperator.java | 7 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../schema/CountGroupByLevelMergeOperator.java | 6 +-
.../schema/CountGroupByLevelScanOperator.java | 6 +-
.../operator/schema/CountMergeOperator.java | 7 +-
.../schema/NodeManageMemoryMergeOperator.java | 8 +-
.../operator/schema/NodePathsConvertOperator.java | 6 +-
.../operator/schema/NodePathsCountOperator.java | 6 +-
.../operator/schema/SchemaCountOperator.java | 6 +-
.../operator/schema/SchemaFetchMergeOperator.java | 6 +-
.../operator/schema/SchemaFetchScanOperator.java | 6 +-
.../operator/schema/SchemaQueryMergeOperator.java | 6 +-
.../schema/SchemaQueryOrderByHeatOperator.java | 6 +-
.../operator/schema/SchemaQueryScanOperator.java | 6 +-
.../operator/sink/IdentitySinkOperator.java | 35 +-
.../operator/sink/ShuffleHelperOperator.java | 39 +-
.../AbstractSeriesAggregationScanOperator.java | 6 +-
.../operator/source/AlignedSeriesScanOperator.java | 6 +-
.../operator/source/ExchangeOperator.java | 6 +-
.../operator/source/LastCacheScanOperator.java | 6 +-
.../operator/source/SeriesScanOperator.java | 6 +-
.../operator/source/ShowQueriesOperator.java | 6 +-
.../operator/window/AbstractVariationWindow.java | 6 -
.../execution/operator/window/ConditionWindow.java | 6 -
...stractVariationWindow.java => CountWindow.java} | 80 +-
.../operator/window/CountWindowManager.java | 141 +
.../{WindowType.java => CountWindowParameter.java} | 33 +-
.../db/mpp/execution/operator/window/IWindow.java | 19 +-
.../execution/operator/window/SessionWindow.java | 6 -
.../mpp/execution/operator/window/TimeWindow.java | 8 -
.../operator/window/WindowManagerFactory.java | 2 +
.../mpp/execution/operator/window/WindowType.java | 3 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 2 +-
.../metric/PerformanceOverviewMetricsManager.java | 214 -
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 12 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 73 +-
.../db/mpp/plan/execution/QueryExecution.java | 11 +-
.../plan/execution/config/ConfigTaskVisitor.java | 22 +-
.../config/executor/ClusterConfigTaskExecutor.java | 85 +-
.../config/executor/IConfigTaskExecutor.java | 15 +-
...torageGroupTask.java => CountDatabaseTask.java} | 12 +-
.../config/metadata/DatabaseSchemaTask.java | 23 +-
.../config/metadata/DeleteStorageGroupTask.java | 10 +-
...StorageGroupTask.java => ShowDatabaseTask.java} | 12 +-
.../config/metadata/ShowVariablesTask.java | 4 +-
.../memory/StatementMemorySourceVisitor.java | 2 +-
.../plan/expression/multi/FunctionExpression.java | 61 +-
.../multi/builtin/BuiltInScalarFunctionHelper.java | 23 +-
.../BuiltInScalarFunctionHelperFactory.java | 14 +-
.../{CastHelper.java => CastFunctionHelper.java} | 20 +-
.../{DiffHelper.java => DiffFunctionHelper.java} | 11 +-
...{DiffHelper.java => ReplaceFunctionHelper.java} | 56 +-
.../{DiffHelper.java => RoundFunctionHelper.java} | 31 +-
.../mpp/plan/optimization/LimitOffsetPushDown.java | 3 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 91 +-
.../db/mpp/plan/parser/StatementGenerator.java | 96 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 18 +
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 20 +-
.../planner/distribution/DistributionPlanner.java | 21 +
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../node/metedata/write/ActivateTemplateNode.java | 2 +-
.../metedata/write/BatchActivateTemplateNode.java | 166 +
.../metedata/write/CreateMultiTimeSeriesNode.java | 6 +-
.../plan/node/metedata/write/MeasurementGroup.java | 36 +-
.../plan/parameter/GroupByCountParameter.java | 85 +
.../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 34 +
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 8 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 38 +-
.../iotdb/db/mpp/plan/statement/StatementType.java | 2 +
.../db/mpp/plan/statement/StatementVisitor.java | 26 +-
.../component/GroupByCountComponent.java} | 25 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 9 +-
...pStatement.java => CountDatabaseStatement.java} | 4 +-
.../metadata/DatabaseSchemaStatement.java | 16 +-
...Statement.java => DeleteDatabaseStatement.java} | 6 +-
.../plan/statement/metadata/SetTTLStatement.java | 14 +-
...upStatement.java => ShowDatabaseStatement.java} | 4 +-
...nt.java => BatchActivateTemplateStatement.java} | 33 +-
.../template/DropSchemaTemplateStatement.java | 13 +-
.../db/mpp/transformation/api/YieldableReader.java | 6 +-
.../scalar/CastFunctionColumnTransformer.java | 20 +-
.../scalar/ReplaceFunctionColumnTransformer.java | 57 +
.../scalar/RoundFunctionColumnTransformer.java | 72 +
.../transformation/dag/input/IUDFInputDataSet.java | 2 +-
.../dag/input/QueryDataSetInputLayer.java | 4 +-
.../dag/input/TsBlockInputDataSet.java | 2 +-
.../MultiInputColumnIntermediateLayer.java | 10 +-
...InputColumnMultiReferenceIntermediateLayer.java | 12 +-
...nputColumnSingleReferenceIntermediateLayer.java | 10 +-
.../dag/transformer/Transformer.java | 4 +-
.../dag/transformer/binary/BinaryTransformer.java | 4 +-
.../transformer/binary/LogicBinaryTransformer.java | 2 +-
.../multi/MappableUDFQueryRowTransformer.java | 2 +-
.../transformer/multi/UDFQueryRowTransformer.java | 2 +-
.../multi/UDFQueryRowWindowTransformer.java | 2 +-
.../multi/UniversalUDFQueryTransformer.java | 4 +-
.../transformer/ternary/TernaryTransformer.java | 4 +-
.../dag/transformer/unary/IsNullTransformer.java | 2 +-
.../dag/transformer/unary/UnaryTransformer.java | 2 +-
.../unary/scalar/CastFunctionTransformer.java | 20 +-
.../unary/scalar/DiffFunctionTransformer.java | 2 +-
.../ReplaceFunctionTransformer.java} | 44 +-
.../unary/scalar/RoundFunctionTransformer.java | 72 +
.../db/mpp/transformation/dag/udf/UDTFContext.java | 3 +
.../transformation/dag/util/LayerCacheUtils.java | 10 +-
.../org/apache/iotdb/db/pipe/agent/PipeAgent.java | 74 +
.../pipe/agent/{ => plugin}/PipePluginAgent.java | 29 +-
.../db/pipe/agent/runtime/HeartbeatScheduler.java | 11 +-
.../db/pipe/agent/runtime/MetaSyncScheduler.java | 10 +-
.../agent/runtime/PipeRuntimeAgent.java} | 22 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 22 +-
.../db/pipe/agent/task/PipeTaskRegionAgent.java | 10 +-
.../collector/PipeCollectorEventPendingQueue.java | 10 +-
.../core/collector/PipeCollectorEventSelector.java | 10 +-
.../historical/PipeHistoricalCollector.java | 10 +-
.../collector/realtime/PipeRealtimeCollector.java | 10 +-
.../realtime/cache/PipeRealtimeEventCache.java | 10 +-
.../realtime/listener/IoTLogListerner.java | 10 +-
.../realtime/listener/RatisLogListener.java | 10 +-
.../realtime/listener/SimpleLogListener.java | 10 +-
.../listener/TsFileGenerationListener.java | 10 +-
.../pipe/core/collector/realtime/matcher/Rule.java | 10 +-
.../realtime/matcher/RulePrefixMatchTree.java | 10 +-
.../collector/realtime/recorder/TsFileEpoch.java | 10 +-
.../realtime/recorder/TsFileEpochRecorder.java | 10 +-
.../core/connector/PipeConnectorContainer.java | 10 +-
.../pipe/core/connector/PipeConnectorManager.java | 10 +-
.../PipeConnectorPluginRuntimeWrapper.java} | 15 +-
.../core/event/PipeTabletInsertionEvent.java} | 28 +-
.../pipe/core/event/PipeTsFileInsertionEvent.java} | 21 +-
.../iotdb/db/pipe/core/event/access/PipeRow.java | 102 +
.../core/event/access/PipeRowIterator.java} | 38 +-
.../core/event/collector/PipeEventCollector.java} | 31 +-
.../core/event/collector/PipeRowCollector.java} | 15 +-
.../pipe/core/event/indexer/PipeEventIndexer.java | 10 +-
.../core/event/indexer/PipeIoTEventIndexer.java | 10 +-
.../core/event/indexer/PipeRatisEventIndexer.java | 10 +-
.../core/event/indexer/PipeSimpleEventIndexer.java | 10 +-
.../core/event/indexer/PipeTsFileEventIndexer.java | 10 +-
.../PipeProcessorPluginRuntimeWrapper.java | 13 +-
.../executor/PipeAssignerSubtaskExecutor.java | 10 +-
.../executor/PipeConnectorSubtaskExecutor.java | 10 +-
.../executor/PipeProcessorSubtaskExecutor.java | 10 +-
.../execution/executor/PipeSubtaskExecutor.java | 10 +-
.../pipe/execution/executor/PipeTaskExecutor.java | 49 +
.../scheduler/PipeAssignerSubtaskScheduler.java} | 21 +-
.../scheduler/PipeConnectorSubtaskScheduler.java} | 21 +-
.../scheduler/PipeProcessorSubtaskScheduler.java} | 21 +-
.../execution/scheduler/PipeSubtaskScheduler.java | 21 +-
.../execution/scheduler/PipeTaskScheduler.java | 60 +
.../iotdb/db/pipe/resource/PipeFileManager.java | 10 +-
.../iotdb/db/pipe/resource/PipeRaftlogHolder.java | 10 +-
.../iotdb/db/pipe/resource/PipeTsFileHolder.java | 10 +-
.../iotdb/db/pipe/resource/PipeWALHolder.java | 10 +-
.../MNodeIterator.java => pipe/task/PipeTask.java} | 38 +-
.../apache/iotdb/db/pipe/task/PipeTaskBuilder.java | 11 +-
.../pipe/task/metrics/PipeTaskRuntimeRecorder.java | 10 +-
.../db/pipe/task/runnable/PipeAssignerSubtask.java | 12 +-
.../pipe/task/runnable/PipeConnectorSubtask.java | 12 +-
.../pipe/task/runnable/PipeProcessorSubtask.java | 12 +-
.../iotdb/db/pipe/task/runnable/PipeSubtask.java | 20 +-
.../pipe/task/stage/PipeTaskCollectorStage.java} | 21 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 19 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 19 +-
.../task/stage/PipeTaskStage.java} | 37 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 154 +-
.../db/service/ResourcesInformationHolder.java | 12 +
.../db/service/metrics/DataNodeMetricsHelper.java | 6 +-
.../metrics/IoTDBInternalLocalReporter.java | 37 +
.../service/thrift/impl/ClientRPCServiceImpl.java | 52 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 6 +-
.../db/sync/transport/server/ReceiverManager.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 3 +
.../engine/compaction/AbstractCompactionTest.java | 7 +-
.../compaction/FastAlignedCrossCompactionTest.java | 139 +-
.../FastNonAlignedCrossCompactionTest.java | 138 +-
.../inner/InnerCompactionSchedulerTest.java | 6 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 901 ++
.../iotdb/db/engine/storagegroup/TTLTest.java | 4 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 18 +-
.../iotdb/db/metadata/idtable/IDTableTest.java | 2 +-
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 64 +-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 93 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 257 -
.../mtree/disk/CachedMNodeContainerTest.java | 25 +-
.../metadata/mtree/schemafile/RecordUtilTests.java | 32 +-
.../mtree/schemafile/SchemaFileLogTest.java | 23 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 301 +-
.../metadata/mtree/schemafile/SchemaPageTest.java | 26 +-
.../mtree/schemafile/WrappedSegmentTest.java | 48 +-
.../schemaRegion/SchemaRegionBasicTest.java | 2 +-
.../schemaRegion/SchemaStatisticsTest.java | 185 +-
.../iotdb/db/mpp/execution/exchange/StubSink.java | 5 +
.../iotdb/db/mpp/execution/exchange/Utils.java | 4 +-
.../db/mpp/execution/memory/MemoryPoolTest.java | 26 +-
.../operator/AggregationOperatorTest.java | 26 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 38 +-
.../operator/AlignedSeriesScanOperatorTest.java | 6 +-
.../operator/DeviceMergeOperatorTest.java | 565 --
.../execution/operator/DeviceViewOperatorTest.java | 3 +-
.../mpp/execution/operator/FillOperatorTest.java | 16 +-
.../operator/HorizontallyConcatOperatorTest.java | 2 +-
.../operator/LastQueryMergeOperatorTest.java | 38 +-
.../execution/operator/LastQueryOperatorTest.java | 4 +-
.../operator/LastQuerySortOperatorTest.java | 5 +-
.../mpp/execution/operator/LimitOperatorTest.java | 2 +-
.../execution/operator/LinearFillOperatorTest.java | 56 +-
.../execution/operator/MergeSortOperatorTest.java | 38 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 6 +-
.../operator/RawDataAggregationOperatorTest.java | 54 +-
.../SeriesAggregationScanOperatorTest.java | 65 +-
.../execution/operator/SeriesScanOperatorTest.java | 2 +-
.../operator/SingleDeviceViewOperatorTest.java | 3 +-
.../SlidingWindowAggregationOperatorTest.java | 3 +-
.../execution/operator/TimeJoinOperatorTest.java | 6 +-
.../operator/UpdateLastCacheOperatorTest.java | 6 +-
.../operator/schema/SchemaCountOperatorTest.java | 4 +-
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../db/mpp/plan/plan/PipelineBuilderTest.java | 96 +-
.../NodeManagementMemoryMergeNodeSerdeTest.java | 2 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 43 +-
.../datanode1conf/iotdb-common.properties | 3 +-
.../datanode2conf/iotdb-common.properties | 3 +-
.../datanode3conf/iotdb-common.properties | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +-
.../java/org/apache/iotdb/session/Session.java | 14 +
.../apache/iotdb/session/SessionConnection.java | 20 +
.../org/apache/iotdb/session/pool/SessionPool.java | 20 +
site/replace-picture-urls.sh | 3 +-
.../docsearch/client/components/Docsearch.ts | 1 -
site/src/main/.vuepress/config.ts | 2 +-
site/src/main/.vuepress/public/favicon.ico | Bin 1595 -> 2816 bytes
.../Ecosystem-Integration/Workbench/image10.jpeg | Bin 0 -> 131946 bytes
.../Ecosystem-Integration/Workbench/image11.jpeg | Bin 0 -> 487707 bytes
.../Ecosystem-Integration/Workbench/image12.png | Bin 0 -> 45444 bytes
.../Ecosystem-Integration/Workbench/image13.jpeg | Bin 0 -> 488050 bytes
.../Ecosystem-Integration/Workbench/image14.jpeg | Bin 0 -> 457975 bytes
.../Ecosystem-Integration/Workbench/image15.jpeg | Bin 0 -> 493580 bytes
.../Ecosystem-Integration/Workbench/image16.jpeg | Bin 0 -> 444360 bytes
.../Ecosystem-Integration/Workbench/image17.jpeg | Bin 0 -> 512202 bytes
.../Ecosystem-Integration/Workbench/image18.jpeg | Bin 0 -> 99839 bytes
.../Ecosystem-Integration/Workbench/image19.jpeg | Bin 0 -> 596956 bytes
.../Ecosystem-Integration/Workbench/image20.png | Bin 0 -> 674410 bytes
.../Ecosystem-Integration/Workbench/image21.jpeg | Bin 0 -> 694550 bytes
.../Ecosystem-Integration/Workbench/image22.jpeg | Bin 0 -> 808356 bytes
.../Ecosystem-Integration/Workbench/image23.jpeg | Bin 0 -> 827186 bytes
.../Ecosystem-Integration/Workbench/image24.png | Bin 0 -> 179727 bytes
.../Ecosystem-Integration/Workbench/image25.jpeg | Bin 0 -> 529074 bytes
.../Ecosystem-Integration/Workbench/image26.jpeg | Bin 0 -> 307123 bytes
.../Ecosystem-Integration/Workbench/image27.png | Bin 0 -> 350407 bytes
.../Ecosystem-Integration/Workbench/image28.jpeg | Bin 0 -> 737495 bytes
.../Ecosystem-Integration/Workbench/image29.jpeg | Bin 0 -> 71283 bytes
.../Ecosystem-Integration/Workbench/image30.png | Bin 0 -> 200568 bytes
.../Ecosystem-Integration/Workbench/image31.jpeg | Bin 0 -> 433529 bytes
.../Ecosystem-Integration/Workbench/image32.jpeg | Bin 0 -> 539089 bytes
.../Ecosystem-Integration/Workbench/image33.png | Bin 0 -> 273003 bytes
.../Ecosystem-Integration/Workbench/image34.png | Bin 0 -> 148569 bytes
.../Ecosystem-Integration/Workbench/image35.png | Bin 0 -> 186961 bytes
.../Ecosystem-Integration/Workbench/image36.png | Bin 0 -> 349267 bytes
.../Ecosystem-Integration/Workbench/image37.png | Bin 0 -> 400709 bytes
.../Ecosystem-Integration/Workbench/image38.png | Bin 0 -> 349067 bytes
.../Ecosystem-Integration/Workbench/image39.jpeg | Bin 0 -> 941372 bytes
.../Ecosystem-Integration/Workbench/image40.png | Bin 0 -> 168395 bytes
.../Ecosystem-Integration/Workbench/image41.png | Bin 0 -> 342396 bytes
.../Ecosystem-Integration/Workbench/image42.png | Bin 0 -> 470241 bytes
.../Ecosystem-Integration/Workbench/image43.png | Bin 0 -> 110992 bytes
.../Ecosystem-Integration/Workbench/image44.png | Bin 0 -> 241073 bytes
.../Ecosystem-Integration/Workbench/image45.png | Bin 0 -> 253855 bytes
.../Ecosystem-Integration/Workbench/image5.jpeg | Bin 0 -> 7926 bytes
.../Ecosystem-Integration/Workbench/image6.jpeg | Bin 0 -> 395220 bytes
.../Ecosystem-Integration/Workbench/image7.png | Bin 0 -> 392808 bytes
.../Ecosystem-Integration/Workbench/image8.jpeg | Bin 0 -> 107764 bytes
.../Ecosystem-Integration/Workbench/image9.jpeg | Bin 0 -> 146196 bytes
site/src/main/.vuepress/sidebar/zh.ts | 1 +
site/src/main/.vuepress/styles/config.scss | 1 +
site/src/main/.vuepress/utils/editLink.ts | 8 +-
site/src/main/package-lock.json | 3588 ++++---
site/src/main/package.json | 7 +-
site/src/main/pnpm-lock.yaml | 9892 ++++++++++++++++++++
thrift-commons/src/main/thrift/common.thrift | 3 +-
.../src/main/thrift/confignode.thrift | 12 +-
thrift/src/main/thrift/client.thrift | 7 +
thrift/src/main/thrift/datanode.thrift | 12 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 7 +
.../tsfile/write/schema/MeasurementSchema.java | 8 +
649 files changed, 36050 insertions(+), 15273 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup
=> database}/AdjustMaxRegionGroupNumPlan.java (94%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup
=> database}/DatabaseSchemaPlan.java (90%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup
=> database}/DeleteDatabasePlan.java (96%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup
=> database}/PreDeleteDatabasePlan.java (97%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup
=> database}/SetDataReplicationFactorPlan.java (74%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup
=> database}/SetSchemaReplicationFactorPlan.java (77%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup
=> database}/SetTTLPlan.java (70%)
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{storagegroup
=> database}/SetTimePartitionIntervalPlan.java (91%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/CreatePipePluginProcedure.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/plugin/DropPipePluginProcedure.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/pipe/plugin/CreatePipePluginState.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/pipe/plugin/DropPipePluginState.java
(82%)
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/CreatePipePluginProcedureTest.java
create mode 100644
confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/DropPipePluginProcedureTest.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/ratis/metrics/RatisMetricsManager.java
create mode 100644
docs/UserGuide/Monitor-Alert/Apache-IoTDB-Disk-IO-Dashboard.json
create mode 100644 docs/zh/UserGuide/Ecosystem-Integration/Workbench.md
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/IoTDBModeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/builtinfunction/scalar/IoTDBReplaceFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/builtinfunction/scalar/IoTDBRoundFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/groupby/IoTDBGroupByCountIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryWithLimitOffsetIT.java
delete mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dprofile/UDAFMode.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/{udf/builtin/UDTFRound.java
=> pipe/task/meta/PipeTaskMetaAccessor.java} (82%)
rename {server/src/main/java/org/apache/iotdb/db/metadata/mnode =>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node}/IMNode.java
(51%)
rename {server/src/main/java/org/apache/iotdb/db/metadata/mnode =>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node}/MNodeType.java
(97%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractAboveDatabaseMNode.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractDatabaseDeviceMNode.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractDatabaseMNode.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractDeviceMNode.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/common/AbstractMeasurementMNode.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/container/IMNodeContainer.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/info/IDatabaseDeviceInfo.java
(79%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/constant/BuiltinScalarFunctionEnum.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/info/IDatabaseInfo.java
(69%)
copy server/src/main/java/org/apache/iotdb/db/metadata/mnode/IEntityMNode.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/info/IDeviceInfo.java
(55%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IMeasurementMNode.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/info/IMeasurementInfo.java
(76%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator/IMNodeIterator.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/role/IDatabaseMNode.java
(73%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IEntityMNode.java =>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/role/IDeviceMNode.java
(63%)
copy {server/src/main/java/org/apache/iotdb/db/metadata/mnode =>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/role}/IMeasurementMNode.java
(84%)
rename {server/src/main/java/org/apache/iotdb/db/metadata/mnode/container =>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/utils}/IMNodeContainer.java
(81%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IMeasurementMNode.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/utils/IMNodeFactory.java
(50%)
rename {server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator =>
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/utils}/IMNodeIterator.java
(82%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/node/visitor/MNodeVisitor.java
rename
schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/{RStorageGroupMNode.java
=> RDatabaseMNode.java} (74%)
rename
schema-engine-rocksdb/src/main/java/org/apache/iotdb/db/metadata/schemaregion/rocksdb/mnode/{REntityMNode.java
=> RDeviceMNode.java} (70%)
create mode 100644 server/src/main/codegen/templates/ModeAccumulator.ftl
create mode 100644
server/src/main/java/org/apache/iotdb/db/conf/DataNodeStartupCheck.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/InsertMeasurementMNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/MNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/MNodeUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/MeasurementMNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/StorageGroupEntityMNode.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/StorageGroupMNode.java
rename
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{IStorageGroupMNode.java
=> config/IConfigMNode.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/config/basic/ConfigBasicMNode.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{container/MNodeContainers.java
=> config/container/ConfigMNodeContainer.java} (59%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/config/factory/ConfigMNodeFactory.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{InternalMNode.java =>
config/impl/ConfigBasicInternalMNode.java} (50%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/config/impl/ConfigDatabaseMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/config/info/ConfigDatabaseInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/config/info/ConfigMNodeInfo.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/container/MNodeContainerMapImpl.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/estimator/BasicMNodSizeEstimator.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=> server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/IMemMNode.java
(82%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/basic/BasicMNode.java
rename
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{container/MNodeContainers.java
=> mem/container/MemMNodeContainer.java} (60%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/estimator/MNodeSizeEstimator.java
(80%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/factory/MemMNodeFactory.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{iterator/MNodeIterator.java
=> mem/impl/AboveDatabaseMNode.java} (61%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{InternalMNode.java =>
mem/impl/BasicInternalMNode.java} (50%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/process/join/merge/DescTimeComparator.java
=> metadata/mnode/mem/impl/DatabaseDeviceMNode.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{iterator/MNodeIterator.java
=> mem/impl/DatabaseMNode.java} (52%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{iterator/MNodeIterator.java
=> mem/impl/DeviceMNode.java} (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/impl/MeasurementMNode.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/constant/BuiltinScalarFunctionEnum.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/info/BasicMNodeInfo.java
(66%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/info/DatabaseDeviceInfo.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{iterator/MNodeIterator.java
=> mem/info/DatabaseInfo.java} (52%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{EntityMNode.java =>
mem/info/DeviceInfo.java} (57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/mem/info/MeasurementInfo.java
rename server/src/main/java/org/apache/iotdb/db/metadata/mnode/{ =>
mem}/iterator/AbstractTraverserIterator.java (77%)
copy server/src/main/java/org/apache/iotdb/db/metadata/mnode/{ =>
mem}/iterator/MNodeIterator.java (75%)
rename server/src/main/java/org/apache/iotdb/db/metadata/mnode/{ =>
mem}/iterator/MemoryTraverserIterator.java (65%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/transformation/api/YieldableReader.java
=> metadata/mnode/schemafile/ICachedMNode.java} (72%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/schemafile/basic/CachedBasicMNode.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{mtree/store/disk =>
mnode/schemafile/container}/CachedMNodeContainer.java (67%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{mtree/store/disk =>
mnode/schemafile/container}/ICachedMNodeContainer.java (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/schemafile/factory/CacheMNodeFactory.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{iterator/MNodeIterator.java
=> schemafile/impl/CachedAboveDatabaseMNode.java} (50%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{InternalMNode.java =>
schemafile/impl/CachedBasicInternalMNode.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/schemafile/impl/CachedDatabaseDeviceMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/schemafile/impl/CachedDatabaseMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/schemafile/impl/CachedDeviceMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/schemafile/impl/CachedMeasurementMNode.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{iterator/MNodeIterator.java
=> schemafile/info/CacheMNodeInfo.java} (58%)
rename server/src/main/java/org/apache/iotdb/db/metadata/mnode/{ =>
schemafile}/iterator/CachedTraverserIterator.java (67%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/utils/MNodeUtils.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/visitor/MNodeVisitor.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/IMTreeBelowSG.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/ConfigMTreeStore.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/store/disk/memcontrol/CachedMNodeSizeEstimator.java
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/{MNodeAboveSGCollector.java
=> MNodeAboveDBCollector.java} (63%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateMNodeGenerator.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{AbstractVariationWindow.java
=> CountWindow.java} (55%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/CountWindowManager.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/window/{WindowType.java
=> CountWindowParameter.java} (53%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/metric/PerformanceOverviewMetricsManager.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{CountStorageGroupTask.java
=> CountDatabaseTask.java} (84%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{ShowStorageGroupTask.java
=> ShowDatabaseTask.java} (75%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/multi/builtin/helper/{CastHelper.java
=> CastFunctionHelper.java} (92%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/multi/builtin/helper/{DiffHelper.java
=> DiffFunctionHelper.java} (86%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/multi/builtin/helper/{DiffHelper.java
=> ReplaceFunctionHelper.java} (58%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/multi/builtin/helper/{DiffHelper.java
=> RoundFunctionHelper.java} (72%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/BatchActivateTemplateNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/GroupByCountParameter.java
rename
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/AboveDatabaseMNode.java
=> mpp/plan/statement/component/GroupByCountComponent.java} (66%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CountStorageGroupStatement.java
=> CountDatabaseStatement.java} (89%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{DeleteStorageGroupStatement.java
=> DeleteDatabaseStatement.java} (93%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{ShowStorageGroupStatement.java
=> ShowDatabaseStatement.java} (96%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/template/{DropSchemaTemplateStatement.java
=> BatchActivateTemplateStatement.java} (60%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/scalar/ReplaceFunctionColumnTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/scalar/RoundFunctionColumnTransformer.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/unary/{IsNullTransformer.java
=> scalar/ReplaceFunctionTransformer.java} (53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/transformer/unary/scalar/RoundFunctionTransformer.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/agent/PipeAgent.java
rename server/src/main/java/org/apache/iotdb/db/pipe/agent/{ =>
plugin}/PipePluginAgent.java (86%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/HeartbeatScheduler.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/MetaSyncScheduler.java
(82%)
rename
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/estimator/IMNodeSizeEstimator.java
=> pipe/agent/runtime/PipeRuntimeAgent.java} (61%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/constant/BuiltinScalarFunctionEnum.java
=> server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskAgent.java
(62%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/agent/task/PipeTaskRegionAgent.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/PipeCollectorEventPendingQueue.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/PipeCollectorEventSelector.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/historical/PipeHistoricalCollector.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/PipeRealtimeCollector.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/cache/PipeRealtimeEventCache.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/IoTLogListerner.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/RatisLogListener.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/SimpleLogListener.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/listener/TsFileGenerationListener.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/matcher/Rule.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/matcher/RulePrefixMatchTree.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/recorder/TsFileEpoch.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/collector/realtime/recorder/TsFileEpochRecorder.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorContainer.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorManager.java
(82%)
rename
server/src/{test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeNonMemoryTest.java
=>
main/java/org/apache/iotdb/db/pipe/core/connector/PipeConnectorPluginRuntimeWrapper.java}
(72%)
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/iterator/MNodeIterator.java
=> pipe/core/event/PipeTabletInsertionEvent.java} (55%)
rename
server/src/{test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeMemoryModeTest.java
=>
main/java/org/apache/iotdb/db/pipe/core/event/PipeTsFileInsertionEvent.java}
(63%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/core/event/access/PipeRow.java
copy
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/iterator/MNodeIterator.java
=> pipe/core/event/access/PipeRowIterator.java} (51%)
rename
server/src/{test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeDiskModeTest.java
=>
main/java/org/apache/iotdb/db/pipe/core/event/collector/PipeEventCollector.java}
(55%)
rename
server/src/{test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreeFullMemoryTest.java
=>
main/java/org/apache/iotdb/db/pipe/core/event/collector/PipeRowCollector.java}
(73%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeEventIndexer.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeIoTEventIndexer.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeRatisEventIndexer.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeSimpleEventIndexer.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/event/indexer/PipeTsFileEventIndexer.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/processor/PipeProcessorPluginRuntimeWrapper.java
(72%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeAssignerSubtaskExecutor.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeConnectorSubtaskExecutor.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeProcessorSubtaskExecutor.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeSubtaskExecutor.java
(82%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/execution/executor/PipeTaskExecutor.java
copy
server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/process/join/merge/AscTimeComparator.java
=> pipe/execution/scheduler/PipeAssignerSubtaskScheduler.java} (66%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/process/join/merge/AscTimeComparator.java
=> pipe/execution/scheduler/PipeConnectorSubtaskScheduler.java} (66%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/execution/operator/process/join/merge/AscTimeComparator.java
=> pipe/execution/scheduler/PipeProcessorSubtaskScheduler.java} (66%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/constant/BuiltinScalarFunctionEnum.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeSubtaskScheduler.java
(71%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/execution/scheduler/PipeTaskScheduler.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=> server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeFileManager.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeRaftlogHolder.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=> server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeTsFileHolder.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=> server/src/main/java/org/apache/iotdb/db/pipe/resource/PipeWALHolder.java
(82%)
rename
server/src/main/java/org/apache/iotdb/db/{metadata/mnode/iterator/MNodeIterator.java
=> pipe/task/PipeTask.java} (51%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=> server/src/main/java/org/apache/iotdb/db/pipe/task/PipeTaskBuilder.java (82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/task/metrics/PipeTaskRuntimeRecorder.java
(82%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/task/runnable/PipeAssignerSubtask.java
(79%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/task/runnable/PipeConnectorSubtask.java
(79%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/task/runnable/PipeProcessorSubtask.java
(79%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/constant/BuiltinScalarFunctionEnum.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/task/runnable/PipeSubtask.java
(71%)
rename
server/src/{test/java/org/apache/iotdb/db/metadata/mtree/multimode/MTreePartialMemoryTest.java
=> main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskCollectorStage.java}
(67%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskConnectorStage.java
(68%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFRound.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/task/stage/PipeTaskProcessorStage.java
(68%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/execution/exchange/sink/ISinkHandle.java
=> pipe/task/stage/PipeTaskStage.java} (53%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/metadata/mtree/MTreeBelowSGTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/DeviceMergeOperatorTest.java
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image10.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image11.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image12.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image13.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image14.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image15.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image16.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image17.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image18.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image19.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image20.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image21.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image22.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image23.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image24.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image25.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image26.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image27.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image28.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image29.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image30.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image31.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image32.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image33.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image34.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image35.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image36.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image37.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image38.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image39.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image40.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image41.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image42.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image43.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image44.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image45.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image5.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image6.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image7.png
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image8.jpeg
create mode 100644
site/src/main/.vuepress/public/img/UserGuide/Ecosystem-Integration/Workbench/image9.jpeg
create mode 100644 site/src/main/pnpm-lock.yaml
