You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2023/05/06 18:09:58 UTC
[iotdb] 03/03: Merge branch 'master' of github.com:apache/iotdb into IOTDB-5787
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 <ro...@apache.org>
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(-)