apache / bookkeeper

Duplication

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

Longest Duplicates

The list of 50 longest duplicates.

See data for all 1,182 duplicates...

Size	#	Folders	Files	Lines	Code
106	x 2	bookkeeper-common/src/ma...bookkeeper/common/stats stream/distributedlog/co...ributedlog/common/stats	BroadCastStatsLogger.java BroadCastStatsLogger.java	33:228 (100%) 33:228 (100%)	view
96	x 2	buildtools/src/main/resources/bookkeeper buildtools/src/main/resources/distributedlog	findbugsExclude.xml findbugsExclude.xml	173:317 (49%) 29:172 (88%)	view
63	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLInputStream.java DLInputStream.java	151:241 (47%) 139:229 (50%)	view
58	x 2	stream/api/src/main/java...pache/bookkeeper/api/kv stream/api/src/main/java...pache/bookkeeper/api/kv	PTableWriteView.java TableWriteView.java	91:158 (31%) 95:162 (33%)	view
42	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongLongHashMap.java ConcurrentLongLongPairHashMap.java	59:125 (7%) 58:125 (10%)	view
42	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongLongHashMap.java ConcurrentLongLongPairHashMap.java	172:233 (7%) 172:233 (10%)	view
40	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	RackawareEnsemblePlacementPolicy.java ZoneawareEnsemblePlacementPolicy.java	95:151 (19%) 60:116 (58%)	view
39	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongHashSet.java ConcurrentLongLongPairHashMap.java	58:119 (12%) 64:125 (9%)	view
39	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongHashSet.java ConcurrentLongLongHashMap.java	58:119 (12%) 64:125 (7%)	view
36	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLOutputStream.java DLOutputStream.java	42:97 (53%) 42:97 (53%)	view
35	x 2	tools/perf/src/main/java...kkeeper/tools/perf/dlog tools/perf/src/main/java...eper/tools/perf/journal	PerfWriter.java JournalWriter.java	336:384 (12%) 418:466 (9%)	view
33	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLInputStream.java DLInputStream.java	37:85 (24%) 36:84 (26%)	view
32	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	BatchedReadOp.java PendingReadOp.java	256:305 (17%) 345:396 (14%)	view
32	x 2	bookkeeper-server/src/ma.../apache/bookkeeper/sasl bookkeeper-server/src/ma.../apache/bookkeeper/sasl	SASLBookieAuthProviderFactory.java SaslClientState.java	175:212 (27%) 132:169 (29%)	view
31	x 2	bookkeeper-server/src/ma.../apache/bookkeeper/meta bookkeeper-server/src/ma.../apache/bookkeeper/meta	LedgerMetadataSerDe.java LedgerMetadataSerDe.java	158:197 (9%) 227:264 (9%)	view
31	x 2	stream/clients/java/kv/s...kkeeper/clients/impl/kv stream/clients/java/kv/s...kkeeper/clients/impl/kv	PByteBufSimpleTableImpl.java PByteBufTableRangeImpl.java	250:293 (16%) 204:247 (18%)	view
30	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLOutputStream.java DLOutputStream.java	99:140 (44%) 99:140 (44%)	view
29	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongHashSet.java ConcurrentLongLongHashMap.java	167:214 (8%) 186:233 (5%)	view
29	x 2	stream/clients/python stream/clients/python	nox.py noxfile.py	49:104 (60%) 56:110 (58%)	view
29	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLInputStream.java DLInputStream.java	93:137 (21%) 91:139 (23%)	view
29	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongHashSet.java ConcurrentLongLongPairHashMap.java	167:214 (8%) 186:233 (6%)	view
27	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongLongHashMap.java ConcurrentLongLongPairHashMap.java	392:420 (5%) 336:364 (6%)	view
24	x 2	bookkeeper-server/src/ma...apache/bookkeeper/proto bookkeeper-server/src/ma...apache/bookkeeper/proto	BookieProtocol.java BookieProtocol.java	516:551 (7%) 584:619 (7%)	view
23	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	LedgerHandle.java LedgerHandle.java	1051:1077 (2%) 1085:1111 (2%)	view
23	x 2	bookkeeper-server/src/ma...pache/bookkeeper/bookie bookkeeper-server/src/ma...pache/bookkeeper/bookie	InterleavedLedgerStorage.java SortedLedgerStorage.java	697:729 (5%) 431:463 (8%)	view
23	x 2	stream/distributedlog/co.../distributedlog/auditor stream/distributedlog/co.../distributedlog/auditor	DLAuditor.java DLAuditor.java	130:153 (5%) 469:492 (5%)	view
22	x 2	bookkeeper-server/src/ma...pache/bookkeeper/bookie bookkeeper-server/src/ma...eper/bookie/storage/ldb	InterleavedLedgerStorage.java SingleDirectoryDbLedgerStorage.java	257:296 (5%) 273:312 (3%)	view
22	x 2	metadata-drivers/etcd/sr...ookkeeper/metadata/etcd stream/common/src/main/j.../bookkeeper/common/util	EtcdUtils.java Bytes.java	178:209 (22%) 33:64 (95%)	view
21	x 2	stats/bookkeeper-stats-p...e/bookkeeper/stats/otel stats/bookkeeper-stats-p...keeper/stats/prometheus	OtelMetricsProvider.java PrometheusMetricsProvider.java	125:147 (30%) 225:247 (16%)	view
21	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	BatchedReadOp.java PendingReadOp.java	217:252 (11%) 296:336 (9%)	view
21	x 2	bookkeeper-dist/src/assemble bookkeeper-dist/src/assemble	bin-all.xml bin-server.xml	17:42 (26%) 17:42 (30%)	view
21	x 2	bookkeeper-server/src/ma...ols/cli/commands/bookie bookkeeper-server/src/ma...ols/cli/commands/bookie	FlipBookieIdCommand.java UpdateBookieInLedgerCommand.java	113:143 (23%) 120:150 (21%)	view
21	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongLongHashMap.java ConcurrentOpenHashMap.java	749:781 (3%) 562:598 (5%)	view
20	x 2	bookkeeper-proto/src/main/proto bookkeeper-proto/src/main/proto	proto BookkeeperProtocol.proto DataFormats.proto	1:22 (9%) 1:23 (16%)	view
19	x 2	stream/common/src/main/j.../bookkeeper/common/hash stream/common/src/main/j.../bookkeeper/common/hash	Murmur3.java Murmur3.java	238:261 (6%) 354:377 (6%)	view
19	x 2	stream/statelib/src/main...eeper/statelib/api/mvcc stream/statelib/src/main...eeper/statelib/api/mvcc	MVCCAsyncStore.java MVCCAsyncStore.java	355:375 (5%) 388:408 (5%)	view
19	x 2	stream/clients/java/all/...ache/bookkeeper/clients stream/clients/java/all/...ache/bookkeeper/clients	SimpleStorageClientImpl.java StorageClientImpl.java	85:111 (30%) 94:120 (21%)	view
19	x 2	site3/website site3/website	docusaurus.config.js docusaurus.config.js	124:149 (8%) 240:265 (8%)	view
19	x 2	stream/clients/python/bookkeeper/common stream/clients/python/bookkeeper/common	constants.py constants.py	23:41 (37%) 45:63 (37%)	view
19	x 2	stream/clients/java/base...ookkeeper/clients/utils stream/storage/impl/src/...okkeeper/stream/storage	ClientResources.java StorageResources.java	78:101 (28%) 97:120 (32%)	view
18	x 2	stream/proto/src/main/proto stream/proto/src/main/proto	proto common.proto kv.proto	1:18 (72%) 1:18 (31%)	view
18	x 2	stream/proto/src/main/proto stream/proto/src/main/proto	proto common.proto kv_store.proto	1:18 (72%) 1:18 (29%)	view
18	x 2	stream/proto/src/main/proto stream/proto/src/main/proto	proto cluster.proto kv_store.proto	1:18 (58%) 1:18 (29%)	view
18	x 2	stream/proto/src/main/proto stream/statelib/src/main/proto	proto storage.proto kv.proto	1:18 (9%) 1:18 (35%)	view
18	x 2	stream/proto/src/main/proto stream/proto/src/main/proto	proto common.proto storage.proto	1:18 (72%) 1:18 (9%)	view
18	x 2	stream/proto/src/main/proto stream/proto/src/main/proto	proto kv_store.proto stream.proto	1:18 (29%) 1:18 (10%)	view
18	x 2	metadata-drivers/etcd/sr...r/metadata/etcd/helpers metadata-drivers/etcd/sr...r/metadata/etcd/helpers	KeySetReader.java ValueStream.java	257:279 (10%) 285:307 (9%)	view
18	x 2	stream/proto/src/main/proto stream/tests-common/src/main/proto	proto kv_rpc.proto rpc.proto	1:18 (6%) 1:18 (50%)	view
18	x 2	stream/proto/src/main/proto stream/proto/src/main/proto	proto kv_rpc.proto kv_store.proto	1:18 (6%) 1:18 (29%)	view
18	x 2	stream/proto/src/main/proto stream/proto/src/main/proto	proto cluster.proto kv_rpc.proto	1:18 (58%) 1:18 (6%)	view

Duplicated Units

The list of top 50 duplicated units.

See data for all 54 unit duplicates...

Size	#	Folders	Files	Lines	Code
35	x 2	bookkeeper-server/src/ma.../apache/bookkeeper/sasl bookkeeper-server/src/ma.../apache/bookkeeper/sasl	SASLBookieAuthProviderFactory.java SaslClientState.java	182:218  139:175	view
34	x 2	bookkeeper-common/src/ma...bookkeeper/common/stats stream/distributedlog/co...ributedlog/common/stats	BroadCastStatsLogger.java BroadCastStatsLogger.java	107:148  107:148	view
33	x 2	bookkeeper-common/src/ma...bookkeeper/common/stats stream/distributedlog/co...ributedlog/common/stats	BroadCastStatsLogger.java BroadCastStatsLogger.java	63:104  63:104	view
31	x 2	stream/api/src/main/java...pache/bookkeeper/api/kv stream/api/src/main/java...pache/bookkeeper/api/kv	TableWriteView.java PTableWriteView.java	104:136  100:132	view
30	x 2	tools/perf/src/main/java...eper/tools/perf/journal tools/perf/src/main/java...kkeeper/tools/perf/dlog	JournalWriter.java PerfWriter.java	427:469  345:387	view
28	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLInputStream.java DLInputStream.java	186:219  174:207	view
27	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLInputStream.java DLInputStream.java	152:183  140:171	view
24	x 2	stream/api/src/main/java...pache/bookkeeper/api/kv stream/api/src/main/java...pache/bookkeeper/api/kv	TableWriteView.java PTableWriteView.java	138:163  134:159	view
23	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLInputStream.java DLInputStream.java	108:135  106:133	view
19	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	BatchedReadOp.java PendingReadOp.java	256:282  345:371	view
19	x 2	stats/bookkeeper-stats-p...keeper/stats/prometheus stats/bookkeeper-stats-p...e/bookkeeper/stats/otel	PrometheusMetricsProvider.java OtelMetricsProvider.java	229:249  129:149	view
18	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentOpenHashMap.java ConcurrentLongHashMap.java	147:168  158:179	view
18	x 3	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentOpenHashSet.java ConcurrentLongLongPairHashMap.java ConcurrentLongLongHashMap.java	144:165  171:192  171:192	view
14	x 2	metadata-drivers/etcd/sr...r/metadata/etcd/helpers metadata-drivers/etcd/sr...r/metadata/etcd/helpers	ValueStream.java KeySetReader.java	246:261  228:243	view
14	x 2	metadata-drivers/etcd/sr...r/metadata/etcd/helpers metadata-drivers/etcd/sr...r/metadata/etcd/helpers	ValueStream.java KeySetReader.java	285:300  257:272	view
14	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	BatchedReadOp.java PendingReadOp.java	285:303  374:394	view
14	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	ZoneawareEnsemblePlacementPolicy.java RackawareEnsemblePlacementPolicy.java	99:114  134:149	view
13	x 2	circe-checksum/src/main/...m/scurrilous/circe/impl circe-checksum/src/main/...m/scurrilous/circe/impl	AbstractIncrementalIntHash.java AbstractIncrementalLongHash.java	72:86  72:86	view
13	x 2	circe-checksum/src/main/...m/scurrilous/circe/impl circe-checksum/src/main/...m/scurrilous/circe/impl	AbstractStatelessIntHash.java AbstractStatelessLongHash.java	47:61  47:61	view
21	x 2	stream/clients/python stream/clients/python	noxfile.py nox.py	0:0  0:0	view
12	x 2	stream/server/src/main/j...ookkeeper/stream/server bookkeeper-server/src/ma...pache/bookkeeper/server	StorageServer.java EmbeddedServer.java	426:439  512:525	view
12	x 2	stream/storage/impl/src/.../stream/storage/impl/kv stream/statelib/src/main...eper/statelib/impl/mvcc	TableStoreUtils.java MVCCUtils.java	282:295  243:256	view
12	x 3	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentOpenHashMap.java ConcurrentLongLongPairHashMap.java ConcurrentLongLongHashMap.java	495:509  560:574  800:814	view
11	x 2	tools/perf/src/main/java...eper/tools/perf/journal tools/perf/src/main/java...kkeeper/tools/perf/dlog	JournalWriter.java PerfWriter.java	505:518  406:419	view
11	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	BatchedReadOp.java PendingReadOp.java	237:254  321:338	view
11	x 2	bookkeeper-server/src/ma.../apache/bookkeeper/sasl bookkeeper-server/src/ma.../apache/bookkeeper/sasl	SASLClientProviderFactory.java SASLBookieAuthProviderFactory.java	117:129  109:121	view
10	x 2	bookkeeper-common/src/ma.../bookkeeper/common/conf bookkeeper-server/src/ma.../apache/bookkeeper/conf	ComponentConfiguration.java AbstractConfiguration.java	309:320  1285:1296	view
10	x 2	tools/perf/src/main/java...kkeeper/tools/perf/dlog tools/perf/src/main/java...kkeeper/tools/perf/dlog	PerfWriter.java PerfReaderBase.java	181:193  107:119	view
9	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLInputStream.java DLInputStream.java	93:106  91:104	view
8	x 3	stream/common/src/main/j.../bookkeeper/common/util stream/statelib/src/main...ookkeeper/statelib/impl metadata-drivers/etcd/sr...ookkeeper/metadata/etcd	Bytes.java Bytes.java EtcdUtils.java	33:42  35:44  178:187	view
8	x 3	stream/common/src/main/j.../bookkeeper/common/util stream/statelib/src/main...ookkeeper/statelib/impl metadata-drivers/etcd/sr...ookkeeper/metadata/etcd	Bytes.java Bytes.java EtcdUtils.java	56:65  75:84  201:210	view
8	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLOutputStream.java DLOutputStream.java	124:133  124:133	view
8	x 2	bookkeeper-server/src/ma...ls/cli/commands/bookies bookkeeper-server/src/ma...per/server/http/service	ClusterInfoCommand.java ClusterInfoService.java	99:109  102:112	view
8	x 5	bookkeeper-server/src/ma...ols/cli/commands/cookie bookkeeper-server/src/ma...ols/cli/commands/cookie bookkeeper-server/src/ma...ols/cli/commands/cookie bookkeeper-server/src/ma...ols/cli/commands/cookie bookkeeper-server/src/ma...ols/cli/commands/cookie	UpdateCookieCommand.java GetCookieCommand.java DeleteCookieCommand.java GenerateCookieCommand.java CreateCookieCommand.java	81:90  71:80  70:79  112:121  78:87	view
8	x 2	bookkeeper-server/src/ma...ols/cli/commands/bookie bookkeeper-server/src/ma...ols/cli/commands/bookie	ConvertToDBStorageCommand.java ConvertToInterleavedStorageCommand.java	117:126  178:187	view
8	x 2	bookkeeper-server/src/ma.../bookkeeper/replication bookkeeper-server/src/ma.../bookkeeper/replication	Auditor.java AuditorTask.java	587:598  109:120	view
8	x 2	bookkeeper-server/src/ma...keeper/util/collections bookkeeper-server/src/ma...keeper/util/collections	ConcurrentLongLongPairHashMap.java ConcurrentLongLongHashMap.java	645:657  880:892	view
8	x 2	bookkeeper-server/src/ma.../apache/bookkeeper/meta bookkeeper-server/src/ma.../apache/bookkeeper/meta	ZkLedgerIdGenerator.java FlatLedgerManager.java	125:134  72:81	view
7	x 2	stream/api/src/main/java...okkeeper/api/kv/impl/op stream/api/src/main/java...okkeeper/api/kv/impl/op	DeleteOpImpl.java RangeOpImpl.java	59:68  59:68	view
7	x 2	stream/common/src/main/j...eeper/common/grpc/stats stream/common/src/main/j...eeper/common/grpc/stats	ServerStats.java ClientStats.java	88:96  88:96	view
7	x 5	stream/clients/java/kv/s...kkeeper/clients/impl/kv stream/clients/java/kv/s...kkeeper/clients/impl/kv stream/clients/java/kv/s...kkeeper/clients/impl/kv stream/clients/java/kv/s...kkeeper/clients/impl/kv stream/clients/java/kv/s...kkeeper/clients/impl/kv	PutRequestProcessor.java IncrementRequestProcessor.java TxnRequestProcessor.java RangeRequestProcessor.java DeleteRequestProcessor.java	65:73  65:73  65:73  65:73  65:73	view
7	x 2	bookkeeper-server/src/ma.../apache/bookkeeper/util bookkeeper-server/src/ma.../apache/bookkeeper/util	StringEntryFormatter.java HexDumpEntryFormatter.java	37:45  45:53	view
7	x 2	bookkeeper-server/src/ma...pache/bookkeeper/client bookkeeper-server/src/ma...pache/bookkeeper/client	BatchedReadOp.java PendingReadOp.java	221:230  300:309	view
6	x 2	bookkeeper-common/src/ma.../bookkeeper/common/util bookkeeper-server/src/ma.../apache/bookkeeper/util	SafeRunnable.java SafeRunnable.java	56:63  39:46	view
6	x 2	bookkeeper-common/src/ma...bookkeeper/common/stats stream/distributedlog/co...ributedlog/common/stats	BroadCastStatsLogger.java BroadCastStatsLogger.java	167:176  167:176	view
6	x 2	bookkeeper-common/src/ma...bookkeeper/common/stats stream/distributedlog/co...ributedlog/common/stats	OpStatsListener.java OpStatsListener.java	33:40  32:39	view
6	x 10	tools/stream/src/main/ja...ream/cli/commands/table tools/stream/src/main/ja...ream/cli/commands/table tools/stream/src/main/ja...ream/cli/commands/table tools/stream/src/main/ja...ream/cli/commands/table tools/stream/src/main/ja...ream/cli/commands/table tools/stream/src/main/ja...ream/cli/commands/table tools/stream/src/main/ja...ream/cli/commands/table tools/stream/src/main/ja.../cli/commands/namespace tools/stream/src/main/ja.../cli/commands/namespace tools/stream/src/main/ja.../cli/commands/namespace	DeleteTableCommand.java CreateTableCommand.java DelCommand.java GetTableCommand.java PutCommand.java GetCommand.java IncrementCommand.java CreateNamespaceCommand.java GetNamespaceCommand.java DeleteNamespaceCommand.java	48:55  61:68  51:58  50:57  49:56  56:63  49:56  49:56  49:56  48:55	view
6	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLInputStream.java DLInputStream.java	235:242  223:230	view
6	x 2	stream/distributedlog/io...pache/distributedlog/fs stream/statelib/src/main...rocksdb/checkpoint/dlog	DLOutputStream.java DLOutputStream.java	114:121  114:121	view
6	x 2	stream/distributedlog/co...e/distributedlog/thrift stream/distributedlog/co...e/distributedlog/thrift	BKDLConfigFormat.java AccessControlEntry.java	1010:1018  595:603	view