awslabs / amazon-kinesis-connector-flink

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

Intro

For duplication, we look at places in code where there are 6 or more lines of code that are exactly the same.
Before duplication is calculated, the code is cleaned to remove empty lines, comments, and frequently duplicated constructs such as imports.
You should aim at having as little as possible (<5%) of duplicated code as high-level of duplication can lead to maintenance difficulties, poor factoring, and logical contradictions.

Duplication Overall

2% duplication:

4,545 cleaned lines of cleaned code (without empty lines, comments, and frequently duplicated constructs such as imports)
128 duplicated lines

13 duplicates

Duplication per Extension

Duplication per Component (primary)

Longest Duplicates

The list of 13 longest duplicates.

See data for all 13 duplicates...

Size	#	Folders	Files	Lines	Code
14	x 2	amazon-kinesis-connector.../connectors/flink/model amazon-kinesis-connector.../connectors/flink/model	KinesisStreamShard.java StreamShardHandle.java	57:81 (28%) 50:74 (38%)	view
7	x 2	amazon-kinesis-connector.../connectors/flink/table amazon-kinesis-connector.../connectors/flink/table	KinesisOptions.java KinesisOptions.java	150:158 (5%) 170:178 (5%)	view
7	x 2	amazon-kinesis-connector...nectors/flink/internals amazon-kinesis-connector...nectors/flink/internals	KinesisDataFetcher.java KinesisDataFetcher.java	563:569 (1%) 672:678 (1%)	view
6	x 2	amazon-kinesis-connector...rnals/publisher/polling amazon-kinesis-connector...rnals/publisher/polling	AdaptivePollingRecordPublisher.java PollingRecordPublisher.java	53:58 (14%) 81:86 (7%)	view
6	x 2	amazon-kinesis-connector...inesis/connectors/flink amazon-kinesis-connector.../connectors/flink/table	FixedKinesisPartitioner.java KinesisDynamicSink.java	61:67 (20%) 141:147 (7%)	view
6	x 2	amazon-kinesis-connector...nectors/flink/internals amazon-kinesis-connector...nectors/flink/internals	DynamoDBStreamsDataFetcher.java KinesisDataFetcher.java	79:84 (13%) 382:387 (<1%)	view
6	x 2	amazon-kinesis-connector.../connectors/flink/table amazon-kinesis-connector.../connectors/flink/table	KinesisDynamicSink.java KinesisDynamicSource.java	141:147 (7%) 133:139 (9%)	view
6	x 2	amazon-kinesis-connector...inesis/connectors/flink amazon-kinesis-connector...inesis/connectors/flink	FlinkDynamoDBStreamsConsumer.java FlinkKinesisConsumer.java	72:77 (23%) 466:471 (3%)	view
6	x 2	amazon-kinesis-connector.../connectors/flink/table amazon-kinesis-connector.../connectors/flink/table	KinesisDynamicSink.java RowDataFieldsKinesisPartitioner.java	141:147 (7%) 250:256 (4%)	view
6	x 2	amazon-kinesis-connector...inesis/connectors/flink amazon-kinesis-connector.../connectors/flink/table	FixedKinesisPartitioner.java RowDataFieldsKinesisPartitioner.java	61:67 (20%) 250:256 (4%)	view
6	x 2	amazon-kinesis-connector.../connectors/flink/table amazon-kinesis-connector.../connectors/flink/table	KinesisDynamicSource.java RowDataFieldsKinesisPartitioner.java	133:139 (9%) 250:256 (4%)	view
6	x 2	amazon-kinesis-connector...inesis/connectors/flink amazon-kinesis-connector.../connectors/flink/table	FixedKinesisPartitioner.java KinesisDynamicSource.java	61:67 (20%) 133:139 (9%)	view
6	x 2	amazon-kinesis-connector...rnals/publisher/polling amazon-kinesis-connector...rnals/publisher/polling	PollingRecordPublisherFactory.java PollingRecordPublisherFactory.java	75:80 (17%) 83:88 (17%)	view

Duplicated Units

The list of top 1 duplicated units.

See data for all 1 unit duplicate

Size	#	Folders	Files	Lines	Code
7	x 2	amazon-kinesis-connector.../connectors/flink/model amazon-kinesis-connector.../connectors/flink/model	StreamShardHandle.java KinesisStreamShard.java	49:59 56:66	view