apache / incubator-pekko-connectors
Duplication

Places in code with 6 or more lines that are exactly the same.

Intro
Learn more...
Duplication Overall
system9% (3,196 lines)
dependency graphs: 2D graph | 3D graph | 3D graph (with duplicates)...
Duplication per Extension
scala9% (3,196 lines)
Duplication per Component (primary)
mqtt-streaming20% (634 lines)
ftp32% (473 lines)
google-cloud-bigquery-storage31% (256 lines)
s35% (242 lines)
google-fcm20% (195 lines)
google-cloud-storage10% (157 lines)
elasticsearch12% (149 lines)
hdfs18% (122 lines)
amqp7% (95 lines)
mqtt-streaming-bench52% (88 lines)
csv10% (84 lines)
jms3% (78 lines)
huawei-push-kit9% (66 lines)
pravega6% (62 lines)
couchbase7% (62 lines)
solr12% (58 lines)
mqtt7% (51 lines)
reference18% (48 lines)
google-cloud-pub-sub-grpc13% (48 lines)
sqs3% (32 lines)
google-cloud-pub-sub6% (32 lines)
google-common2% (27 lines)
google-cloud-bigquery1% (23 lines)
orientdb6% (22 lines)
text13% (20 lines)
xml3% (16 lines)
influxdb3% (16 lines)
slick9% (16 lines)
cassandra2% (12 lines)
mongodb6% (12 lines)
kinesis0% (0 lines)
geode0% (0 lines)
sse0% (0 lines)
sns0% (0 lines)
udp0% (0 lines)
file0% (0 lines)
azure-storage-queue0% (0 lines)
dynamodb0% (0 lines)
csv-bench0% (0 lines)
testkit0% (0 lines)
simple-codecs0% (0 lines)
project0% (0 lines)
awslambda0% (0 lines)
avroparquet0% (0 lines)
spring-web0% (0 lines)
scripts0% (0 lines)
unix-domain-socket0% (0 lines)
hbase0% (0 lines)
kudu0% (0 lines)
aws-event-bridge0% (0 lines)
json-streaming0% (0 lines)
ironmq0% (0 lines)
ROOT0% (0 lines)

Duplication Between Components (50+ lines)

G google-fcm google-fcm huawei-push-kit huawei-push-kit google-fcm--huawei-push-kit 116

Download: SVG DOT (open online Graphviz editor)

Open 3D force graph...

Show more details on duplication between components...
Longest Duplicates
The list of 50 longest duplicates.
See data for all 277 duplicates...
Size#FoldersFilesLinesCode
63 x 2 ftp/src/main/scala/org/a.../connectors/ftp/javadsl
ftp/src/main/scala/org/a.../connectors/ftp/javadsl
378:467 (24%)
473:562 (24%)
view
60 x 2 ftp/src/main/scala/org/a.../connectors/ftp/javadsl
ftp/src/main/scala/org/a.../connectors/ftp/javadsl
284:367 (23%)
378:461 (23%)
view
60 x 2 ftp/src/main/scala/org/a.../connectors/ftp/javadsl
ftp/src/main/scala/org/a.../connectors/ftp/javadsl
284:367 (23%)
473:556 (23%)
view
39 x 2 ftp/src/main/scala/org/a...connectors/ftp/scaladsl
ftp/src/main/scala/org/a...connectors/ftp/scaladsl
278:331 (25%)
335:388 (25%)
view
39 x 2 ftp/src/main/scala/org/a...connectors/ftp/scaladsl
ftp/src/main/scala/org/a...connectors/ftp/scaladsl
220:273 (25%)
278:331 (25%)
view
39 x 2 ftp/src/main/scala/org/a...connectors/ftp/scaladsl
ftp/src/main/scala/org/a...connectors/ftp/scaladsl
220:273 (25%)
335:388 (25%)
view
36 x 2 google-cloud-bigquery-st...igquery/storage/javadsl
google-cloud-bigquery-st...igquery/storage/javadsl
65:105 (23%)
64:104 (25%)
view
29 x 2 csv/src/main/scala/org/a...eam/connectors/csv/impl
csv/src/main/scala/org/a...eam/connectors/csv/impl
230:258 (10%)
262:290 (10%)
view
27 x 2 google-cloud-bigquery-st...igquery/storage/javadsl
google-cloud-bigquery-st...igquery/storage/javadsl
33:63 (17%)
32:62 (18%)
view
25 x 2 google-cloud-storage/src...ors/googlecloud/storage
google-cloud-storage/src...ors/googlecloud/storage
90:114 (20%)
117:141 (20%)
view
22 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
269:290 (2%)
294:315 (2%)
view
22 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
269:290 (2%)
317:338 (2%)
view
22 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
294:315 (2%)
317:338 (2%)
view
21 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
112:132 (3%)
138:158 (3%)
view
20 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
88:107 (3%)
139:158 (3%)
view
20 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
88:107 (3%)
113:132 (3%)
view
18 x 2 google-fcm/src/main/scal.../firebase/fcm/v1/models
huawei-push-kit/src/main...s/huawei/pushkit/models
28:57 (90%)
26:54 (90%)
view
16 x 2 google-fcm/src/main/scal...ors/google/firebase/fcm
huawei-push-kit/src/main...s/huawei/pushkit/models
111:132 (12%)
33:54 (80%)
view
16 x 2 google-fcm/src/main/scal...ors/google/firebase/fcm
google-fcm/src/main/scal.../firebase/fcm/v1/models
111:132 (12%)
36:57 (80%)
view
16 x 2 ftp/src/main/scala/org/a...eam/connectors/ftp/impl
ftp/src/main/scala/org/a...eam/connectors/ftp/impl
107:127 (6%)
230:250 (6%)
view
16 x 2 google-fcm/src/main/scal...oogle/firebase/fcm/impl
google-fcm/src/main/scal...le/firebase/fcm/v1/impl
42:64 (66%)
37:59 (84%)
view
16 x 2 pravega/src/main/scala/o...ream/connectors/pravega
pravega/src/main/scala/o...ream/connectors/pravega
399:420 (4%)
520:541 (4%)
view
15 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
645:659 (2%)
715:729 (2%)
view
15 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
568:582 (2%)
679:693 (2%)
view
14 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
663:676 (1%)
734:747 (1%)
view
14 x 2 google-fcm/src/main/scal...oogle/firebase/fcm/impl
google-fcm/src/main/scal...le/firebase/fcm/v1/impl
38:58 (31%)
32:52 (7%)
view
13 x 2 google-cloud-storage/src...ors/googlecloud/storage
google-cloud-storage/src...ors/googlecloud/storage
57:69 (10%)
102:114 (10%)
view
13 x 2 amqp/src/main/scala/org/...am/connectors/amqp/impl
amqp/src/main/scala/org/...am/connectors/amqp/impl
149:163 (9%)
157:171 (12%)
view
13 x 2 ftp/src/main/scala/org/a...eam/connectors/ftp/impl
ftp/src/main/scala/org/a...eam/connectors/ftp/impl
41:60 (44%)
36:55 (54%)
view
13 x 2 google-cloud-storage/src...ors/googlecloud/storage
google-cloud-storage/src...ors/googlecloud/storage
57:69 (10%)
129:141 (10%)
view
13 x 2 mqtt-streaming/src/main/...mqtt/streaming/scaladsl
mqtt-streaming/src/main/...mqtt/streaming/scaladsl
344:358 (2%)
687:701 (2%)
view
13 x 2 csv/src/main/scala/org/a...eam/connectors/csv/impl
csv/src/main/scala/org/a...eam/connectors/csv/impl
340:352 (4%)
356:368 (4%)
view
13 x 2 ftp/src/main/scala/org/a...eam/connectors/ftp/impl
ftp/src/main/scala/org/a...eam/connectors/ftp/impl
306:325 (5%)
361:380 (5%)
view
13 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
452:464 (1%)
738:750 (1%)
view
12 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
592:603 (2%)
608:619 (2%)
view
12 x 2 elasticsearch/src/main/s...tors/elasticsearch/impl
elasticsearch/src/main/s...tors/elasticsearch/impl
62:77 (26%)
54:69 (30%)
view
12 x 2 google-cloud-storage/src...ors/googlecloud/storage
google-cloud-storage/src...ors/googlecloud/storage
101:112 (15%)
116:127 (15%)
view
12 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
312:323 (2%)
356:367 (2%)
view
11 x 2 mqtt-streaming-bench/src.../stream/connectors/mqtt
mqtt-streaming-bench/src...nnectors/mqtt/streaming
23:43 (14%)
23:43 (12%)
view
11 x 2 hdfs/src/main/scala/org/...connectors/hdfs/javadsl
hdfs/src/main/scala/org/...connectors/hdfs/javadsl
178:188 (10%)
213:223 (10%)
view
11 x 2 ftp/src/main/scala/org/a...eam/connectors/ftp/impl
ftp/src/main/scala/org/a...eam/connectors/ftp/impl
212:225 (4%)
361:375 (4%)
view
11 x 2 google-fcm/src/main/scal...ors/google/firebase/fcm
s3/src/main/scala/org/ap...ko/stream/connectors/s3
176:189 (5%)
101:114 (2%)
view
11 x 2 google-cloud-bigquery-st...gquery/storage/scaladsl
google-cloud-bigquery-st...gquery/storage/scaladsl
46:57 (18%)
46:57 (18%)
view
11 x 2 google-common/src/main/s.../connectors/google/http
s3/src/main/scala/org/ap...ream/connectors/s3/impl
52:62 (39%)
1094:1104 (1%)
view
11 x 2 mqtt-streaming-bench/src.../stream/connectors/mqtt
mqtt-streaming-bench/src...nnectors/mqtt/streaming
112:125 (14%)
125:138 (12%)
view
11 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
415:425 (1%)
452:462 (1%)
view
11 x 2 mqtt-streaming/src/main/...ors/mqtt/streaming/impl
mqtt-streaming/src/main/...ors/mqtt/streaming/impl
415:425 (1%)
738:748 (1%)
view
11 x 2 mqtt-streaming/src/main/...mqtt/streaming/scaladsl
mqtt-streaming/src/main/...mqtt/streaming/scaladsl
375:388 (2%)
722:735 (2%)
view
11 x 2 elasticsearch/src/main/s...tors/elasticsearch/impl
elasticsearch/src/main/s...tors/elasticsearch/impl
169:180 (5%)
202:213 (5%)
view
11 x 2 elasticsearch/src/main/s...s/elasticsearch/javadsl
elasticsearch/src/main/s...s/elasticsearch/javadsl
116:128 (11%)
148:160 (11%)
view
Duplicated Units
The list of top 3 duplicated units.
See data for all 3 unit duplicates...
Size#FoldersFilesLinesCode
11 x 2 google-fcm/src/main/scal...le/firebase/fcm/v1/impl
google-fcm/src/main/scal...oogle/firebase/fcm/impl
37:50 
42:55 
view
7 x 2 mqtt-streaming-bench/src.../stream/connectors/mqtt
mqtt-streaming-bench/src...nnectors/mqtt/streaming
27:35 
27:35 
view
7 x 2 mqtt-streaming-bench/src.../stream/connectors/mqtt
mqtt-streaming-bench/src...nnectors/mqtt/streaming
113:121 
126:134 
view