Places in code with 6 or more lines that are exactly the same.
From Component --> To Component |
Duplicated Lines |
File Pairs | Details |
---|---|---|---|
broker (<1%)   --> client (1%) |
399 | 13 file pairs | details... |
broker (<1%)   --> proxy (1%) |
382 | 12 file pairs | details... |
broker (<1%)   --> remoting (1%) |
306 | 30 file pairs | details... |
client (<1%)   --> remoting (1%) |
264 | 29 file pairs | details... |
broker (<1%)   --> store (<1%) |
252 | 6 file pairs | details... |
common (1%)   --> remoting (<1%) |
239 | 27 file pairs | details... |
broker (<1%)   --> container (11%) |
227 | 8 file pairs | details... |
common (1%)   --> proxy (<1%) |
211 | 8 file pairs | details... |
proxy (<1%)   --> remoting (<1%) |
204 | 29 file pairs | details... |
controller (2%)   --> namesrv (4%) |
176 | 4 file pairs | details... |
common (<1%)   --> store (<1%) |
151 | 6 file pairs | details... |
broker (<1%)   --> controller (2%) |
135 | 3 file pairs | details... |
client (<1%)   --> proxy (<1%) |
132 | 5 file pairs | details... |
broker (<1%)   --> common (<1%) |
116 | 10 file pairs | details... |
remoting (<1%)   --> tools (<1%) |
116 | 19 file pairs | details... |
broker (<1%)   --> namesrv (2%) |
97 | 2 file pairs | details... |
client (<1%)   --> common (<1%) |
90 | 13 file pairs | details... |
remoting (<1%)   --> store (<1%) |
82 | 7 file pairs | details... |
namesrv (1%)   --> proxy (<1%) |
67 | 2 file pairs | details... |
broker (<1%)   --> tools (<1%) |
66 | 4 file pairs | details... |
remoting (<1%)   --> tieredstore (<1%) |
60 | 4 file pairs | details... |
Size | # | Folders | Files | Lines | Code |
---|---|---|---|---|---|
56 | x 2 | broker/src/main/java/org...etmq/broker/transactionstore/src/main/java/org/...he/rocketmq/store/timer | 171:255 (40%)225:309 (32%) | view | |
53 | x 2 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumer | 115:187 (14%)107:179 (22%) | view | |
44 | x 2 | common/src/main/java/org/apache/rocketmq/commonproxy/src/main/java/org/...e/rocketmq/proxy/config | 232:317 (28%)1212:1297 (5%) | view | |
42 | x 2 | common/src/main/java/org...e/rocketmq/common/statscommon/src/main/java/org...e/rocketmq/common/stats | 93:150 (28%)48:105 (26%) | view | |
31 | x 2 | broker/src/main/java/org...cketmq/broker/processorbroker/src/main/java/org...cketmq/broker/processor | 89:130 (24%)66:106 (54%) | view | |
31 | x 2 | tools/src/main/java/org/.../tools/command/consumertools/src/main/java/org/.../tools/command/consumer | 109:151 (35%)93:135 (42%) | view | |
29 | x 2 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumer | 137:173 (9%)121:157 (9%) | view | |
29 | x 2 | tools/src/main/java/org/...cketmq/tools/command/hatools/src/main/java/org/...cketmq/tools/command/ha | 57:99 (40%)54:96 (35%) | view | |
29 | x 2 | common/src/main/java/org/apache/rocketmq/commoncommon/src/main/java/org...etmq/common/compression | 364:400 (6%)60:96 (54%) | view | |
29 | x 2 | tools/src/main/java/org/...etmq/tools/command/authtools/src/main/java/org/...etmq/tools/command/auth | 78:120 (38%)78:120 (38%) | view | |
28 | x 2 | remoting/src/main/java/o.../remoting/protocol/bodyremoting/src/main/java/o.../remoting/protocol/body | 27:71 (96%)27:71 (96%) | view | |
28 | x 2 | client/src/main/java/org...q/client/consumer/storeclient/src/main/java/org...q/client/consumer/store | 77:116 (16%)58:97 (19%) | view | |
28 | x 2 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumer | 347:387 (7%)262:302 (11%) | view | |
28 | x 2 | filter/src/main/java/org.../rocketmq/filter/parserfilter/src/main/java/org.../rocketmq/filter/parser | 161:188 (34%)69:96 (77%) | view | |
27 | x 2 | remoting/src/main/java/o...protocol/header/namesrvremoting/src/main/java/o...protocol/header/namesrv | 31:75 (93%)34:77 (93%) | view | |
24 | x 2 | remoting/src/main/java/o...emoting/protocol/headerremoting/src/main/java/o...emoting/protocol/header | 58:97 (53%)71:113 (46%) | view | |
24 | x 2 | client/src/main/java/org...he/rocketmq/client/hookclient/src/main/java/org...he/rocketmq/client/hook | 44:89 (42%)66:111 (36%) | view | |
23 | x 2 | broker/src/main/java/org...cketmq/broker/pagecachebroker/src/main/java/org...cketmq/broker/pagecache | 73:111 (42%)73:111 (42%) | view | |
23 | x 2 | controller/src/main/java...mq/controller/processornamesrv/src/main/java/or...ketmq/namesrv/processor | 269:297 (11%)616:644 (5%) | view | |
22 | x 2 | tools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...cketmq/tools/command/ha | 64:95 (33%)66:97 (27%) | view | |
22 | x 2 | auth/src/main/java/org/a...h/authorization/managerauth/src/main/java/org/a...h/authorization/manager | 65:96 (13%)98:129 (13%) | view | |
22 | x 2 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumer | 192:219 (7%)181:208 (7%) | view | |
21 | x 2 | tools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...cketmq/tools/command/ha | 64:94 (32%)69:99 (29%) | view | |
21 | x 2 | broker/src/main/java/org...cketmq/broker/processorproxy/src/main/java/org/...proxy/remoting/activity | 1703:1730 (<1%)100:127 (21%) | view | |
21 | x 2 | store/src/main/java/org/apache/rocketmq/storestore/src/main/java/org/...he/rocketmq/store/queue | 885:914 (2%)315:344 (2%) | view | |
21 | x 2 | remoting/src/main/java/o...emoting/protocol/headerremoting/src/main/java/o...emoting/protocol/header | 34:54 (23%)38:58 (16%) | view | |
20 | x 2 | broker/src/main/java/org...cketmq/broker/pagecachebroker/src/main/java/org...cketmq/broker/pagecache | 76:111 (37%)67:101 (42%) | view | |
20 | x 2 | common/src/main/java/org/apache/rocketmq/commoncommon/src/main/java/org/apache/rocketmq/common | 1720:1757 (1%)248:285 (13%) | view | |
20 | x 2 | client/src/main/java/org...e/rocketmq/client/traceclient/src/main/java/org...e/rocketmq/client/trace | 78:124 (25%)77:114 (21%) | view | |
20 | x 2 | remoting/src/main/java/o...emoting/protocol/headerremoting/src/main/java/o...emoting/protocol/header | 30:65 (90%)25:60 (95%) | view | |
20 | x 2 | common/src/main/java/org/apache/rocketmq/commonproxy/src/main/java/org/...e/rocketmq/proxy/config | 1720:1757 (1%)1228:1265 (2%) | view | |
20 | x 2 | broker/src/main/java/org...cketmq/broker/pagecachebroker/src/main/java/org...cketmq/broker/pagecache | 67:101 (42%)76:111 (37%) | view | |
20 | x 2 | store/src/main/java/org/.../rocketmq/store/dledgerstore/src/main/java/org/.../rocketmq/store/dledger | 626:647 (2%)770:791 (2%) | view | |
20 | x 2 | remoting/src/main/java/o...emoting/protocol/headerremoting/src/main/java/o...emoting/protocol/header | 52:88 (33%)83:119 (20%) | view | |
20 | x 2 | controller/src/main/java...ocketmq/controller/implcontroller/src/main/java...ocketmq/controller/impl | 191:211 (5%)193:213 (10%) | view | |
19 | x 2 | remoting/src/main/java/o...emoting/protocol/headerremoting/src/main/java/o...emoting/protocol/header | 34:61 (90%)35:62 (70%) | view | |
19 | x 2 | auth/src/main/java/org/a.../authentication/contextauth/src/main/java/org/a...h/authorization/context | 47:74 (54%)31:58 (54%) | view | |
19 | x 2 | store/src/main/java/org/apache/rocketmq/storestore/src/main/java/org/...he/rocketmq/store/queue | 1134:1164 (2%)1106:1136 (2%) | view | |
19 | x 2 | client/src/main/java/org...he/rocketmq/client/implproxy/src/main/java/org/...q/proxy/service/message | 865:885 (<1%)384:403 (5%) | view | |
19 | x 2 | broker/src/main/java/org...cketmq/broker/config/v1broker/src/main/java/org...tmq/broker/subscription | 26:52 (90%)26:52 (90%) | view | |
19 | x 2 | common/src/main/java/org...rocketmq/common/messagecommon/src/main/java/org...rocketmq/common/message | 235:273 (3%)350:389 (3%) | view | |
19 | x 2 | client/src/main/java/org...mq/client/impl/producerclient/src/main/java/org...mq/client/impl/producer | 686:709 (1%)1334:1357 (1%) | view | |
19 | x 2 | tieredstore/src/main/jav...tmq/tieredstore/metricstieredstore/src/main/jav...tmq/tieredstore/metrics | 178:200 (9%)211:233 (9%) | view | |
19 | x 2 | remoting/src/main/java/o...emoting/protocol/headerremoting/src/main/java/o...emoting/protocol/header | 103:139 (21%)108:144 (15%) | view | |
18 | x 2 | store/src/main/java/org/apache/rocketmq/storestore/src/main/java/org/apache/rocketmq/store | 138:170 (7%)234:266 (7%) | view | |
18 | x 2 | example/src/main/java/or...ketmq/example/benchmarkexample/src/main/java/or...ketmq/example/benchmark | 238:261 (6%)355:378 (6%) | view | |
18 | x 2 | broker/src/main/java/org...che/rocketmq/broker/outclient/src/main/java/org...he/rocketmq/client/impl | 1430:1448 (1%)1022:1040 (<1%) | view | |
18 | x 2 | common/src/main/java/org/apache/rocketmq/commoncommon/src/main/java/org...etmq/common/compression | 408:429 (3%)34:55 (33%) | view | |
18 | x 2 | remoting/src/main/java/o...emoting/protocol/headerremoting/src/main/java/o...emoting/protocol/header | 46:75 (43%)46:75 (42%) | view | |
18 | x 2 | tools/src/main/java/org/...tmq/tools/command/topictools/src/main/java/org/...tmq/tools/command/topic | 73:99 (16%)78:103 (16%) | view |
Size | # | Folders | Files | Lines | Code |
---|---|---|---|---|---|
41 | x 2 | broker/src/main/java/org...etmq/broker/transactionstore/src/main/java/org/...he/rocketmq/store/timer | 181:226 235:280 | view | |
23 | x 2 | tools/src/main/java/org/...cketmq/tools/command/hatools/src/main/java/org/...cketmq/tools/command/ha | 68:96 65:93 | view | |
18 | x 2 | auth/src/main/java/org/a...h/authorization/factoryauth/src/main/java/org/a.../authentication/factory | 136:155 133:152 | view | |
16 | x 2 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumer | 275:292 360:377 | view | |
14 | x 2 | controller/src/main/java...che/rocketmq/controllernamesrv/src/main/java/org/apache/rocketmq/namesrv | 128:148 160:180 | view | |
13 | x 2 | tools/src/main/java/org/...cketmq/tools/command/hatools/src/main/java/org/...mq/tools/command/broker | 47:65 68:86 | view | |
13 | x 2 | tools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...tmq/tools/command/topic | 46:64 51:69 | view | |
13 | x 2 | client/src/main/java/org...q/client/consumer/storeclient/src/main/java/org...q/client/consumer/store | 78:93 59:74 | view | |
11 | x 2 | tools/src/main/java/org/...etmq/tools/command/authtools/src/main/java/org/...etmq/tools/command/auth | 50:67 49:66 | view | |
11 | x 2 | auth/src/main/java/org/a...h/authorization/contextauth/src/main/java/org/a.../authentication/context | 32:44 48:60 | view | |
10 | x 3 | tools/src/main/java/org/...cketmq/tools/command/hatools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...mq/tools/command/broker | 48:62 44:58 45:59 | view | |
10 | x 2 | tools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...q/tools/command/message | 56:70 47:60 | view | |
10 | x 2 | tools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...mq/tools/command/broker | 51:65 43:57 | view | |
10 | x 3 | tools/src/main/java/org/...mq/tools/command/offsettools/src/main/java/org/...etmq/tools/command/authtools/src/main/java/org/...etmq/tools/command/auth | 43:57 46:61 46:61 | view | |
10 | x 2 | tools/src/main/java/org/...ools/command/controllertools/src/main/java/org/...q/tools/command/namesrv | 44:58 39:52 | view | |
10 | x 2 | remoting/src/main/java/o...rocketmq/remoting/nettyproxy/src/main/java/org/...rocketmq/proxy/remoting | 212:225 100:113 | view | |
10 | x 3 | example/src/main/java/or...mq/example/tracemessageexample/src/main/java/or...mq/example/tracemessageexample/src/main/java/or...mq/example/tracemessage | 65:77 58:70 84:96 | view | |
9 | x 2 | broker/src/main/java/org/apache/rocketmq/brokerstore/src/main/java/org/apache/rocketmq/store | 2261:2271 2162:2172 | view | |
9 | x 2 | client/src/main/java/org...q/client/consumer/storeclient/src/main/java/org...q/client/consumer/store | 217:228 183:193 | view | |
8 | x 2 | tools/src/main/java/org/...mq/tools/command/exporttools/src/main/java/org/...mq/tools/command/export | 50:60 63:73 | view | |
7 | x 7 | tools/src/main/java/org/...ools/command/connectiontools/src/main/java/org/...tmq/tools/command/topictools/src/main/java/org/...tmq/tools/command/topictools/src/main/java/org/...tools/command/containertools/src/main/java/org/...tools/command/containertools/src/main/java/org/...q/tools/command/namesrvtools/src/main/java/org/...q/tools/command/namesrv | 43:53 66:76 48:58 40:50 40:50 39:48 43:53 | view | |
7 | x 2 | tools/src/main/java/org/...ools/command/connectiontools/src/main/java/org/...tmq/tools/command/topic | 46:56 49:58 | view | |
7 | x 6 | tools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...mq/tools/command/brokertools/src/main/java/org/...mq/tools/command/brokerexample/src/main/java/or...example/benchmark/timer | 41:51 41:51 40:50 52:62 54:64 145:155 | view | |
7 | x 2 | tools/src/main/java/org/.../tools/command/consumertools/src/main/java/org/...tmq/tools/command/topic | 54:64 49:58 | view | |
7 | x 2 | tools/src/main/java/org/...q/tools/command/messagetools/src/main/java/org/...q/tools/command/message | 43:53 38:47 | view | |
7 | x 2 | common/src/main/java/org...e/rocketmq/common/statscommon/src/main/java/org...e/rocketmq/common/stats | 87:95 190:198 | view | |
7 | x 2 | common/src/main/java/org...e/rocketmq/common/statscommon/src/main/java/org...e/rocketmq/common/stats | 97:105 200:208 | view | |
7 | x 2 | broker/src/main/java/org/apache/rocketmq/brokercontainer/src/main/java/...ache/rocketmq/container | 262:270 369:377 | view | |
7 | x 2 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumer | 433:442 1173:1182 | view | |
7 | x 2 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumer | 155:163 79:87 | view | |
7 | x 2 | controller/src/main/java...che/rocketmq/controllernamesrv/src/main/java/org/apache/rocketmq/namesrv | 154:164 229:238 | view | |
7 | x 2 | auth/src/main/java/org/a...h/authorization/contextauth/src/main/java/org/a.../authentication/context | 46:54 62:70 | view | |
6 | x 2 | common/src/main/java/org...rocketmq/common/messagecommon/src/main/java/org...rocketmq/common/message | 61:68 68:75 | view | |
6 | x 3 | broker/src/main/java/org...tmq/broker/subscriptionbroker/src/main/java/org...cketmq/broker/config/v2broker/src/main/java/org...cketmq/broker/config/v1 | 30:37 121:128 30:37 | view | |
6 | x 3 | broker/src/main/java/org...cketmq/broker/config/v1broker/src/main/java/org...cketmq/broker/config/v1broker/src/main/java/org...cketmq/broker/config/v1 | 158:165 164:171 201:208 | view | |
6 | x 2 | broker/src/main/java/org...e/rocketmq/broker/topicclient/src/main/java/org...mq/client/impl/producer | 181:188 457:464 | view | |
6 | x 4 | broker/src/main/java/org...cketmq/broker/processorcontroller/src/main/java...mq/controller/processorcontainer/src/main/java/...ache/rocketmq/containernamesrv/src/main/java/or...ketmq/namesrv/processor | 3312:3319 332:339 277:284 675:682 | view | |
6 | x 2 | store/src/main/java/org/.../rocketmq/store/metricsstore/src/main/java/org/.../rocketmq/store/metrics | 146:153 243:250 | view | |
6 | x 3 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/producer | 106:113 676:683 483:490 | view | |
6 | x 2 | client/src/main/java/org...mq/client/impl/consumerclient/src/main/java/org...mq/client/impl/consumer | 423:430 1163:1170 | view | |
6 | x 2 | remoting/src/main/java/o...rocketmq/remoting/nettyremoting/src/main/java/o...rocketmq/remoting/netty | 341:349 876:884 | view | |
6 | x 2 | remoting/src/main/java/o.../remoting/protocol/bodyremoting/src/main/java/o.../remoting/protocol/body | 65:72 65:72 | view | |
6 | x 2 | auth/src/main/java/org/a...h/authorization/managerauth/src/main/java/org/a.../authentication/manager | 54:61 48:55 | view |