apache / flink-connector-pulsar

Duplication

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

Longest Duplicates

The list of 28 longest duplicates.

See data for all 28 duplicates...

Size	#	Folders	Files	Lines	Code
18	x 2	flink-connector-pulsar/s...or/pulsar/common/config flink-connector-pulsar/s...or/pulsar/common/config	PulsarClientFactory.java PulsarClientFactory.java	129:146 (12%) 201:218 (12%)	view
11	x 2	flink-connector-pulsar/s...k/connector/pulsar/sink flink-connector-pulsar/s...connector/pulsar/source	PulsarSinkOptions.java PulsarSourceOptions.java	272:282 (5%) 506:516 (2%)	view
8	x 2	flink-connector-pulsar/s...ctor/pulsar/sink/config flink-connector-pulsar/s...or/pulsar/source/config	SinkConfiguration.java SourceConfiguration.java	134:143 (11%) 212:221 (7%)	view
7	x 2	flink-connector-pulsar/s...common/schema/factories flink-connector-pulsar/s...common/schema/factories	AvroSchemaFactory.java JSONSchemaFactory.java	53:59 (35%) 46:52 (46%)	view
6	x 2	flink-connector-pulsar/s...r/pulsar/sink/committer flink-connector-pulsar/s...or/pulsar/source/config	PulsarCommittable.java SourceConfiguration.java	50:56 (24%) 212:218 (5%)	view
6	x 2	flink-connector-pulsar/s...r/pulsar/sink/committer flink-connector-pulsar/s...source/enumerator/topic	PulsarCommittable.java TopicRange.java	50:56 (24%) 87:93 (16%)	view
6	x 2	flink-connector-pulsar/s...source/enumerator/topic flink-connector-pulsar/s...tor/pulsar/source/split	TopicRange.java PulsarPartitionSplit.java	87:93 (16%) 101:107 (12%)	view
6	x 2	flink-connector-pulsar/s...r/pulsar/sink/committer flink-connector-pulsar/s...source/enumerator/topic	PulsarCommittable.java TopicPartition.java	50:56 (24%) 153:159 (9%)	view
6	x 2	flink-connector-pulsar/s...r/pulsar/sink/committer flink-connector-pulsar/s...ctor/pulsar/sink/config	PulsarCommittable.java SinkConfiguration.java	50:56 (24%) 134:140 (8%)	view
6	x 2	flink-connector-pulsar/s...ulsar/source/enumerator flink-connector-pulsar/s...ulsar/source/enumerator	PulsarSourceEnumerator.java PulsarSourceEnumerator.java	72:77 (4%) 90:95 (4%)	view
6	x 2	flink-connector-pulsar/s...source/enumerator/topic flink-connector-pulsar/s...tor/pulsar/source/split	TopicPartition.java PulsarPartitionSplit.java	153:159 (9%) 101:107 (12%)	view
6	x 2	flink-connector-pulsar/s...ctor/pulsar/sink/config flink-connector-pulsar/s...source/enumerator/topic	SinkConfiguration.java TopicPartition.java	134:140 (8%) 153:159 (9%)	view
6	x 2	flink-connector-pulsar/s...r/pulsar/sink/committer flink-connector-pulsar/s...tor/pulsar/source/split	PulsarCommittable.java PulsarPartitionSplit.java	50:56 (24%) 101:107 (12%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/common/schema flink-connector-pulsar/s...ctor/pulsar/sink/config	PulsarSchema.java SinkConfiguration.java	197:203 (5%) 134:140 (8%)	view
6	x 2	flink-connector-pulsar/s...ctor/pulsar/sink/config flink-connector-pulsar/s...tor/pulsar/source/split	SinkConfiguration.java PulsarPartitionSplit.java	134:140 (8%) 101:107 (12%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/common/schema flink-connector-pulsar/s...or/pulsar/source/config	PulsarSchema.java SourceConfiguration.java	197:203 (5%) 212:218 (5%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/common/schema flink-connector-pulsar/s...source/enumerator/topic	PulsarSchema.java TopicPartition.java	197:203 (5%) 153:159 (9%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/common/schema flink-connector-pulsar/s...r/pulsar/sink/committer	PulsarSchema.java PulsarCommittable.java	197:203 (5%) 50:56 (24%)	view
6	x 2	flink-connector-pulsar/s...source/enumerator/topic flink-connector-pulsar/s...source/enumerator/topic	TopicPartition.java TopicRange.java	153:159 (9%) 87:93 (16%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/source/config flink-connector-pulsar/s...source/enumerator/topic	SourceConfiguration.java TopicRange.java	212:218 (5%) 87:93 (16%)	view
6	x 2	flink-connector-pulsar/s...ctor/pulsar/sink/config flink-connector-pulsar/s...source/enumerator/topic	SinkConfiguration.java TopicRange.java	134:140 (8%) 87:93 (16%)	view
6	x 2	flink-connector-pulsar/s...lsar/sink/writer/router flink-connector-pulsar/s...lsar/sink/writer/router	KeyHashTopicRouter.java RoundRobinTopicRouter.java	52:57 (30%) 53:58 (33%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/source/config flink-connector-pulsar/s...tor/pulsar/source/split	SourceConfiguration.java PulsarPartitionSplit.java	212:218 (5%) 101:107 (12%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/common/schema flink-connector-pulsar/s...tor/pulsar/source/split	PulsarSchema.java PulsarPartitionSplit.java	197:203 (5%) 101:107 (12%)	view
6	x 2	flink-connector-pulsar/s...k/connector/pulsar/sink flink-connector-pulsar/s...connector/pulsar/source	PulsarSinkOptions.java PulsarSourceOptions.java	113:118 (3%) 194:199 (1%)	view
6	x 2	flink-connector-pulsar/s...connector/pulsar/source flink-connector-pulsar/s...connector/pulsar/source	PulsarSource.java PulsarSource.java	145:150 (7%) 160:165 (7%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/source/config flink-connector-pulsar/s...source/enumerator/topic	SourceConfiguration.java TopicPartition.java	212:218 (5%) 153:159 (9%)	view
6	x 2	flink-connector-pulsar/s...or/pulsar/common/schema flink-connector-pulsar/s...source/enumerator/topic	PulsarSchema.java TopicRange.java	197:203 (5%) 87:93 (16%)	view

Duplicated Units

The list of top 1 duplicated units.

See data for all 1 unit duplicate

Size	#	Folders	Files	Lines	Code
6	x 2	flink-connector-pulsar/s...common/schema/factories flink-connector-pulsar/s...common/schema/factories	AvroSchemaFactory.java JSONSchemaFactory.java	54:61  47:54	view