This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from da33c12 bugfix: solve the concurrency problem in ruleTransfer
add d9c8d3a 1、基于fileSink写入文件行数计算TPS
add 3302432 1、基于fileSink写入文件行数计算TPS 2、移除无用测试类
No new revisions were added by this update.
Summary of changes:
adapter/{storage => benchmark}/pom.xml | 46 ++++---------
.../adapter/benchmark/AbstractEventCommon.java | 74 +++++++++++++++++++++
.../adapter/benchmark/EventTPSCommon.java | 75 ++++++++++++++++++++++
adapter/pom.xml | 1 +
4 files changed, 161 insertions(+), 35 deletions(-)
copy adapter/{storage => benchmark}/pom.xml (61%)
create mode 100644
adapter/benchmark/src/main/java/org/apache/rocketmq/eventbridge/adapter/benchmark/AbstractEventCommon.java
create mode 100644
adapter/benchmark/src/main/java/org/apache/rocketmq/eventbridge/adapter/benchmark/EventTPSCommon.java
