(iotdb) branch master updated (214c49a2108 -> f4804a41440)

[ta...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from 214c49a2108 new iot_consensus_throttle_threshold_in_byte (#12333)
     add f4804a41440 Thread-safety load balance infrastructure (#12330)

No new revisions were added by this update.

Summary of changes:
 .../client/async/AsyncDataNodeClientPool.java      |   3 +-
 .../heartbeat/ConfigNodeHeartbeatHandler.java      |  22 +-
 .../heartbeat/DataNodeHeartbeatHandler.java        |  73 ++--
 ...CHandler.java => TransferLeaderRPCHandler.java} |  20 +-
 .../client/sync/SyncDataNodeClientPool.java        |   9 +-
 .../iotdb/confignode/manager/ConfigManager.java    |  33 +-
 .../iotdb/confignode/manager/load/LoadManager.java | 139 +++----
 .../manager/load/balancer/RouteBalancer.java       | 416 +++++++++++++--------
 .../router/priority/GreedyPriorityBalancer.java    |   4 +-
 .../router/priority/LeaderPriorityBalancer.java    |   4 +-
 .../load/cache/AbstractHeartbeatSample.java}       |  33 +-
 .../manager/load/cache/AbstractLoadCache.java      |  86 +++++
 .../manager/load/cache/AbstractStatistics.java     |  49 +++
 .../confignode/manager/load/cache/LoadCache.java   | 284 ++++++--------
 .../load/cache/consensus/ConsensusGroupCache.java  |  61 +++
 .../consensus/ConsensusGroupHeartbeatSample.java   |  27 +-
 .../cache/consensus/ConsensusGroupStatistics.java} |  34 +-
 .../manager/load/cache/node/BaseNodeCache.java     | 106 +-----
 .../load/cache/node/ConfigNodeHeartbeatCache.java  |  39 +-
 .../load/cache/node/DataNodeHeartbeatCache.java    |  37 +-
 .../load/cache/node/NodeHeartbeatSample.java       |  70 ++--
 .../manager/load/cache/node/NodeStatistics.java    |  94 +----
 .../manager/load/cache/region/RegionCache.java     |  56 +--
 .../load/cache/region/RegionGroupCache.java        |  96 ++---
 .../load/cache/region/RegionGroupStatistics.java   |  80 ++--
 .../load/cache/region/RegionHeartbeatSample.java   |  27 +-
 .../load/cache/region/RegionStatistics.java        |  38 +-
 .../manager/load/cache/route/RegionRouteCache.java | 147 --------
 .../manager/load/service/EventService.java         | 272 ++++++++++++++
 .../manager/load/service/HeartbeatService.java     |  26 +-
 .../manager/load/service/StatisticsService.java    | 237 +-----------
 ...va => ConsensusGroupStatisticsChangeEvent.java} |  30 +-
 .../load/subscriber/IClusterStatusSubscriber.java  |   8 +-
 ...scriber.java => NodeStatisticsChangeEvent.java} |  25 +-
 ....java => RegionGroupStatisticsChangeEvent.java} |  24 +-
 .../iotdb/confignode/manager/node/NodeManager.java |  13 +-
 .../runtime/PipeLeaderChangeHandler.java           |  41 +-
 .../runtime/PipeRuntimeCoordinator.java            |  23 +-
 .../procedure/env/ConfigNodeProcedureEnv.java      |  45 +--
 .../procedure/env/RegionMaintainHandler.java       |  43 ++-
 .../impl/node/AddConfigNodeProcedure.java          |  10 +-
 .../impl/region/CreateRegionGroupsProcedure.java   |  78 ++--
 .../impl/schema/DeleteDatabaseProcedure.java       |   5 +-
 .../router/priority/GreedyPriorityTest.java        |  10 +-
 .../priority/LeaderPriorityBalancerTest.java       |   8 +-
 ...CacheTest.java => ConsensusGroupCacheTest.java} |  20 +-
 .../manager/load/cache/NodeCacheTest.java          |  37 +-
 .../manager/load/cache/RegionGroupCacheTest.java   | 116 +++---
 .../persistence/node/NodeStatisticsTest.java       |  66 ----
 .../statistics/RegionGroupStatisticsTest.java      |  76 ----
 .../partition/statistics/RegionStatisticsTest.java |  66 ----
 .../org/apache/iotdb/consensus/IConsensus.java     |   8 +
 .../apache/iotdb/consensus/iot/IoTConsensus.java   |   7 +
 .../iotdb/consensus/ratis/RatisConsensus.java      |  12 +
 .../iotdb/consensus/simple/SimpleConsensus.java    |   5 +
 .../impl/DataNodeInternalRPCServiceImpl.java       |  52 ++-
 .../iotdb/commons/concurrent/ThreadName.java       |   1 +
 .../src/main/thrift/datanode.thrift                |   8 +-
 58 files changed, 1594 insertions(+), 1865 deletions(-)
 copy iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{AsyncTSStatusRPCHandler.java => TransferLeaderRPCHandler.java} (80%)
 rename iotdb-core/confignode/src/{test/java/org/apache/iotdb/confignode/manager/load/cache/RegionRouteCacheTest.java => main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractHeartbeatSample.java} (51%)
 create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractLoadCache.java
 create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/AbstractStatistics.java
 create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupCache.java
 copy iotdb-connector/spark-tsfile/src/main/java/org/apache/iotdb/spark/tsfile/qp/common/Operator.java => iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupHeartbeatSample.java (60%)
 mode change 100755 => 100644
 copy iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/common/NodeRef.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/consensus/ConsensusGroupStatistics.java} (54%)
 delete mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/route/RegionRouteCache.java
 create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/EventService.java
 rename iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/{RouteChangeEvent.java => ConsensusGroupStatisticsChangeEvent.java} (52%)
 copy iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/{IClusterStatusSubscriber.java => NodeStatisticsChangeEvent.java} (54%)
 rename iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/subscriber/{StatisticsChangeEvent.java => RegionGroupStatisticsChangeEvent.java} (65%)
 rename iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/load/cache/{LoadCacheTest.java => ConsensusGroupCacheTest.java} (58%)
 delete mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/node/NodeStatisticsTest.java
 delete mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionGroupStatisticsTest.java
 delete mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/partition/statistics/RegionStatisticsTest.java