[iotdb] branch master updated (1569d17634 -> f72560bca2)

[yo...@apache.org]

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

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


    from 1569d17634 add a notice of time_duration function to indicate some specific situations (#9594)
     add f72560bca2 [IOTDB-5570] Move heartbeat thread and statistics thread to load manager (#9608)

No new revisions were added by this update.

Summary of changes:
 .../heartbeat/ConfigNodeHeartbeatHandler.java      |  17 +-
 .../heartbeat/DataNodeHeartbeatHandler.java        |  57 ++-
 .../statemachine/ConfigRegionStateMachine.java     |   9 +-
 .../iotdb/confignode/manager/ConfigManager.java    |  27 +-
 .../iotdb/confignode/manager/ProcedureManager.java |  79 ++--
 .../confignode/manager/RetryFailedTasksThread.java |  21 +-
 .../iotdb/confignode/manager/load/LoadManager.java | 386 +++++++++---------
 .../manager/load/balancer/RegionBalancer.java      |   7 +-
 .../manager/load/balancer/RouteBalancer.java       |  21 +-
 .../confignode/manager/load/cache/LoadCache.java   | 452 +++++++++++++++++++++
 .../cache/node}/BaseNodeCache.java                 |  59 +--
 .../cache/node}/ConfigNodeHeartbeatCache.java      |  29 +-
 .../cache/node}/DataNodeHeartbeatCache.java        |  25 +-
 .../cache/node}/NodeHeartbeatSample.java           |   7 +-
 .../cache/node}/NodeStatistics.java                |  11 +-
 .../cache/region}/RegionCache.java                 |   7 +-
 .../cache/region}/RegionGroupCache.java            |  36 +-
 .../cache/region}/RegionGroupStatistics.java       |  16 +-
 .../cache/region}/RegionHeartbeatSample.java       |   3 +-
 .../cache/region}/RegionStatistics.java            |  16 +-
 .../manager/load/service/HeartbeatService.java     | 192 +++++++++
 .../StatisticsService.java}                        | 209 ++--------
 .../iotdb/confignode/manager/node/NodeManager.java | 322 +--------------
 .../manager/observer/NodeStatisticsEvent.java      |   2 +-
 .../manager/partition/PartitionManager.java        | 166 +++-----
 .../manager/partition/PartitionMetrics.java        |  18 +-
 .../manager/partition/RegionGroupStatus.java       |  21 +-
 .../confignode/persistence/node/NodeInfo.java      |  47 ++-
 .../partition/DatabasePartitionTable.java          |  62 ++-
 .../persistence/partition/PartitionInfo.java       |  50 ++-
 .../persistence/partition/RegionGroup.java         |  13 +-
 .../procedure/env/ConfigNodeProcedureEnv.java      |  41 +-
 .../procedure/env/DataNodeRemoveHandler.java       |  15 +-
 .../impl/schema/DeleteDatabaseProcedure.java       |   2 +-
 .../impl/statemachine/RegionMigrateProcedure.java  |   3 +
 .../router/priority/GreedyPriorityTest.java        |   8 +-
 .../priority/LeaderPriorityBalancerTest.java       |   8 +-
 .../confignode/manager/node/NodeCacheTest.java     |   8 +-
 .../manager/partition/RegionGroupCacheTest.java    |   4 +-
 .../persistence/node/NodeStatisticsTest.java       |   2 +-
 .../statistics/RegionGroupStatisticsTest.java      |   4 +-
 .../partition/statistics/RegionStatisticsTest.java |   2 +-
 42 files changed, 1383 insertions(+), 1101 deletions(-)
 create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/LoadCache.java
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/BaseNodeCache.java (74%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/ConfigNodeHeartbeatCache.java (80%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/DataNodeHeartbeatCache.java (80%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/NodeHeartbeatSample.java (95%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{node/heartbeat => load/cache/node}/NodeStatistics.java (95%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionCache.java (89%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionGroupCache.java (86%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionGroupStatistics.java (94%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionHeartbeatSample.java (95%)
 rename confignode/src/main/java/org/apache/iotdb/confignode/manager/{partition/heartbeat => load/cache/region}/RegionStatistics.java (86%)
 create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/HeartbeatService.java
 copy confignode/src/main/java/org/apache/iotdb/confignode/manager/load/{LoadManager.java => service/StatisticsService.java} (51%)