This is an automated email from the ASF dual-hosted git repository.
CRZbulabula pushed a change to branch feat-region-delete-speed-limit
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0df08a1fcaa Limit region deletion with migration speed limit
add 801d4fbcab6 Limit region migration transfer for all protocols
No new revisions were added by this update.
Summary of changes:
.../consensus/ratis/RateLimitedGrpcFactory.java} | 29 ++++-----
.../ratis/RateLimitedGrpcLogAppender.java | 76 ++++++++++++++++++++++
.../consensus/ratis/RateLimitedGrpcRpcType.java} | 18 ++---
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +
.../ratis/RateLimitedGrpcLogAppenderTest.java | 66 +++++++++++++++++++
.../iotconsensusv2/IoTConsensusV2RateLimiter.java | 58 +++++++++++++++++
.../iotconsensusv2/IoTConsensusV2SyncSink.java | 37 ++++++-----
.../handler/IoTConsensusV2DeleteEventHandler.java | 2 +
.../IoTConsensusV2TabletBatchEventHandler.java | 2 +
.../IoTConsensusV2TabletInsertionEventHandler.java | 2 +
.../IoTConsensusV2TsFileInsertionEventHandler.java | 2 +
.../IoTConsensusV2RateLimiterTest.java | 62 ++++++++++++++++++
.../conf/iotdb-system.properties.template | 2 +-
13 files changed, 317 insertions(+), 41 deletions(-)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/view/CreateTableViewStatement.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcFactory.java}
(59%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppender.java
copy
iotdb-core/{calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/fill/identity/IdentityFill.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcRpcType.java}
(67%)
create mode 100644
iotdb-core/consensus/src/test/java/org/apache/iotdb/consensus/ratis/RateLimitedGrpcLogAppenderTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/iotconsensusv2/IoTConsensusV2RateLimiter.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/sink/protocol/iotconsensusv2/IoTConsensusV2RateLimiterTest.java
