apache / rocketmq-connect
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 793 files with 54,500 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 3 files changed 21-50 times (1,988 lines of code)
    • 39 files changed 6-20 times (7,259 lines of code)
    • 751 files changed 1-5 times (45,253 lines of code)
0% | 0% | 3% | 13% | 83%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 793 files with 54,500 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 4 files changed by 11-25 contributors (2,248 lines of code)
    • 8 files changed by 6-10 contributors (1,381 lines of code)
    • 231 files changed by 2-5 contributors (22,311 lines of code)
    • 550 files changed by 1 contributor (28,560 lines of code)
0% | 4% | 2% | 40% | 52%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, md, sh, yaml, properties, txt, gitignore, avsc, py, json, yml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 3% | 13% | 83%
xml0% | 0% | 0% | 17% | 82%
py0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
avsc0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
rocketmq-connect-runtime0% | 0% | 13% | 35% | 50%
connectors0% | 0% | 0% | 5% | 94%
rocketmq-connect-sample0% | 0% | 0% | 58% | 41%
schema-converter0% | 0% | 0% | 0% | 100%
transforms0% | 0% | 0% | 0% | 100%
rocketmq-connect-cli0% | 0% | 0% | 0% | 100%
metric-exporter0% | 0% | 0% | 0% | 100%
style0% | 0% | 0% | 0% | 100%
distribution0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
Worker.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 739 44 2019-08-04 2023-04-21 44 13 877036922@qq.com 877036922@qq.com
WorkerSourceTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 578 33 2019-08-16 2023-05-15 40 14 san@chenyiliu.com sunxiaojian926@163.com
WorkerSinkTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 671 36 2019-11-19 2022-12-26 30 13 877036922@qq.com ashen@moesrc.com
RestHandler.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest
 260 17 2019-08-05 2022-12-26 20 11 877036922@qq.com yechun@corp.netease.com
ConnectUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 398 24 2019-08-16 2023-04-14 20 9 san@chenyiliu.com 877036922@qq.com
WorkerDirectTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 198 21 2021-10-26 2022-11-03 18 9 30995057+git-yang@users.nor... yechun@corp.netease.com
RebalanceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 73 4 2019-08-21 2023-05-16 17 9 duhengforever@apache.org 877036922@qq.com
ConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 29 1 2019-09-24 2023-02-28 14 6 zero.xu@bytedance.com sunxiaojian926@163.com
ClusterManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 124 12 2019-08-13 2023-02-28 14 7 duhengforever@apache.org sunxiaojian926@163.com
BrokerBasedLog.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync
 296 17 2019-08-16 2023-02-28 14 8 san@chenyiliu.com sunxiaojian926@163.com
MemoryConfigManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory
 141 16 2022-05-24 2023-02-28 12 4 sunxiaojian926@163.com sunxiaojian926@163.com
TransformChain.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 107 6 2022-03-07 2022-09-28 11 5 877036922@qq.com sunxiaojian926@163.com
FileSourceTask.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 212 4 2019-08-13 2023-04-04 11 8 877036922@qq.com clooker@163.com
ClusterManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 17 1 2019-08-21 2023-02-28 10 4 duhengforever@apache.org sunxiaojian926@163.com
PositionManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 27 2 2021-03-27 2023-02-28 10 4 30995057+git-yang@users.nor... sunxiaojian926@163.com
StandaloneConnectStartup.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime
 156 4 2022-05-24 2023-02-28 10 3 sunxiaojian926@163.com sunxiaojian926@163.com
DistributedConnectStartup.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime
 158 4 2022-05-24 2023-02-28 10 3 sunxiaojian926@163.com sunxiaojian926@163.com
AbstractConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 433 30 2022-07-28 2023-05-17 10 4 sunxiaojian926@163.com 877036922@qq.com
ReplicatorSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 647 22 2022-12-07 2023-05-17 10 4 lizhiboo@yeah.net 877036922@qq.com
FileSinkTask.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 61 1 2019-08-01 2022-06-22 9 4 877036922@qq.com sunxiaojian926@163.com
RebalanceService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 51 5 2019-08-21 2022-09-28 8 6 duhengforever@apache.org sunxiaojian926@163.com
AbstractConnectController.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller
 219 24 2022-05-24 2023-02-28 8 2 sunxiaojian926@163.com sunxiaojian926@163.com
WorkerConnector.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 286 24 2022-03-01 2023-02-28 8 3 877036922@qq.com sunxiaojian926@163.com
DefaultConnectorContext.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 40 3 2022-03-01 2022-09-28 7 3 877036922@qq.com sunxiaojian926@163.com
DefaultAllocateConnAndTaskStrategy.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy
 60 2 2019-08-21 2022-09-28 7 4 duhengforever@apache.org sunxiaojian926@163.com
FilePositionManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory
 140 12 2022-05-24 2023-02-28 7 3 sunxiaojian926@163.com sunxiaojian926@163.com
ConnectKeyValue.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common
 145 28 2022-03-01 2022-09-28 7 3 877036922@qq.com sunxiaojian926@163.com
RmqSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 209 10 2022-03-02 2022-09-28 7 5 877036922@qq.com yechun@corp.netease.com
Plugin.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation
 219 16 2022-07-28 2022-11-08 7 2 sunxiaojian926@163.com yechun@corp.netease.com
ReplicatorSourceConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 251 13 2022-12-07 2023-05-17 7 4 lizhiboo@yeah.net 877036922@qq.com
WorkerTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 253 31 2020-07-28 2022-09-28 7 4 affeisme@gmail.com sunxiaojian926@163.com
PluginUtils.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation
 263 12 2022-07-28 2023-03-24 7 2 sunxiaojian926@163.com 877036922@qq.com
WorkerConfig.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config
 381 91 2022-08-25 2023-04-20 7 4 sunxiaojian926@163.com 877036922@qq.com
package.xml
in rocketmq-connect-runtime/src/main/resources
 24 - 2019-08-13 2023-04-03 6 4 duhengforever@apache.org 877036922@qq.com
PositionStorageReaderImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store
 33 3 2022-03-01 2022-09-28 6 3 877036922@qq.com sunxiaojian926@163.com
ConnectorConfig.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config
 58 3 2022-08-25 2022-12-07 6 3 sunxiaojian926@163.com lizhiboo@yeah.net
DistributedConnectController.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/distributed
 74 3 2022-05-24 2022-09-28 6 2 sunxiaojian926@163.com sunxiaojian926@163.com
Utils.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 99 12 2022-06-22 2022-09-28 6 1 sunxiaojian926@163.com sunxiaojian926@163.com
logback.xml
in rocketmq-connect-runtime/src/main/resources
 174 - 2019-08-13 2023-03-24 6 2 877036922@qq.com 877036922@qq.com
WorkerSinkTaskContext.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 178 13 2022-04-01 2023-03-24 6 2 877036922@qq.com 877036922@qq.com
ConnectStatsManager.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats
 243 36 2022-04-01 2022-12-07 6 4 877036922@qq.com lizhiboo@yeah.net
ReplicatorConnectorConfig.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 522 104 2022-12-07 2023-05-17 6 4 lizhiboo@yeah.net 877036922@qq.com
StateManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 23 1 2022-08-24 2023-02-28 5 1 sunxiaojian926@163.com sunxiaojian926@163.com
JsonDeserializer.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization
 30 3 2022-06-28 2022-09-28 5 2 sunxiaojian926@163.com sunxiaojian926@163.com
StandaloneConnectController.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/standalone
 38 3 2022-05-24 2022-09-28 5 2 sunxiaojian926@163.com sunxiaojian926@163.com
MemoryClusterManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory
 40 9 2022-05-24 2023-02-28 5 2 sunxiaojian926@163.com sunxiaojian926@163.com
AbstractConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config
 68 10 2022-05-16 2023-05-15 5 1 sunxiaojian926@163.com sunxiaojian926@163.com
EventBridgeSinkConnector.java
in connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink
 68 7 2022-04-24 2022-06-02 5 2 wb-zh378814@alibaba-inc.com zhaohaihzb@126.com
FileBaseKeyValueStore.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store
 90 6 2022-03-01 2022-09-30 5 4 877036922@qq.com wqdyxnbd@163.com
EventBridgeSinkTask.java
in connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink
 112 7 2022-04-24 2022-06-02 5 1 wb-zh378814@alibaba-inc.com wb-zh378814@alibaba-inc.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
WorkerSourceTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 578 33 2019-08-16 2023-05-15 40 14 san@chenyiliu.com sunxiaojian926@163.com
Worker.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 739 44 2019-08-04 2023-04-21 44 13 877036922@qq.com 877036922@qq.com
WorkerSinkTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 671 36 2019-11-19 2022-12-26 30 13 877036922@qq.com ashen@moesrc.com
RestHandler.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest
 260 17 2019-08-05 2022-12-26 20 11 877036922@qq.com yechun@corp.netease.com
ConnectUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 398 24 2019-08-16 2023-04-14 20 9 san@chenyiliu.com 877036922@qq.com
WorkerDirectTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 198 21 2021-10-26 2022-11-03 18 9 30995057+git-yang@users.nor... yechun@corp.netease.com
RebalanceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 73 4 2019-08-21 2023-05-16 17 9 duhengforever@apache.org 877036922@qq.com
BrokerBasedLog.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync
 296 17 2019-08-16 2023-02-28 14 8 san@chenyiliu.com sunxiaojian926@163.com
FileSourceTask.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 212 4 2019-08-13 2023-04-04 11 8 877036922@qq.com clooker@163.com
ClusterManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 124 12 2019-08-13 2023-02-28 14 7 duhengforever@apache.org sunxiaojian926@163.com
ConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 29 1 2019-09-24 2023-02-28 14 6 zero.xu@bytedance.com sunxiaojian926@163.com
RebalanceService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 51 5 2019-08-21 2022-09-28 8 6 duhengforever@apache.org sunxiaojian926@163.com
TransformChain.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 107 6 2022-03-07 2022-09-28 11 5 877036922@qq.com sunxiaojian926@163.com
RmqSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 209 10 2022-03-02 2022-09-28 7 5 877036922@qq.com yechun@corp.netease.com
RmqSourceReplicator.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 245 13 2022-03-02 2023-04-06 5 5 877036922@qq.com jinrongtong5@163.com
MemoryConfigManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory
 141 16 2022-05-24 2023-02-28 12 4 sunxiaojian926@163.com sunxiaojian926@163.com
ReplicatorSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 647 22 2022-12-07 2023-05-17 10 4 lizhiboo@yeah.net 877036922@qq.com
AbstractConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 433 30 2022-07-28 2023-05-17 10 4 sunxiaojian926@163.com 877036922@qq.com
PositionManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 27 2 2021-03-27 2023-02-28 10 4 30995057+git-yang@users.nor... sunxiaojian926@163.com
ClusterManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 17 1 2019-08-21 2023-02-28 10 4 duhengforever@apache.org sunxiaojian926@163.com
FileSinkTask.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 61 1 2019-08-01 2022-06-22 9 4 877036922@qq.com sunxiaojian926@163.com
ReplicatorSourceConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 251 13 2022-12-07 2023-05-17 7 4 lizhiboo@yeah.net 877036922@qq.com
WorkerTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 253 31 2020-07-28 2022-09-28 7 4 affeisme@gmail.com sunxiaojian926@163.com
WorkerConfig.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config
 381 91 2022-08-25 2023-04-20 7 4 sunxiaojian926@163.com 877036922@qq.com
DefaultAllocateConnAndTaskStrategy.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy
 60 2 2019-08-21 2022-09-28 7 4 duhengforever@apache.org sunxiaojian926@163.com
ReplicatorConnectorConfig.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 522 104 2022-12-07 2023-05-17 6 4 lizhiboo@yeah.net 877036922@qq.com
package.xml
in rocketmq-connect-runtime/src/main/resources
 24 - 2019-08-13 2023-04-03 6 4 duhengforever@apache.org 877036922@qq.com
ConnectStatsManager.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats
 243 36 2022-04-01 2022-12-07 6 4 877036922@qq.com lizhiboo@yeah.net
FileBaseKeyValueStore.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store
 90 6 2022-03-01 2022-09-30 5 4 877036922@qq.com wqdyxnbd@163.com
RmqMetaReplicator.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 215 15 2022-03-02 2022-07-14 4 4 877036922@qq.com sunxiaojian926@163.com
MetaSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 96 3 2022-03-02 2022-07-14 4 4 877036922@qq.com sunxiaojian926@163.com
StandaloneConnectStartup.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime
 156 4 2022-05-24 2023-02-28 10 3 sunxiaojian926@163.com sunxiaojian926@163.com
DistributedConnectStartup.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime
 158 4 2022-05-24 2023-02-28 10 3 sunxiaojian926@163.com sunxiaojian926@163.com
WorkerConnector.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 286 24 2022-03-01 2023-02-28 8 3 877036922@qq.com sunxiaojian926@163.com
ConnectKeyValue.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common
 145 28 2022-03-01 2022-09-28 7 3 877036922@qq.com sunxiaojian926@163.com
FilePositionManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory
 140 12 2022-05-24 2023-02-28 7 3 sunxiaojian926@163.com sunxiaojian926@163.com
DefaultConnectorContext.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 40 3 2022-03-01 2022-09-28 7 3 877036922@qq.com sunxiaojian926@163.com
ConnectorConfig.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config
 58 3 2022-08-25 2022-12-07 6 3 sunxiaojian926@163.com lizhiboo@yeah.net
PositionStorageReaderImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store
 33 3 2022-03-01 2022-09-28 6 3 877036922@qq.com sunxiaojian926@163.com
DelegatingClassLoader.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation
 358 19 2022-08-12 2022-12-27 5 3 sunxiaojian926@163.com 877036922@qq.com
RedisSourceConnector.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector
 32 1 2022-03-02 2022-09-22 4 3 877036922@qq.com wqdyxnbd@163.com
ReplicatorHeartbeatConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 69 5 2022-12-07 2023-05-17 4 3 lizhiboo@yeah.net 877036922@qq.com
Utils.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common
 180 13 2022-03-02 2022-05-17 4 3 877036922@qq.com zhangjidi_yewu@cmss.chinamo...
AllocateConnAndTaskStrategy.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy
 9 - 2019-08-21 2022-09-28 4 3 duhengforever@apache.org sunxiaojian926@163.com
AllocateConnAndTaskStrategyByConsistentHash.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy
 74 5 2019-10-22 2022-09-28 4 3 zero.xu@bytedance.com sunxiaojian926@163.com
MemoryBasedKeyValueStore.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store
 48 11 2020-07-28 2022-09-28 4 3 affeisme@gmail.com sunxiaojian926@163.com
FileSourceConnector.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 32 - 2022-03-01 2022-06-22 4 3 877036922@qq.com sunxiaojian926@163.com
FileSinkConnector.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 32 1 2022-03-01 2022-06-22 4 3 877036922@qq.com sunxiaojian926@163.com
DingTalkSinkTask.java
in connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink
 63 6 2022-04-15 2022-12-23 3 3 33314633+zhaohai1299002788@... amboochou@gmail.com
TaskDivideConfig.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 70 17 2022-03-02 2022-05-11 3 3 877036922@qq.com 649518322@qq.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
JsonSchemaData.java
in schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json
 901 13 2022-11-07 2022-11-07 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
GenericDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 828 42 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
DefaultColumnConverter.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter
 366 8 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
KafkaSinkSchemaConverter.java
in connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema
 297 5 2022-06-22 2022-07-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
RocketMQSourceSchemaConverter.java
in connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema
 295 5 2022-06-22 2022-07-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
User.java
in connectors/rocketmq-connect-deltalake/src/main/java/example/avro
 287 37 2022-09-19 2022-09-19 1 1 lizhiboo@yeah.net lizhiboo@yeah.net
AbstractStateManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 285 22 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
RocketMqDatabaseHistory.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium
 269 10 2022-06-22 2023-01-31 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
ExpressionBuilder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util
 266 40 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
SourceOffsetCompute.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset
 261 5 2022-05-16 2023-05-15 5 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceTask.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 250 11 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ExpressionBuilder.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/util
 247 36 2022-10-11 2022-10-11 1 1 871958943@qq.com 871958943@qq.com
DorisSinkConfig.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector
 247 23 2022-10-11 2022-10-11 1 1 871958943@qq.com 871958943@qq.com
FieldsMetadata.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata
 244 7 2022-10-11 2022-10-11 1 1 871958943@qq.com 871958943@qq.com
FieldsMetadata.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata
 244 7 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
DatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 230 16 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
TimestampIncrementingCriteria.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 226 17 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
DbStructure.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 221 7 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
KafkaSourceTask.java
in connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector
 201 11 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
OkHttpUtils.java
in connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common
 200 15 2022-04-15 2022-04-15 1 1 33314633+zhaohai1299002788@... 33314633+zhaohai1299002788@...
RetryWithToleranceOperator.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors
 200 19 2022-06-22 2022-09-28 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
TimestampIncrementingQuerier.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier
 192 10 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
AbstractPositionManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 190 17 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
DeltalakeWriterOnHdfs.java
in connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/writer
 186 6 2022-09-19 2022-09-19 1 1 lizhiboo@yeah.net lizhiboo@yeah.net
BufferedRecords.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink
 182 6 2022-10-11 2022-10-11 1 1 871958943@qq.com 871958943@qq.com
RocketMqAdminUtil.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium
 182 10 2023-01-31 2023-01-31 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
RecordOffsetManagement.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 179 21 2022-07-28 2023-02-28 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 178 23 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ElasticsearchSinkTask.java
in connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector
 176 6 2022-11-24 2022-11-24 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
RocketMqSignalThread.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/signal
 175 7 2022-10-26 2023-01-31 2 1 sunxiaojian926@163.com sunxiaojian926@163.com
DefaultJdbcRecordBinder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder
 170 6 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
AvroSchemaUtils.java
in schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/util
 167 11 2022-11-07 2022-11-07 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
MySqlReadOnlyIncrementalSnapshotChangeEventSource.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql
 166 17 2022-10-26 2022-10-26 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSinkConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 166 18 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ColumnDefinition.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column
 163 23 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
DeadLetterQueueReporter.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors
 162 4 2022-06-22 2022-09-28 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
ColumnDefinition.java
in connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column
 149 21 2022-10-11 2022-10-11 1 1 871958943@qq.com 871958943@qq.com
BufferedRecords.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 148 7 2022-05-16 2023-05-15 5 1 sunxiaojian926@163.com sunxiaojian926@163.com
AvroDatumReaderFactory.java
in schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde
 145 7 2022-11-07 2022-11-07 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
AbstractLocalSchemaRegistryClient.java
in schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common
 136 9 2022-11-07 2022-11-07 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
BaseTransformation.java
in transforms/src/main/java/org/apache/rocketmq/connect/transforms
 136 19 2022-08-03 2022-08-03 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
LocalStateManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local
 132 9 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ElasticsearchQuery.java
in connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/replicator/source
 129 5 2022-10-31 2022-11-24 3 1 wqdyxnbd@163.com wqdyxnbd@163.com
ConnectMetricsTemplates.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics
 128 12 2022-09-28 2022-09-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
rmq_codeStyle.xml
in connectors/rocketmq-connect-redis/style
 126 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
Converters.java
in connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema
 126 8 2022-06-22 2023-01-31 5 1 sunxiaojian926@163.com sunxiaojian926@163.com
RetryUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 123 8 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ConfigKeyInfo.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities
 121 15 2022-08-12 2022-09-28 2 1 sunxiaojian926@163.com sunxiaojian926@163.com
MySqlReadOnlyIncrementalSnapshotContext.java
in connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql
 120 16 2022-10-26 2022-10-26 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ElasticsearchSourceTask.java
in connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector
 120 10 2022-10-31 2022-11-24 2 1 wqdyxnbd@163.com wqdyxnbd@163.com
Correlations

File Size vs. Number of Changes: 793 points

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointConnector.java x: 151 lines of code y: 4 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointTask.java x: 247 lines of code y: 5 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java x: 69 lines of code y: 4 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java x: 213 lines of code y: 3 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java x: 251 lines of code y: 7 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java x: 647 lines of code y: 10 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java x: 6 lines of code y: 1 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java x: 522 lines of code y: 6 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java x: 95 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java x: 433 lines of code y: 10 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceImpl.java x: 73 lines of code y: 17 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java x: 111 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/DefaultJdbcRecordBinder.java x: 170 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/HeaderField.java x: 5 lines of code y: 2 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java x: 19 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java x: 68 lines of code y: 5 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/CachedConnectionProvider.java x: 89 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java x: 9 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/DefaultColumnConverter.java x: 366 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java x: 230 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectFactory.java x: 7 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectLoader.java x: 87 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java x: 828 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/mysql/MysqlDatabaseDialectFactory.java x: 15 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb/OpenMLDBDatabaseDialect.java x: 96 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/exception/ConfigException.java x: 13 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/exception/TableAlterOrCreateException.java x: 10 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java x: 163 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java x: 72 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinition.java x: 88 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java x: 45 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java x: 113 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java x: 148 lines of code y: 5 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/DbStructure.java x: 221 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConfig.java x: 166 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConnector.java x: 36 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkTask.java x: 78 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java x: 68 lines of code y: 2 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java x: 244 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SchemaPair.java x: 38 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java x: 59 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConfig.java x: 178 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConnector.java x: 55 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceTask.java x: 250 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingCriteria.java x: 226 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/ColumnMapping.java x: 52 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/IncrementContext.java x: 63 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/QueryContext.java x: 73 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/TableLoadMode.java x: 25 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java x: 261 lines of code y: 5 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java x: 78 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/BulkQuerier.java x: 100 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/Querier.java x: 97 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java x: 192 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/BytesUtil.java x: 12 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ColumnDefAdjuster.java x: 48 lines of code y: 1 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ConnectorGroupUtils.java x: 27 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java x: 266 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java x: 93 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcDriverInfo.java x: 63 lines of code y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/NumericMapping.java x: 29 lines of code y: 4 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/TableType.java x: 40 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java x: 578 lines of code y: 40 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtil.java x: 104 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java x: 739 lines of code y: 44 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java x: 381 lines of code y: 7 # changes metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQClientUtil.java x: 122 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java x: 398 lines of code y: 20 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java x: 245 lines of code y: 5 # changes rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java x: 212 lines of code y: 11 # changes rocketmq-connect-cli/src/main/resources/package.xml x: 24 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/resources/package.xml x: 24 lines of code y: 6 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/context/UnAckMessage.java x: 38 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTaskContext.java x: 178 lines of code y: 6 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTaskContext.java x: 33 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginUtils.java x: 263 lines of code y: 7 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginWrapper.java x: 81 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/resources/logback.xml x: 174 lines of code y: 6 # changes connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceConnector.java x: 62 lines of code y: 1 # changes connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/connector/IotdbSourceTask.java x: 101 lines of code y: 1 # changes schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java x: 2028 lines of code y: 2 # changes metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQScheduledReporter.java x: 109 lines of code y: 1 # changes metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/stats/Avg.java x: 27 lines of code y: 1 # changes metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/stats/Value.java x: 31 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/DistributedConnectStartup.java x: 158 lines of code y: 10 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/StandaloneConnectStartup.java x: 156 lines of code y: 10 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/RecordOffsetManagement.java x: 179 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TargetState.java x: 5 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnector.java x: 286 lines of code y: 8 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/AbstractConnectController.java x: 219 lines of code y: 8 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractPositionManagementService.java x: 190 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractStateManagementService.java x: 285 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementService.java x: 17 lines of code y: 10 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementServiceImpl.java x: 124 lines of code y: 14 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java x: 29 lines of code y: 14 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/IChangeNotifier.java x: 13 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/PositionManagementService.java x: 27 lines of code y: 10 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/StateManagementService.java x: 23 lines of code y: 5 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalPositionManagementServiceImpl.java x: 81 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalStateManagementServiceImpl.java x: 132 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/FilePositionManagementServiceImpl.java x: 140 lines of code y: 7 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryClusterManagementServiceImpl.java x: 40 lines of code y: 5 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java x: 141 lines of code y: 12 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryStateManagementServiceImpl.java x: 72 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/RetryUtil.java x: 123 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java x: 296 lines of code y: 14 # changes connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/config/SchemaManger.java x: 21 lines of code y: 1 # changes connectors/rocketmq-connect-hive/src/main/java/org/apache/rocketmq/connect/hive/connector/HiveSourceTask.java x: 104 lines of code y: 1 # changes connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqAdminUtil.java x: 182 lines of code y: 1 # changes connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-core/src/main/java/org/apache/rocketmq/connect/debezium/RocketMqDatabaseHistory.java x: 269 lines of code y: 3 # changes connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/signal/RocketMqSignalThread.java x: 175 lines of code y: 2 # changes connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/Converters.java x: 126 lines of code y: 5 # changes connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java x: 205 lines of code y: 2 # changes connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnector.java x: 50 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/DelegatingClassLoader.java x: 358 lines of code y: 5 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java x: 260 lines of code y: 20 # changes connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/HttpSinkTask.java x: 33 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java x: 671 lines of code y: 30 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonConverterConfig.java x: 43 lines of code y: 3 # changes connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/resources/debezium-mysql-source-config.yaml x: 30 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/ConnectorConfig.java x: 58 lines of code y: 6 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsManager.java x: 243 lines of code y: 6 # changes connectors/rocketmq-connect-sftp/src/main/java/org/apache/rocketmq/connect/http/sink/SftpSourceTask.java x: 117 lines of code y: 1 # changes connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/source/Replicator.java x: 76 lines of code y: 1 # changes connectors/rocketmq-connect-mqtt/src/main/java/org/apache/rocketmq/connect/mqtt/util/ConfigUtil.java x: 46 lines of code y: 1 # changes connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConfig.java x: 110 lines of code y: 2 # changes connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/config/ElasticsearchConstant.java x: 14 lines of code y: 2 # changes connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSinkConnector.java x: 41 lines of code y: 1 # changes connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/connector/ElasticsearchSourceTask.java x: 120 lines of code y: 2 # changes connectors/rocketmq-connect-elasticsearch/src/main/java/org/apache/rocketmq/connect/elasticsearch/replicator/source/ElasticsearchQuery.java x: 129 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/Plugin.java x: 219 lines of code y: 7 # changes schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/serde/AvroDatumReaderFactory.java x: 145 lines of code y: 1 # changes schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchemaData.java x: 901 lines of code y: 1 # changes schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/AbstractLocalSchemaRegistryClient.java x: 136 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java x: 198 lines of code y: 18 # changes connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/Config.java x: 127 lines of code y: 3 # changes connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java x: 153 lines of code y: 3 # changes connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java x: 16 lines of code y: 2 # changes connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceTask.java x: 20 lines of code y: 2 # changes connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/pattern/RabbitMQPatternProcessor.java x: 22 lines of code y: 2 # changes connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mysql/src/main/java/io/debezium/connector/mysql/MySqlReadOnlyIncrementalSnapshotContext.java x: 120 lines of code y: 1 # changes connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/connector/DorisSinkConfig.java x: 247 lines of code y: 1 # changes connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/schema/column/ColumnDefinition.java x: 149 lines of code y: 1 # changes connectors/rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris/sink/metadata/FieldsMetadata.java x: 244 lines of code y: 1 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common/ConstDefine.java x: 8 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java x: 199 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/ConfigUtil.java x: 46 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/DbConnectorConfig.java x: 70 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/SourceDbConnectorConfig.java x: 52 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkConnector.java x: 177 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSinkTask.java x: 79 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceConnector.java x: 62 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java x: 167 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Database.java x: 86 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/Schema.java x: 81 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/sink/Updater.java x: 164 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java x: 138 lines of code y: 2 # changes connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy/DivideTaskByTopic.java x: 94 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ErrorMetricsGroup.java x: 65 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/ConnectMetrics.java x: 88 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/MetricGroup.java x: 30 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/FileBaseKeyValueStore.java x: 90 lines of code y: 5 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnAndTaskConfigs.java x: 27 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java x: 145 lines of code y: 7 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/SinkConnectorConfig.java x: 52 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/SourceTaskOffsetCommitter.java x: 76 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TransformChain.java x: 107 lines of code y: 11 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerTask.java x: 253 lines of code y: 7 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/distributed/DistributedConnectController.java x: 74 lines of code y: 6 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginClassLoader.java x: 50 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonConverter.java x: 664 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/ProcessingContext.java x: 115 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/RetryWithToleranceOperator.java x: 200 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/metrics/ConnectMetricsTemplates.java x: 128 lines of code y: 1 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/ConnectorInfo.java x: 57 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/CreateConnectorRequest.java x: 37 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/entities/PluginInfo.java x: 54 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/JsonDeserializer.java x: 30 lines of code y: 5 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/Serdes.java x: 105 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/serialization/store/RecordPositionMapSerde.java x: 15 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/DefaultConnectorContext.java x: 40 lines of code y: 7 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceService.java x: 51 lines of code y: 8 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategy.java x: 9 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/DefaultAllocateConnAndTaskStrategy.java x: 60 lines of code y: 7 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java x: 267 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/ClusterConfigState.java x: 98 lines of code y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/MemoryBasedKeyValueStore.java x: 48 lines of code y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/PositionStorageReaderImpl.java x: 33 lines of code y: 6 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectorTaskId.java x: 58 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/TransferUtils.java x: 84 lines of code y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java x: 99 lines of code y: 6 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java x: 209 lines of code y: 7 # changes connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java x: 212 lines of code y: 2 # changes connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java x: 74 lines of code y: 2 # changes connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java x: 116 lines of code y: 2 # changes connectors/rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceTask.java x: 149 lines of code y: 2 # changes connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java x: 155 lines of code y: 2 # changes connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java x: 32 lines of code y: 4 # changes connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java x: 101 lines of code y: 2 # changes connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java x: 360 lines of code y: 2 # changes connectors/rocketmq-connect-deltalake/src/main/java/example/avro/User.java x: 287 lines of code y: 1 # changes connectors/rocketmq-connect-deltalake/src/main/java/org/apache/rocketmq/connect/deltalake/writer/DeltalakeWriterOnHdfs.java x: 186 lines of code y: 1 # changes transforms/src/main/java/org/apache/rocketmq/connect/transforms/SetNull.java x: 41 lines of code y: 2 # changes connectors/rocketmq-connect-hudi/src/main/java/org/apache/rocketmq/connect/hudi/sink/Updater.java x: 222 lines of code y: 3 # changes connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkValueConverter.java x: 97 lines of code y: 3 # changes connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkSchemaConverter.java x: 297 lines of code y: 3 # changes connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/RocketMQSourceSchemaConverter.java x: 295 lines of code y: 3 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java x: 215 lines of code y: 4 # changes rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSinkTask.java x: 61 lines of code y: 9 # changes connectors/rocketmq-connect-debezium/rocketmq-connect-debezium-mongodb/src/main/resources/debezium-mongodb-source-config.yaml x: 1 lines of code y: 1 # changes distribution/conf/logback.xml x: 95 lines of code y: 1 # changes connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/EventBridgeSinkTask.java x: 112 lines of code y: 5 # changes connectors/aliyun/rocketmq-connect-eventbridge/src/main/java/org/apache/rocketmq/connect/eventbridge/sink/constant/EventBridgeConstant.java x: 15 lines of code y: 4 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java x: 180 lines of code y: 4 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java x: 121 lines of code y: 3 # changes connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/common/OkHttpUtils.java x: 200 lines of code y: 1 # changes connectors/rocketmq-connect-kafka/src/main/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceConnector.java x: 69 lines of code y: 1 # changes rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/ConnectAdminStartup.java x: 146 lines of code y: 2 # changes style/rmq_codeStyle.xml x: 126 lines of code y: 2 # changes
44.0
# changes
  min: 1.0
  average: 2.17
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 44.0
0 2028.0
lines of code
min: 1.0 | average: 68.73 | 25th percentile: 16.0 | median: 37.0 | 75th percentile: 84.0 | max: 2028.0

Number of Contributors vs. Number of Changes: 793 points

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointConnector.java x: 2 # contributors y: 4 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointTask.java x: 2 # contributors y: 5 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java x: 3 # contributors y: 4 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java x: 3 # contributors y: 3 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java x: 4 # contributors y: 7 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java x: 4 # contributors y: 10 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java x: 1 # contributors y: 1 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java x: 4 # contributors y: 6 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceImpl.java x: 9 # contributors y: 17 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/HeaderField.java x: 1 # contributors y: 2 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java x: 1 # contributors y: 3 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java x: 1 # contributors y: 5 # changes connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java x: 1 # contributors y: 4 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java x: 14 # contributors y: 40 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java x: 13 # contributors y: 44 # changes metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQClientUtil.java x: 2 # contributors y: 2 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java x: 9 # contributors y: 20 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java x: 5 # contributors y: 5 # changes rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java x: 8 # contributors y: 11 # changes rocketmq-connect-cli/src/main/resources/package.xml x: 2 # contributors y: 3 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTaskContext.java x: 2 # contributors y: 6 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginUtils.java x: 2 # contributors y: 7 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/DistributedConnectStartup.java x: 3 # contributors y: 10 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnector.java x: 3 # contributors y: 8 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/AbstractConnectController.java x: 2 # contributors y: 8 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementServiceImpl.java x: 7 # contributors y: 14 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java x: 6 # contributors y: 14 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/FilePositionManagementServiceImpl.java x: 3 # contributors y: 7 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java x: 4 # contributors y: 12 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java x: 8 # contributors y: 14 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/DelegatingClassLoader.java x: 3 # contributors y: 5 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java x: 11 # contributors y: 20 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java x: 13 # contributors y: 30 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/ConnectorConfig.java x: 3 # contributors y: 6 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java x: 9 # contributors y: 18 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/FileBaseKeyValueStore.java x: 4 # contributors y: 5 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TransformChain.java x: 5 # contributors y: 11 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceService.java x: 6 # contributors y: 8 # changes rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/Utils.java x: 1 # contributors y: 6 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java x: 5 # contributors y: 7 # changes connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java x: 4 # contributors y: 4 # changes rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSinkTask.java x: 4 # contributors y: 9 # changes distribution/conf/logback.xml x: 2 # contributors y: 1 # changes
44.0
# changes
  min: 1.0
  average: 2.17
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 44.0
0 14.0
# contributors
min: 1.0 | average: 1.5 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 14.0

Number of Contributors vs. File Size: 793 points

connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointConnector.java x: 2 # contributors y: 151 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorCheckpointTask.java x: 2 # contributors y: 247 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatConnector.java x: 3 # contributors y: 69 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorHeartbeatTask.java x: 3 # contributors y: 213 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceConnector.java x: 4 # contributors y: 251 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/ReplicatorSourceTask.java x: 4 # contributors y: 647 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/LoggerName.java x: 1 # contributors y: 6 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/ReplicatorConnectorConfig.java x: 4 # contributors y: 522 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils/ReplicatorUtils.java x: 2 # contributors y: 95 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractConfigManagementService.java x: 4 # contributors y: 433 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceImpl.java x: 9 # contributors y: 73 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/AbstractJdbcRecordBinder.java x: 1 # contributors y: 111 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder/DefaultJdbcRecordBinder.java x: 1 # contributors y: 170 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DebeziumTimeTypes.java x: 2 # contributors y: 67 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java x: 1 # contributors y: 19 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java x: 1 # contributors y: 68 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/CachedConnectionProvider.java x: 1 # contributors y: 89 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection/ConnectionProvider.java x: 1 # contributors y: 9 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter/DefaultColumnConverter.java x: 1 # contributors y: 366 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java x: 1 # contributors y: 230 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectLoader.java x: 1 # contributors y: 87 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/GenericDatabaseDialect.java x: 1 # contributors y: 828 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb/OpenMLDBDatabaseDialect.java x: 1 # contributors y: 96 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java x: 1 # contributors y: 163 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java x: 1 # contributors y: 72 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java x: 1 # contributors y: 45 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java x: 1 # contributors y: 113 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java x: 1 # contributors y: 148 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/DbStructure.java x: 1 # contributors y: 221 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcSinkConnector.java x: 1 # contributors y: 36 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java x: 1 # contributors y: 244 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java x: 1 # contributors y: 59 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConfig.java x: 1 # contributors y: 178 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceConnector.java x: 1 # contributors y: 55 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/JdbcSourceTask.java x: 1 # contributors y: 250 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common/TableLoadMode.java x: 1 # contributors y: 25 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java x: 1 # contributors y: 261 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java x: 2 # contributors y: 78 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java x: 1 # contributors y: 192 lines of code connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java x: 1 # contributors y: 266 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTask.java x: 14 # contributors y: 578 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/FileAndPropertyUtil.java x: 2 # contributors y: 104 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/Worker.java x: 13 # contributors y: 739 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/config/WorkerConfig.java x: 4 # contributors y: 381 lines of code metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/reporter/RocketMQClientUtil.java x: 2 # contributors y: 122 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ConnectUtil.java x: 9 # contributors y: 398 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceReplicator.java x: 5 # contributors y: 245 lines of code rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FileSourceTask.java x: 8 # contributors y: 212 lines of code rocketmq-connect-cli/src/main/resources/package.xml x: 2 # contributors y: 24 lines of code rocketmq-connect-runtime/src/main/resources/package.xml x: 4 # contributors y: 24 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTaskContext.java x: 2 # contributors y: 178 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSourceTaskContext.java x: 2 # contributors y: 33 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginUtils.java x: 2 # contributors y: 263 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/PluginWrapper.java x: 2 # contributors y: 81 lines of code rocketmq-connect-runtime/src/main/resources/logback.xml x: 2 # contributors y: 174 lines of code schema-converter/avro-schema-converter/src/main/java/org/apache/rocketmq/schema/avro/AvroData.java x: 2 # contributors y: 2028 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/DistributedConnectStartup.java x: 3 # contributors y: 158 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerConnector.java x: 3 # contributors y: 286 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/AbstractConnectController.java x: 2 # contributors y: 219 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractPositionManagementService.java x: 1 # contributors y: 190 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/AbstractStateManagementService.java x: 1 # contributors y: 285 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementService.java x: 4 # contributors y: 17 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ClusterManagementServiceImpl.java x: 7 # contributors y: 124 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/ConfigManagementService.java x: 6 # contributors y: 29 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local/LocalStateManagementServiceImpl.java x: 1 # contributors y: 132 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/FilePositionManagementServiceImpl.java x: 3 # contributors y: 140 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryClusterManagementServiceImpl.java x: 2 # contributors y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/memory/MemoryConfigManagementServiceImpl.java x: 4 # contributors y: 141 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/RetryUtil.java x: 1 # contributors y: 123 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/ServiceProviderUtil.java x: 2 # contributors y: 100 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/BrokerBasedLog.java x: 8 # contributors y: 296 lines of code connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/common/OkHttpUtils.java x: 2 # contributors y: 205 lines of code connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkConnector.java x: 2 # contributors y: 50 lines of code connectors/aliyun/rocketmq-connect-dingtalk/src/main/java/org/apache/rocketmq/connect/dingtalk/sink/DingTalkSinkTask.java x: 3 # contributors y: 63 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/controller/isolation/DelegatingClassLoader.java x: 3 # contributors y: 358 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest/RestHandler.java x: 11 # contributors y: 260 lines of code connectors/rocketmq-connect-http/src/main/java/org/apache/rocketmq/connect/http/sink/HttpSinkTask.java x: 3 # contributors y: 33 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerSinkTask.java x: 13 # contributors y: 671 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsManager.java x: 4 # contributors y: 243 lines of code schema-converter/json-schema-converter/src/main/java/org/apache/rocketmq/schema/json/JsonSchemaData.java x: 1 # contributors y: 901 lines of code schema-converter/schema-converter-common/src/main/java/org/apache/rocketmq/schema/common/AbstractLocalSchemaRegistryClient.java x: 1 # contributors y: 136 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/WorkerDirectTask.java x: 9 # contributors y: 198 lines of code connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/connector/BaseJmsSourceTask.java x: 2 # contributors y: 153 lines of code connectors/rocketmq-connect-jms/src/main/java/org/apache/rocketmq/connect/jms/pattern/PatternProcessor.java x: 2 # contributors y: 61 lines of code connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/RabbitmqConfig.java x: 2 # contributors y: 16 lines of code connectors/rocketmq-connect-rabbitmq/src/main/java/org/apache/rocketmq/connect/rabbitmq/connector/RabbitmqSourceConnector.java x: 2 # contributors y: 15 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/config/Config.java x: 2 # contributors y: 199 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/connector/CassandraSourceTask.java x: 2 # contributors y: 167 lines of code connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/source/Querier.java x: 2 # contributors y: 138 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/FileBaseKeyValueStore.java x: 4 # contributors y: 90 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/common/ConnectKeyValue.java x: 3 # contributors y: 145 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper/TransformChain.java x: 5 # contributors y: 107 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/converter/record/json/JsonConverter.java x: 2 # contributors y: 664 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/errors/RetryWithToleranceOperator.java x: 1 # contributors y: 200 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/DefaultConnectorContext.java x: 3 # contributors y: 40 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/RebalanceService.java x: 6 # contributors y: 51 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategy.java x: 3 # contributors y: 9 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/AllocateConnAndTaskStrategyByConsistentHash.java x: 3 # contributors y: 74 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy/DefaultAllocateConnAndTaskStrategy.java x: 4 # contributors y: 60 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/stats/ConnectStatsService.java x: 2 # contributors y: 267 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store/MemoryBasedKeyValueStore.java x: 3 # contributors y: 48 lines of code rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync/DataSynchronizerCallback.java x: 2 # contributors y: 4 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqSourceTask.java x: 5 # contributors y: 209 lines of code connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java x: 2 # contributors y: 212 lines of code connectors/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java x: 2 # contributors y: 116 lines of code connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java x: 2 # contributors y: 360 lines of code rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file/FilterTransform.java x: 3 # contributors y: 25 lines of code connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/KafkaSinkSchemaConverter.java x: 1 # contributors y: 297 lines of code connectors/rocketmq-connect-debezium/kafka-connect-adaptor/src/main/java/org/apache/rocketmq/connect/kafka/connect/adaptor/schema/RocketMQSourceSchemaConverter.java x: 1 # contributors y: 295 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/MetaSourceTask.java x: 4 # contributors y: 96 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/RmqMetaReplicator.java x: 4 # contributors y: 215 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common/Utils.java x: 3 # contributors y: 180 lines of code connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config/RmqConnectorConfig.java x: 3 # contributors y: 121 lines of code style/rmq_checkstyle.xml x: 3 # contributors y: 91 lines of code
2028.0
lines of code
  min: 1.0
  average: 68.73
  25th percentile: 16.0
  median: 37.0
  75th percentile: 84.0
  max: 2028.0
0 14.0
# contributors
min: 1.0 | average: 1.5 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 14.0