This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b4045de6eb2 Bump ratis to 3.2.0 (#15825)
add f2f00501a5e Pipe: Added rate limiter for tsFile sending (#15765)
No new revisions were added by this update.
Summary of changes:
.../protocol/IoTDBConfigRegionAirGapConnector.java | 5 ++
.../protocol/IoTDBConfigRegionConnector.java | 5 ++
.../task/builder/PipeDataNodeTaskBuilder.java | 68 ++++++++++++++--------
.../airgap/IoTDBDataRegionAirGapConnector.java | 31 ++++++++++
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 5 ++
.../async/IoTDBDataRegionAsyncConnector.java | 14 +++++
.../async/handler/PipeTransferTsFileHandler.java | 6 ++
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 21 +++++++
.../thrift/sync/IoTDBSchemaRegionConnector.java | 5 ++
.../dataregion/IoTDBDataRegionExtractor.java | 10 +++-
.../pipe/metric/overview/PipeResourceMetrics.java | 14 +++++
.../load/limiter/LoadTsFileRateLimiter.java | 64 +++-----------------
.../apache/iotdb/commons/conf/CommonConfig.java | 16 +++++
.../iotdb/commons/pipe/config/PipeConfig.java | 6 ++
.../iotdb/commons/pipe/config/PipeDescriptor.java | 6 ++
.../config/constant/PipeConnectorConstant.java | 5 ++
.../connector/limiter/GlobalRPCRateLimiter.java} | 15 +++--
.../pipe/connector/limiter/GlobalRateLimiter.java | 14 ++---
.../connector/limiter/TsFileSendRateLimiter.java} | 31 ++++++----
.../connector/protocol/IoTDBAirGapConnector.java | 3 +
.../pipe/connector/protocol/IoTDBConnector.java | 4 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 3 +
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
23 files changed, 241 insertions(+), 111 deletions(-)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DataTypeParameter.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/limiter/GlobalRPCRateLimiter.java}
(66%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeConnectorSubtaskExecutor.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/limiter/TsFileSendRateLimiter.java}
(54%)
