This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch IOTDB-5787 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c16bc7f7a06addf75a187cdf56284dc800c7ef4d Merge: 15f62d4efe7 ee4df02d5b0 Author: Steve Yurong Su <[email protected]> AuthorDate: Sun May 7 02:09:30 2023 +0800 Merge branch 'master' of github.com:apache/iotdb into IOTDB-5787 client-py/SessionExample.py | 1 - client-py/iotdb/Session.py | 323 +++++----- client-py/iotdb/utils/IoTDBConnectionException.py | 29 + client-py/iotdb/utils/IoTDBRpcDataSet.py | 10 +- .../heartbeat/DataNodeHeartbeatHandler.java | 6 +- .../statemachine/ConfigRegionStateMachine.java | 2 - .../confignode/manager/ClusterSchemaManager.java | 20 +- .../iotdb/confignode/manager/ConfigManager.java | 4 +- .../iotdb/confignode/manager/load/LoadManager.java | 117 ++-- .../manager/load/balancer/RouteBalancer.java | 268 ++------- .../load/balancer/router/RegionRouteMap.java | 176 ------ .../confignode/manager/load/cache/LoadCache.java | 156 ++++- .../manager/load/cache/route/RegionRouteCache.java | 138 +++++ .../manager/load/service/HeartbeatService.java | 1 - .../manager/load/service/StatisticsService.java | 70 ++- .../manager/load/subscriber/RouteChangeEvent.java | 35 +- .../manager/partition/PartitionManager.java | 6 +- .../persistence/executor/ConfigPlanExecutor.java | 7 +- .../persistence/partition/PartitionInfo.java | 5 + .../procedure/env/ConfigNodeProcedureEnv.java | 34 +- .../procedure/env/DataNodeRemoveHandler.java | 4 +- .../impl/pipe/task/CreatePipeProcedureV2.java | 2 +- .../impl/schema/DataNodeRegionTaskExecutor.java | 4 +- .../impl/schema/DeleteDatabaseProcedure.java | 2 - .../statemachine/CreateRegionGroupsProcedure.java | 1 - .../load/balancer/router/RegionRouteMapTest.java | 82 --- .../consensus/iot/IoTConsensusServerImpl.java | 13 +- docs/Community/Materials.md | 103 ++-- docs/UserGuide/QuickStart/Files.md | 2 +- docs/UserGuide/Reference/DataNode-Config-Manual.md | 14 +- .../Syntax-Conventions/Session-And-TsFile-API.md | 4 +- .../UserGuide/Ecosystem-Integration/Workbench.md | 79 +-- docs/zh/UserGuide/QuickStart/Files.md | 2 +- .../UserGuide/Reference/DataNode-Config-Manual.md | 21 +- .../Syntax-Conventions/Session-And-TsFile-API.md | 4 +- .../metrics/metricsets/jvm/JvmThreadMetrics.java | 31 +- .../metricsets/net/LinuxNetMetricManager.java | 27 +- .../iotdb/metrics/metricsets/net/NetMetrics.java | 2 +- .../resources/conf/iotdb-common.properties | 4 + .../commons/schema/tree/AbstractTreeVisitor.java | 122 +++- pom.xml | 4 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 + .../iotdb/db/engine/TsFileMetricManager.java | 63 +- .../performer/impl/FastCompactionPerformer.java | 19 +- .../impl/ReadChunkCompactionPerformer.java | 11 +- .../impl/ReadPointCompactionPerformer.java | 21 +- .../execute/task/AbstractCompactionTask.java | 12 +- .../execute/task/CompactionTaskSummary.java | 18 + .../execute/task/CrossSpaceCompactionTask.java | 11 +- .../execute/task/InnerSpaceCompactionTask.java | 7 +- .../fast/AlignedSeriesCompactionExecutor.java | 16 +- .../readchunk/AlignedSeriesCompactionExecutor.java | 6 - .../utils/writer/AbstractCompactionWriter.java | 3 +- .../iotdb/db/engine/flush/MemTableFlushTask.java | 2 +- .../db/metadata/mtree/traverser/Traverser.java | 61 ++ .../traverser/TraverserWithLimitOffsetWrapper.java | 5 + .../mtree/traverser/basic/DatabaseTraverser.java | 5 + .../mtree/traverser/basic/EntityTraverser.java | 8 + .../mtree/traverser/basic/MNodeTraverser.java | 5 + .../traverser/basic/MeasurementTraverser.java | 5 + .../metadata/template/ClusterTemplateManager.java | 7 +- .../db/metadata/template/ITemplateManager.java | 3 +- .../visitor/SchemaTreeDeviceVisitor.java | 5 + .../visitor/SchemaTreeMeasurementVisitor.java | 5 + .../SchemaTreeVisitorWithLimitOffsetWrapper.java | 6 + .../iotdb/db/mpp/execution/driver/Driver.java | 2 +- .../execution/schedule/AbstractDriverThread.java | 9 + .../schedule/queue/IndexedBlockingQueue.java | 1 + .../multilevelqueue/MultilevelPriorityQueue.java | 4 +- .../db/mpp/plan/execution/QueryExecution.java | 7 +- .../db/mpp/plan/scheduler/AsyncPlanNodeSender.java | 74 ++- .../plan/scheduler/AsyncSendPlanNodeHandler.java | 27 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 20 +- .../rest/v1/handler/ExecuteStatementHandler.java | 4 +- .../rest/v1/handler/QueryDataSetHandler.java | 5 +- .../rest/v2/handler/ExecuteStatementHandler.java | 4 +- .../rest/v2/handler/QueryDataSetHandler.java | 5 +- .../db/service/metrics/CompactionMetrics.java | 12 +- .../iotdb/db/service/metrics/FileMetrics.java | 26 +- .../metrics/recorder/CompactionMetricsManager.java | 6 +- .../db/service/thrift/ProcessorWithMetrics.java | 2 +- .../service/thrift/impl/ClientRPCServiceImpl.java | 2 +- .../impl/DataNodeInternalRPCServiceImpl.java | 36 +- .../java/org/apache/iotdb/db/wal/WALManager.java | 8 +- .../db/wal/allocation/FirstCreateStrategy.java | 3 + .../iotdb/db/wal/buffer/AbstractWALBuffer.java | 41 +- .../java/org/apache/iotdb/db/wal/node/WALNode.java | 14 +- .../iotdb/db/wal/recover/WALNodeRecoverTask.java | 6 - .../engine/compaction/AbstractCompactionTest.java | 3 + .../compaction/CompactionTaskComparatorTest.java | 8 +- .../compaction/FastAlignedCrossCompactionTest.java | 347 ++++++++++- .../FastInnerCompactionPerformerTest.java | 30 +- .../FastNonAlignedCrossCompactionTest.java | 347 ++++++++++- .../ReadPointAlignedCrossCompactionTest.java | 347 ++++++++++- .../ReadPointNonAlignedCrossCompactionTest.java | 347 ++++++++++- .../CrossSpaceCompactionWithFastPerformerTest.java | 7 +- ...eCompactionWithFastPerformerValidationTest.java | 194 +++--- ...actionWithReadPointPerformerValidationTest.java | 168 +++--- .../utils/MultiTsFileDeviceIteratorTest.java | 12 +- .../schemaRegion/SchemaRegionBasicTest.java | 103 +++- .../apache/iotdb/db/metric/MetricServiceTest.java | 3 - .../DataNodeInternalRPCServiceImplTest.java | 31 +- .../sync/pipedata/BufferedPipeDataQueueTest.java | 658 --------------------- thrift/src/main/thrift/datanode.thrift | 16 +- .../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 4 - 105 files changed, 3050 insertions(+), 2137 deletions(-)
